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 DestinationResolver
session
- 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 Topic
Topic
JMSException
- 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 Queue
Queue
JMSException
- if resolution failedSession.createQueue(String)