org.projectodd.wunderboss.messaging.hornetq

Class HQDestination

java.lang.Object

org.projectodd.wunderboss.messaging.hornetq.HQDestination

All Implemented Interfaces:

Destination

Direct Known Subclasses:

HQQueue, HQTopic

public abstract class HQDestination
extends Object
implements Destination

Nested Class Summary

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

Method Summary

Methods

Modifier and Type	Method and Description
protected HQMessaging	broker()
protected HQSpecificContext	context(Object context)
protected static void	fillInProperties(javax.jms.JMSProducer producer, Map<String,Object> properties)
abstract String	fullName()
static boolean	isJndiName(String name)
javax.jms.Destination	jmsDestination()
abstract String	jmsName()
static String	jndiName(String name, String type)
Listener	listen(MessageHandler handler, Codecs codecs, Map<Destination.ListenOption,Object> options)
String	name()
void	publish(Object content, Codec codec, Map<Destination.MessageOpOption,Object> options)
protected void	publish(Object message, Codec codec, Map<Destination.MessageOpOption,Object> options, Map<String,Object> additionalProperties)
Message	receive(Codecs codecs, Map<Destination.MessageOpOption,Object> options)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

HQDestination

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

Method Detail

name

public String name()

Specified by:

name in interface Destination

jmsDestination

public javax.jms.Destination jmsDestination()

fullName

public abstract String fullName()

jmsName

public abstract String jmsName()

listen

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

Specified by:

listen in interface Destination

Throws:

Exception

publish

public void publish(Object content,
           Codec codec,
           Map<Destination.MessageOpOption,Object> options)
             throws Exception

Specified by:

publish in interface Destination

Throws:

Exception

fillInProperties

protected static void fillInProperties(javax.jms.JMSProducer producer,
                    Map<String,Object> properties)
                                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

context

protected HQSpecificContext context(Object context)
                             throws Exception

Throws:

Exception

publish

protected void publish(Object message,
           Codec codec,
           Map<Destination.MessageOpOption,Object> options,
           Map<String,Object> additionalProperties)
                throws Exception

Throws:

Exception

receive

public Message receive(Codecs codecs,
              Map<Destination.MessageOpOption,Object> options)
                throws Exception

Specified by:

receive in interface Destination

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface Destination

Throws:

Exception

broker

protected HQMessaging broker()

jndiName

public static String jndiName(String name,
              String type)

isJndiName

public static boolean isJndiName(String name)