Class ChannelPublishingJmsMessageListener
java.lang.Object
org.springframework.integration.jms.ChannelPublishingJmsMessageListener
- All Implemented Interfaces:
Aware,BeanFactoryAware,InitializingBean,NamedComponent,TrackableComponent,SessionAwareMessageListener<Message>
public class ChannelPublishingJmsMessageListener
extends Object
implements SessionAwareMessageListener<Message>, InitializingBean, TrackableComponent, BeanFactoryAware
JMS MessageListener that converts a JMS Message into a Spring Integration
Message and sends that Message to a channel. If the 'expectReply' value is
true, it will also wait for a Spring Integration reply Message
and convert that into a JMS reply.- Author:
- Mark Fisher, Juergen Hoeller, Oleg Zhurakousky, Artem Bilan, Gary Russell
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidvoidsetBeanFactory(BeanFactory beanFactory) voidsetComponentName(String componentName) voidsetCorrelationKey(String correlationKey) Provide the name of a JMS property that should be copied from the request Message to the reply Message.voidsetDefaultReplyDestination(Destination defaultReplyDestination) Set the default reply destination to send reply messages to.voidsetDefaultReplyQueueName(String destinationName) Set the name of the default reply queue to send reply messages to.voidsetDefaultReplyTopicName(String destinationName) Set the name of the default reply topic to send reply messages to.voidsetDestinationResolver(DestinationResolver destinationResolver) Set the DestinationResolver that should be used to resolve reply destination names for this listener.voidsetErrorChannel(MessageChannel errorChannel) voidsetErrorChannelName(String errorChannelName) voidsetErrorOnTimeout(boolean errorOnTimeout) voidsetExpectReply(boolean expectReply) Specify whether a JMS reply Message is expected.voidsetExplicitQosEnabledForReplies(boolean explicitQosEnabledForReplies) Specify whether explicit QoS should be enabled for replies (for timeToLive, priority, and deliveryMode settings).voidsetExtractReplyPayload(boolean extractReplyPayload) Specify whether the Spring Integration reply Message's payload should be extracted prior to converting into a JMS Message.voidsetExtractRequestPayload(boolean extractRequestPayload) Specify whether the JMS request Message's body should be extracted prior to converting into a Spring Integration Message.voidsetHeaderMapper(JmsHeaderMapper headerMapper) Provide aJmsHeaderMapperimplementation to use when converting between JMS Messages and Spring Integration Messages.voidsetMessageConverter(MessageConverter messageConverter) Provide aMessageConverterimplementation to use when converting between JMS Messages and Spring Integration Messages.voidsetReplyChannel(MessageChannel replyChannel) voidsetReplyChannelName(String replyChannelName) voidsetReplyDeliveryPersistent(boolean replyDeliveryPersistent) Specify the delivery mode for JMS reply Messages.voidsetReplyPriority(int replyPriority) Specify the priority value for JMS reply Messages.voidsetReplyTimeout(long replyTimeout) voidsetReplyTimeToLive(long replyTimeToLive) Specify the time-to-live property for JMS reply Messages.voidsetRequestChannel(MessageChannel requestChannel) voidsetRequestChannelName(String requestChannelName) voidsetRequestTimeout(long requestTimeout) voidsetShouldTrack(boolean shouldTrack) protected voidstart()protected voidstop()Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.integration.support.context.NamedComponent
getBeanName
-
Field Details
-
logger
-
-
Constructor Details
-
ChannelPublishingJmsMessageListener
public ChannelPublishingJmsMessageListener()
-
-
Method Details
-
setExpectReply
public void setExpectReply(boolean expectReply) Specify whether a JMS reply Message is expected.- Parameters:
expectReply- true if a reply is expected.
-
setComponentName
-
setRequestChannel
-
setRequestChannelName
-
setReplyChannel
-
setReplyChannelName
-
setErrorChannel
-
setErrorChannelName
-
setRequestTimeout
public void setRequestTimeout(long requestTimeout) -
setReplyTimeout
public void setReplyTimeout(long replyTimeout) -
setErrorOnTimeout
public void setErrorOnTimeout(boolean errorOnTimeout) -
setShouldTrack
public void setShouldTrack(boolean shouldTrack) - Specified by:
setShouldTrackin interfaceTrackableComponent
-
getComponentName
- Specified by:
getComponentNamein interfaceNamedComponent
-
getComponentType
- Specified by:
getComponentTypein interfaceNamedComponent
-
setDefaultReplyDestination
Set the default reply destination to send reply messages to. This will be applied in case of a request message that does not carry a "JMSReplyTo" field.- Parameters:
defaultReplyDestination- The default reply destination.
-
setDefaultReplyQueueName
Set the name of the default reply queue to send reply messages to. This will be applied in case of a request message that does not carry a "JMSReplyTo" field.Alternatively, specify a JMS Destination object as "defaultReplyDestination".
- Parameters:
destinationName- The default reply destination name.- See Also:
-
setDefaultReplyTopicName
Set the name of the default reply topic to send reply messages to. This will be applied in case of a request message that does not carry a "JMSReplyTo" field.Alternatively, specify a JMS Destination object as "defaultReplyDestination".
- Parameters:
destinationName- The default reply topic name.- See Also:
-
setReplyTimeToLive
public void setReplyTimeToLive(long replyTimeToLive) Specify the time-to-live property for JMS reply Messages.- Parameters:
replyTimeToLive- The reply time to live.- See Also:
-
setReplyPriority
public void setReplyPriority(int replyPriority) Specify the priority value for JMS reply Messages.- Parameters:
replyPriority- The reply priority.- See Also:
-
setReplyDeliveryPersistent
public void setReplyDeliveryPersistent(boolean replyDeliveryPersistent) Specify the delivery mode for JMS reply Messages.- Parameters:
replyDeliveryPersistent- true for a persistent reply message.- See Also:
-
setCorrelationKey
Provide the name of a JMS property that should be copied from the request Message to the reply Message. If this value is NULL (the default) then the JMSMessageID from the request will be copied into the JMSCorrelationID of the reply unless there is already a value in the JMSCorrelationID property of the newly created reply Message in which case nothing will be copied. If the JMSCorrelationID of the request Message should be copied into the JMSCorrelationID of the reply Message instead, then this value should be set to "JMSCorrelationID". Any other value will be treated as a JMS String Property to be copied as-is from the request Message into the reply Message with the same property name.- Parameters:
correlationKey- The correlation key.
-
setExplicitQosEnabledForReplies
public void setExplicitQosEnabledForReplies(boolean explicitQosEnabledForReplies) Specify whether explicit QoS should be enabled for replies (for timeToLive, priority, and deliveryMode settings).- Parameters:
explicitQosEnabledForReplies- true to enable explicit QoS.
-
setDestinationResolver
Set the DestinationResolver that should be used to resolve reply destination names for this listener.The default resolver is a DynamicDestinationResolver. Specify a JndiDestinationResolver for resolving destination names as JNDI locations.
- Parameters:
destinationResolver- The destination resolver.- See Also:
-
setMessageConverter
Provide aMessageConverterimplementation to use when converting between JMS Messages and Spring Integration Messages. If none is provided, aSimpleMessageConverterwill be used.- Parameters:
messageConverter- The message converter.
-
setHeaderMapper
Provide aJmsHeaderMapperimplementation to use when converting between JMS Messages and Spring Integration Messages. If none is provided, aDefaultJmsHeaderMapperwill be used.- Parameters:
headerMapper- The header mapper.
-
setExtractRequestPayload
public void setExtractRequestPayload(boolean extractRequestPayload) Specify whether the JMS request Message's body should be extracted prior to converting into a Spring Integration Message. This value is set totrueby default. To send the JMS Message itself as a Spring Integration Message payload, set this tofalse.- Parameters:
extractRequestPayload- true if the request payload should be extracted.
-
setExtractReplyPayload
public void setExtractReplyPayload(boolean extractReplyPayload) Specify whether the Spring Integration reply Message's payload should be extracted prior to converting into a JMS Message. This value is set totrueby default. To send the Spring Integration Message itself as the JMS Message's body, set this tofalse.- Parameters:
extractReplyPayload- true if the reply payload should be extracted.
-
setBeanFactory
- Specified by:
setBeanFactoryin interfaceBeanFactoryAware- Throws:
BeansException
-
onMessage
- Specified by:
onMessagein interfaceSessionAwareMessageListener<Message>- Throws:
JMSException
-
afterPropertiesSet
public void afterPropertiesSet()- Specified by:
afterPropertiesSetin interfaceInitializingBean
-
start
protected void start() -
stop
protected void stop()
-