org.projectodd.wunderboss.messaging.hornetq

Class HQTopic

java.lang.Object

org.projectodd.wunderboss.messaging.hornetq.HQDestination

org.projectodd.wunderboss.messaging.hornetq.HQTopic

All Implemented Interfaces:

Destination, Topic

public class HQTopic
extends HQDestination
implements Topic

Nested Class Summary

Nested classes/interfaces inherited from interface org.projectodd.wunderboss.messaging.Topic

Topic.SubscribeOption, Topic.UnsubscribeOption

Nested classes/interfaces inherited from interface org.projectodd.wunderboss.messaging.Destination

Destination.ListenOption, Destination.MessageOpOption, Destination.PublishOption, Destination.ReceiveOption

Constructor Summary

Constructors

Constructor and Description
HQTopic(String name, javax.jms.Destination destination, HQMessaging broker)

Method Summary

Methods

Modifier and Type	Method and Description
protected HQSpecificContext	context(String id, Object context)
String	fullName()
static String	fullName(String name)
javax.jms.Destination	jmsDestination()
String	jmsName()
static String	jmsName(String name)
Listener	subscribe(String id, MessageHandler handler, Codecs codecs, Map<Topic.SubscribeOption,Object> options)
void	unsubscribe(String id, Map<Topic.UnsubscribeOption,Object> options)

Methods inherited from class org.projectodd.wunderboss.messaging.hornetq.HQDestination

broker, context, fillInProperties, isJndiName, jndiName, listen, name, publish, publish, receive, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.projectodd.wunderboss.messaging.Destination

listen, name, publish, receive, stop

Constructor Detail

HQTopic

public HQTopic(String name,
       javax.jms.Destination destination,
       HQMessaging broker)

Method Detail

subscribe

public Listener subscribe(String id,
                 MessageHandler handler,
                 Codecs codecs,
                 Map<Topic.SubscribeOption,Object> options)
                   throws Exception

Specified by:

subscribe in interface Topic

Throws:

Exception

unsubscribe

public void unsubscribe(String id,
               Map<Topic.UnsubscribeOption,Object> options)
                 throws Exception

Specified by:

unsubscribe in interface Topic

Throws:

Exception

jmsName

public static String jmsName(String name)

fullName

public static String fullName(String name)

jmsName

public String jmsName()

Specified by:

jmsName in class HQDestination

fullName

public String fullName()

Specified by:

fullName in class HQDestination

jmsDestination

public javax.jms.Destination jmsDestination()

Overrides:

jmsDestination in class HQDestination

context

protected HQSpecificContext context(String id,
                        Object context)
                             throws Exception

Throws:

Exception