org.projectodd.wunderboss.messaging.hornetq

Class HQQueue

java.lang.Object

org.projectodd.wunderboss.messaging.hornetq.HQDestination

org.projectodd.wunderboss.messaging.hornetq.HQQueue

All Implemented Interfaces:

Destination, Queue

public class HQQueue
extends HQDestination
implements Queue

Nested Class Summary

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

Queue.RequestOption, Queue.RespondOption

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
HQQueue(String name, javax.jms.Destination destination, HQMessaging broker)

Method Summary

Methods

Modifier and Type	Method and Description
String	fullName()
static String	fullName(String name)
String	jmsName()
static String	jmsName(String name)
Response	request(Object content, Codec codec, Codecs codecs, Map<Destination.MessageOpOption,Object> options)
Listener	respond(MessageHandler handler, Codecs codecs, Map<Destination.ListenOption,Object> options)

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

broker, context, fillInProperties, isJndiName, jmsDestination, 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

HQQueue

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

Method Detail

respond

public Listener respond(MessageHandler handler,
               Codecs codecs,
               Map<Destination.ListenOption,Object> options)
                 throws Exception

Specified by:

respond in interface Queue

Throws:

Exception

request

public Response request(Object content,
               Codec codec,
               Codecs codecs,
               Map<Destination.MessageOpOption,Object> options)
                 throws Exception

Specified by:

request in interface Queue

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