类 JmsDestinationAccessor
- java.lang.Object
- org.springframework.jms.support.JmsAccessor
- org.springframework.jms.support.destination.JmsDestinationAccessor
- 所有已实现的接口:
InitializingBean
public abstract class JmsDestinationAccessor extends JmsAccessor
Base class forJmsTemplate
and other JMS-accessing gateway helpers, adding destination-related properties toJmsAccessor's
common properties.Not intended to be used directly. See
JmsTemplate
.- 从以下版本开始:
- 1.2.5
- 作者:
- Juergen Hoeller
- 另请参阅:
JmsAccessor
,JmsTemplate
字段概要
字段 修饰符和类型 字段 说明 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.从类继承的字段 org.springframework.jms.support.JmsAccessor
logger
构造器概要
构造器 构造器 说明 JmsDestinationAccessor()
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 DestinationResolver
getDestinationResolver()
Return the DestinationResolver for this accessor (nevernull
).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, String destinationName)
Resolve the given destination name into a JMSDestination
, via this accessor'sDestinationResolver
.void
setDestinationResolver(DestinationResolver destinationResolver)
Set theDestinationResolver
that is to be used to resolveDestination
references for this accessor.void
setPubSubDomain(boolean pubSubDomain)
Configure the destination accessor with knowledge of the JMS domain used.从类继承的方法 org.springframework.jms.support.JmsAccessor
afterPropertiesSet, convertJmsAccessException, createConnection, createSession, getConnectionFactory, getSessionAcknowledgeMode, isClientAcknowledge, isSessionTransacted, setConnectionFactory, setSessionAcknowledgeMode, setSessionAcknowledgeModeName, setSessionTransacted
字段详细资料
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.- 从以下版本开始:
- 4.3
- 另请参阅:
- 常量字段值
RECEIVE_TIMEOUT_INDEFINITE_WAIT
public static final long RECEIVE_TIMEOUT_INDEFINITE_WAIT
Timeout value indicating a blocking receive without timeout.- 从以下版本开始:
- 4.3
- 另请参阅:
- 常量字段值
构造器详细资料
JmsDestinationAccessor
public JmsDestinationAccessor()
方法详细资料
setDestinationResolver
public void setDestinationResolver(DestinationResolver destinationResolver)
Set theDestinationResolver
that is to be used to resolveDestination
references for this accessor.The default resolver is a DynamicDestinationResolver. Specify a JndiDestinationResolver for resolving destination names as JNDI locations.
getDestinationResolver
public DestinationResolver getDestinationResolver()
Return the DestinationResolver for this accessor (nevernull
).
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.
- 参数:
pubSubDomain
- "true" for the Publish/Subscribe domain (Topics
), "false" for the Point-to-Point domain (Queues
)- 另请参阅:
setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver)
isPubSubDomain
public boolean isPubSubDomain()
resolveDestinationName
protected Destination resolveDestinationName(Session session, String destinationName) throws JMSException
Resolve the given destination name into a JMSDestination
, via this accessor'sDestinationResolver
.- 参数:
session
- the current JMSSession
destinationName
- the name of the destination- 返回:
- the located
Destination
- 抛出:
JMSException
- if resolution failed- 另请参阅:
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.- 参数:
consumer
- the JMS MessageConsumer to receive withtimeout
- the receive timeout (a negative value indicates a no-wait receive; 0 indicates an indefinite wait attempt)- 返回:
- the JMS Message received, or
null
if none - 抛出:
JMSException
- if thrown by JMS API methods- 从以下版本开始:
- 4.3
- 另请参阅:
RECEIVE_TIMEOUT_NO_WAIT
,RECEIVE_TIMEOUT_INDEFINITE_WAIT