Class DynamicDestinationResolver
- java.lang.Object
- org.springframework.jms.support.destination.DynamicDestinationResolver
- All Implemented Interfaces:
DestinationResolver
public class DynamicDestinationResolver extends Object implements DestinationResolver
SimpleDestinationResolver
implementation resolving destination names as dynamic destinations.- Since:
- 1.1
- Author:
- Juergen Hoeller
- See Also:
Session.createQueue(java.lang.String)
,Session.createTopic(java.lang.String)
Constructor Summary
Constructors Constructor Description DynamicDestinationResolver()
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 aQueue
.protected Topic
resolveTopic(Session session, String topicName)
Resolve the given destination name to aTopic
.
Constructor Detail
DynamicDestinationResolver
public DynamicDestinationResolver()
Method Detail
resolveDestinationName
public Destination resolveDestinationName(@Nullable Session session, String destinationName, boolean pubSubDomain) throws JMSException
Resolve the specified destination name as a dynamic destination.- Specified by:
resolveDestinationName
in interfaceDestinationResolver
- Parameters:
session
- the current JMS SessiondestinationName
- the name of the destinationpubSubDomain
-true
if the domain is pub-sub,false
if P2P- Returns:
- the JMS destination (either a topic or a queue)
- Throws:
JMSException
- if resolution failed- See Also:
resolveTopic(javax.jms.Session, String)
,resolveQueue(javax.jms.Session, String)
resolveTopic
protected Topic resolveTopic(Session session, String topicName) throws JMSException
Resolve the given destination name to aTopic
.- Parameters:
session
- the current JMS SessiontopicName
- the name of the desiredTopic
- Returns:
- the JMS
Topic
- Throws:
JMSException
- if resolution failed- See Also:
Session.createTopic(String)
resolveQueue
protected Queue resolveQueue(Session session, String queueName) throws JMSException
Resolve the given destination name to aQueue
.- Parameters:
session
- the current JMS SessionqueueName
- the name of the desiredQueue
- Returns:
- the JMS
Queue
- Throws:
JMSException
- if resolution failed- See Also:
Session.createQueue(String)