public class PollableJmsChannel extends AbstractJmsChannel implements PollableChannel
AbstractMessageChannel.ChannelInterceptorList
logger
Constructor and Description |
---|
PollableJmsChannel(org.springframework.jms.core.JmsTemplate jmsTemplate) |
Modifier and Type | Method and Description |
---|---|
Message<?> |
receive()
Receive a message from this channel, blocking indefinitely if necessary.
|
Message<?> |
receive(long timeout)
Receive a message from this channel, blocking until either a message is
available or the specified timeout period elapses.
|
void |
setMessageSelector(java.lang.String messageSelector) |
doSend
addInterceptor, getComponentType, getFullChannelName, getInterceptors, send, send, setConversionService, setDatatypes, setInterceptors, setShouldTrack
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, onInit, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
send, send
getComponentName
public PollableJmsChannel(org.springframework.jms.core.JmsTemplate jmsTemplate)
public void setMessageSelector(java.lang.String messageSelector)
public Message<?> receive()
PollableChannel
receive
in interface PollableChannel
Message
or null
if interruptedpublic Message<?> receive(long timeout)
PollableChannel
receive
in interface PollableChannel
timeout
- the timeout in millisecondsMessage
or null
if the
specified timeout period elapses or the message reception is interrupted