org.hornetq.jms.client

Class HornetQDestination

java.lang.Object

org.hornetq.jms.client.HornetQDestination

All Implemented Interfaces:

Serializable, Destination, Referenceable

Direct Known Subclasses:

HornetQQueue, HornetQTopic

public class HornetQDestination
extends Object
implements Destination, Serializable, Referenceable

HornetQ implementation of a JMS Destination.

Author:

Tim Fox

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	JMS_QUEUE_ADDRESS_PREFIX
static String	JMS_TEMP_QUEUE_ADDRESS_PREFIX
static String	JMS_TEMP_TOPIC_ADDRESS_PREFIX
static String	JMS_TOPIC_ADDRESS_PREFIX
protected String	name The JMS name

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HornetQDestination(String address, String name, boolean temporary, boolean queue, HornetQSession session)

Method Summary

Methods

Modifier and Type	Method and Description
static HornetQQueue	createQueue(String name)
static SimpleString	createQueueAddressFromName(String name)
static String	createQueueNameForDurableSubscription(String clientID, String subscriptionName)
static HornetQTemporaryQueue	createTemporaryQueue(HornetQSession session)
static HornetQTemporaryQueue	createTemporaryQueue(String name)
static HornetQTemporaryQueue	createTemporaryQueue(String name, HornetQSession session)
static HornetQTemporaryTopic	createTemporaryTopic(HornetQSession session)
static HornetQTemporaryTopic	createTemporaryTopic(String name)
static HornetQTemporaryTopic	createTemporaryTopic(String name, HornetQSession session)
static HornetQTopic	createTopic(String name)
static SimpleString	createTopicAddressFromName(String name)
static Pair<String,String>	decomposeQueueNameForDurableSubscription(String queueName)
void	delete()
boolean	equals(Object o)
protected static String	escape(String input)
static Destination	fromAddress(String address)
String	getAddress()
String	getName()
Reference	getReference()
SimpleString	getSimpleAddress()
int	hashCode()
boolean	isQueue()
boolean	isTemporary()

Methods inherited from class java.lang.Object

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

Field Detail

JMS_QUEUE_ADDRESS_PREFIX

public static final String JMS_QUEUE_ADDRESS_PREFIX

See Also:

Constant Field Values

JMS_TEMP_QUEUE_ADDRESS_PREFIX

public static final String JMS_TEMP_QUEUE_ADDRESS_PREFIX

See Also:

Constant Field Values

JMS_TOPIC_ADDRESS_PREFIX

public static final String JMS_TOPIC_ADDRESS_PREFIX

See Also:

Constant Field Values

JMS_TEMP_TOPIC_ADDRESS_PREFIX

public static final String JMS_TEMP_TOPIC_ADDRESS_PREFIX

See Also:

Constant Field Values

name

protected final String name

The JMS name

Constructor Detail

HornetQDestination

protected HornetQDestination(String address,
                  String name,
                  boolean temporary,
                  boolean queue,
                  HornetQSession session)

Method Detail

escape

protected static String escape(String input)

fromAddress

public static Destination fromAddress(String address)

createQueueNameForDurableSubscription

public static String createQueueNameForDurableSubscription(String clientID,
                                           String subscriptionName)

decomposeQueueNameForDurableSubscription

public static Pair<String,String> decomposeQueueNameForDurableSubscription(String queueName)

createQueueAddressFromName

public static SimpleString createQueueAddressFromName(String name)

createTopicAddressFromName

public static SimpleString createTopicAddressFromName(String name)

createQueue

public static HornetQQueue createQueue(String name)

createTopic

public static HornetQTopic createTopic(String name)

createTemporaryQueue

public static HornetQTemporaryQueue createTemporaryQueue(String name,
                                         HornetQSession session)

createTemporaryQueue

public static HornetQTemporaryQueue createTemporaryQueue(String name)

createTemporaryQueue

public static HornetQTemporaryQueue createTemporaryQueue(HornetQSession session)

createTemporaryTopic

public static HornetQTemporaryTopic createTemporaryTopic(HornetQSession session)

createTemporaryTopic

public static HornetQTemporaryTopic createTemporaryTopic(String name,
                                         HornetQSession session)

createTemporaryTopic

public static HornetQTemporaryTopic createTemporaryTopic(String name)

getReference

public Reference getReference()
                       throws NamingException

Specified by:

getReference in interface Referenceable

Throws:

NamingException

delete

public void delete()
            throws JMSException

Throws:

JMSException

isQueue

public boolean isQueue()

getAddress

public String getAddress()

getSimpleAddress

public SimpleString getSimpleAddress()

getName

public String getName()

isTemporary

public boolean isTemporary()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object