public class DynamicDestinationResolver extends Object implements DestinationResolver
DestinationResolver implementation resolving destination names
as dynamic destinations.Session.createQueue(java.lang.String),
Session.createTopic(java.lang.String)| Constructor and Description |
|---|
DynamicDestinationResolver() |
| Modifier and Type | Method and Description |
|---|---|
Destination |
resolveDestinationName(Session session,
String destinationName,
boolean pubSubDomain)
Resolve the specified destination name as a dynamic destination.
|
protected Queue |
resolveQueue(Session session,
String queueName)
Resolve the given destination name to a
Queue. |
protected Topic |
resolveTopic(Session session,
String topicName)
Resolve the given destination name to a
Topic. |
public Destination resolveDestinationName(@Nullable Session session, String destinationName, boolean pubSubDomain) throws JMSException
resolveDestinationName in interface DestinationResolversession - the current JMS SessiondestinationName - the name of the destinationpubSubDomain - true if the domain is pub-sub, false if P2PJMSException - if resolution failedresolveTopic(javax.jms.Session, String),
resolveQueue(javax.jms.Session, String)protected Topic resolveTopic(Session session, String topicName) throws JMSException
Topic.session - the current JMS SessiontopicName - the name of the desired TopicTopicJMSException - if resolution failedSession.createTopic(String)protected Queue resolveQueue(Session session, String queueName) throws JMSException
Queue.session - the current JMS SessionqueueName - the name of the desired QueueQueueJMSException - if resolution failedSession.createQueue(String)