org.springframework.jms.support.destination

Class JmsDestinationAccessor

java.lang.Object

org.springframework.jms.support.JmsAccessor

org.springframework.jms.support.destination.JmsDestinationAccessor

All Implemented Interfaces:

InitializingBean

Direct Known Subclasses:

AbstractJmsListeningContainer, JmsTemplate

public abstract class JmsDestinationAccessor
extends JmsAccessor

Base class for JmsTemplate and other JMS-accessing gateway helpers, adding destination-related properties to JmsAccessor's common properties.

Not intended to be used directly. See JmsTemplate.

Since:

1.2.5

Author:

Juergen Hoeller

See Also:

JmsAccessor, JmsTemplate

Field Summary

Fields

Modifier and Type	Field and Description
private DestinationResolver	destinationResolver
private boolean	pubSubDomain
static long	RECEIVE_TIMEOUT_INDEFINITE_WAIT Timeout value indicating a blocking receive without timeout.
static long	RECEIVE_TIMEOUT_NO_WAIT Timeout value indicating that a receive operation should check if a message is immediately available without blocking.

Fields inherited from class org.springframework.jms.support.JmsAccessor

logger

Constructor Summary

Constructors

Constructor and Description
JmsDestinationAccessor()

Method Summary

Modifier and Type	Method and Description
DestinationResolver	getDestinationResolver() Return the DestinationResolver for this accessor (never null).
boolean	isPubSubDomain() Return whether the Publish/Subscribe domain (Topics) is used.
protected Message	receiveFromConsumer(MessageConsumer consumer, long timeout) Actually receive a message from the given consumer.
protected Destination	resolveDestinationName(Session session, java.lang.String destinationName) Resolve the given destination name into a JMS Destination, via this accessor's DestinationResolver.
void	setDestinationResolver(DestinationResolver destinationResolver) Set the DestinationResolver that is to be used to resolve javax.jms.Destination references for this accessor.
void	setPubSubDomain(boolean pubSubDomain) Configure the destination accessor with knowledge of the JMS domain used.

Methods inherited from class org.springframework.jms.support.JmsAccessor

afterPropertiesSet, convertJmsAccessException, createConnection, createSession, getConnectionFactory, getSessionAcknowledgeMode, isClientAcknowledge, isSessionTransacted, setConnectionFactory, setSessionAcknowledgeMode, setSessionAcknowledgeModeName, setSessionTransacted

Methods inherited from class java.lang.Object

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

Field Detail

RECEIVE_TIMEOUT_NO_WAIT

public static final long RECEIVE_TIMEOUT_NO_WAIT

Timeout value indicating that a receive operation should check if a message is immediately available without blocking.

Since:

4.3

See Also:

Constant Field Values

RECEIVE_TIMEOUT_INDEFINITE_WAIT

public static final long RECEIVE_TIMEOUT_INDEFINITE_WAIT

Timeout value indicating a blocking receive without timeout.

Since:

4.3

See Also:

Constant Field Values

destinationResolver

private DestinationResolver destinationResolver

pubSubDomain

private boolean pubSubDomain

Constructor Detail

JmsDestinationAccessor

public JmsDestinationAccessor()

Method Detail

setDestinationResolver

public void setDestinationResolver(DestinationResolver destinationResolver)

Set the DestinationResolver that is to be used to resolve javax.jms.Destination references for this accessor.

The default resolver is a DynamicDestinationResolver. Specify a JndiDestinationResolver for resolving destination names as JNDI locations.

See Also:

DynamicDestinationResolver, JndiDestinationResolver

getDestinationResolver

public DestinationResolver getDestinationResolver()

Return the DestinationResolver for this accessor (never null).

setPubSubDomain

public void setPubSubDomain(boolean pubSubDomain)

Configure the destination accessor with knowledge of the JMS domain used. Default is Point-to-Point (Queues).

This setting primarily indicates what type of destination to resolve if dynamic destinations are enabled.

Parameters:

pubSubDomain - "true" for the Publish/Subscribe domain (Topics), "false" for the Point-to-Point domain (Queues)

See Also:

setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver)

isPubSubDomain

public boolean isPubSubDomain()

Return whether the Publish/Subscribe domain (Topics) is used. Otherwise, the Point-to-Point domain (Queues) is used.

resolveDestinationName

protected Destination resolveDestinationName(Session session,
                                             java.lang.String destinationName)
                                      throws JMSException

Resolve the given destination name into a JMS Destination, via this accessor's DestinationResolver.

Parameters:

session - the current JMS Session

destinationName - the name of the destination

Returns:

the located Destination

Throws:

javax.jms.JMSException - if resolution failed

JMSException

See Also:

setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver)

receiveFromConsumer

protected Message receiveFromConsumer(MessageConsumer consumer,
                                      long timeout)
                               throws JMSException

Actually receive a message from the given consumer.

Parameters:

consumer - the JMS MessageConsumer to receive with

timeout - the receive timeout (a negative value indicates a no-wait receive; 0 indicates an indefinite wait attempt)

Returns:

the JMS Message received, or null if none

Throws:

JMSException - if thrown by JMS API methods

Since:

4.3

See Also:

RECEIVE_TIMEOUT_NO_WAIT, RECEIVE_TIMEOUT_INDEFINITE_WAIT