public class ActiveMQDestination extends Object implements javax.jms.Destination, Serializable, Referenceable
Modifier and Type | Class and Description |
---|---|
static class |
ActiveMQDestination.TYPE |
Modifier and Type | Field and Description |
---|---|
protected String |
name
The JMS name
|
static String |
QUEUE_QUALIFIED_PREFIX |
static String |
TEMP_QUEUE_QUALIFED_PREFIX |
static String |
TEMP_TOPIC_QUALIFED_PREFIX |
static String |
TOPIC_QUALIFIED_PREFIX |
Modifier | Constructor and Description |
---|---|
protected |
ActiveMQDestination(String address,
String name,
ActiveMQDestination.TYPE type,
ActiveMQSession session) |
public static final String QUEUE_QUALIFIED_PREFIX
public static final String TOPIC_QUALIFIED_PREFIX
public static final String TEMP_QUEUE_QUALIFED_PREFIX
public static final String TEMP_TOPIC_QUALIFED_PREFIX
protected final String name
protected ActiveMQDestination(String address, String name, ActiveMQDestination.TYPE type, ActiveMQSession session)
public static ActiveMQDestination createDestination(String name, ActiveMQDestination.TYPE defaultType)
public static javax.jms.Destination fromPrefixedName(String address)
public static String createQueueNameForSubscription(boolean isDurable, String clientID, String subscriptionName)
public static String createQueueNameForSharedSubscription(boolean isDurable, String clientID, String subscriptionName)
public static Pair<String,String> decomposeQueueNameForDurableSubscription(String queueName)
public static SimpleString createQueueAddressFromName(String name)
public static SimpleString createTopicAddressFromName(String name)
public static ActiveMQQueue createQueue(String name)
public static ActiveMQTopic createTopic(String name)
public static ActiveMQTemporaryQueue createTemporaryQueue(String name, ActiveMQSession session)
public static ActiveMQTemporaryQueue createTemporaryQueue(String name)
public static ActiveMQTemporaryQueue createTemporaryQueue(ActiveMQSession session)
public static ActiveMQTemporaryTopic createTemporaryTopic(ActiveMQSession session)
public static ActiveMQTemporaryTopic createTemporaryTopic(String name, ActiveMQSession session)
public static ActiveMQTemporaryTopic createTemporaryTopic(String name)
public Reference getReference() throws NamingException
getReference
in interface Referenceable
NamingException
public void delete() throws javax.jms.JMSException
javax.jms.JMSException
public boolean isQueue()
public String getAddress()
public SimpleString getSimpleAddress()
public String getName()
public boolean isTemporary()
public ActiveMQDestination.TYPE getType()
Copyright © 2017 The Apache Software Foundation. All rights reserved.