S
- the target JmsPollableMessageChannelSpec
implementation type.public class JmsPollableMessageChannelSpec<S extends JmsPollableMessageChannelSpec<S>> extends MessageChannelSpec<S,AbstractJmsChannel>
MessageChannelSpec
for an AbstractJmsChannel
.Modifier and Type | Field and Description |
---|---|
protected JmsChannelFactoryBean |
jmsChannelFactoryBean |
channel
logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
S |
deliveryPersistent(boolean deliveryPersistent) |
S |
destination(javax.jms.Destination destination)
Configure the destination that backs this channel.
|
S |
destination(java.lang.String destination)
Configure the destination name that backs this channel.
|
S |
destinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver) |
protected AbstractJmsChannel |
doGet() |
S |
explicitQosEnabled(boolean explicitQosEnabled) |
protected S |
id(java.lang.String id)
Configure the component identifier.
|
S |
jmsMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
Configure the
MessageConverter used for both sending and
receiving. |
S |
messageIdEnabled(boolean messageIdEnabled) |
S |
messageSelector(java.lang.String messageSelector)
Configure a message selector in the
DefaultMessageListenerContainer (when
message driven) or the JmsTemplate (when
polled). |
S |
messageTimestampEnabled(boolean messageTimestampEnabled) |
S |
priority(int priority)
Default priority.
|
S |
receiveTimeout(long receiveTimeout) |
S |
sessionAcknowledgeMode(int sessionAcknowledgeMode) |
S |
sessionTransacted(boolean sessionTransacted)
Configure transactional sessions for both the
JmsTemplate (sends and polled receives) and
DefaultMessageListenerContainer
(message-driven receives). |
S |
timeToLive(long timeToLive) |
datatype, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap
_this, afterPropertiesSet, destroy, get, getId, getObject, getObjectType, isSingleton
protected final JmsChannelFactoryBean jmsChannelFactoryBean
protected S id(java.lang.String id)
IntegrationComponentSpec
beanName
to register the
bean in the application context for this component.id
in class MessageChannelSpec<S extends JmsPollableMessageChannelSpec<S>,AbstractJmsChannel>
id
- the id.public S destination(java.lang.String destination)
destination
- the destination.MessageChannelSpec
.public S destinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
destinationResolver
- the destinationResolver.MessageChannelSpec
.JmsDestinationAccessor.setDestinationResolver(DestinationResolver)
,
JmsDestinationAccessor.setDestinationResolver(DestinationResolver)
public S destination(javax.jms.Destination destination)
destination
- the destination.MessageChannelSpec
.public S messageSelector(java.lang.String messageSelector)
DefaultMessageListenerContainer
(when
message driven) or the JmsTemplate
(when
polled).messageSelector
- the messageSelector.MessageChannelSpec
.AbstractMessageListenerContainer.setMessageSelector(String)
,
JmsTemplate.receiveSelectedAndConvert(String)
public S jmsMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
MessageConverter
used for both sending and
receiving.messageConverter
- the messageConverter.MessageChannelSpec
.JmsTemplate.setMessageConverter(MessageConverter)
public S deliveryPersistent(boolean deliveryPersistent)
deliveryPersistent
- the deliveryPersistent.MessageChannelSpec
.JmsTemplate.setDeliveryPersistent(boolean)
public S explicitQosEnabled(boolean explicitQosEnabled)
explicitQosEnabled
- the explicitQosEnabled.MessageChannelSpec
.JmsTemplate.setExplicitQosEnabled(boolean)
public S messageIdEnabled(boolean messageIdEnabled)
messageIdEnabled
- the messageIdEnabled.MessageChannelSpec
.JmsTemplate.setMessageIdEnabled(boolean)
public S messageTimestampEnabled(boolean messageTimestampEnabled)
messageTimestampEnabled
- the messageTimestampEnabled.MessageChannelSpec
.JmsTemplate.setMessageTimestampEnabled(boolean)
public S priority(int priority)
priority
- the priority.MessageChannelSpec
.JmsTemplate.setPriority(int)
public S timeToLive(long timeToLive)
timeToLive
- the timeToLive.MessageChannelSpec
.JmsTemplate.setTimeToLive(long)
public S receiveTimeout(long receiveTimeout)
receiveTimeout
- the receiveTimeout.MessageChannelSpec
.JmsTemplate.setReceiveTimeout(long)
,
AbstractPollingMessageListenerContainer.setReceiveTimeout(long)
public S sessionAcknowledgeMode(int sessionAcknowledgeMode)
sessionAcknowledgeMode
- the acknowledgement mode constantMessageChannelSpec
.etc.
public S sessionTransacted(boolean sessionTransacted)
JmsTemplate
(sends and polled receives) and
DefaultMessageListenerContainer
(message-driven receives).sessionTransacted
- the sessionTransacted.MessageChannelSpec
.protected AbstractJmsChannel doGet()
doGet
in class MessageChannelSpec<S extends JmsPollableMessageChannelSpec<S>,AbstractJmsChannel>