|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.integration.jms.ChannelPublishingJmsMessageListener
public class ChannelPublishingJmsMessageListener
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.
Constructor Summary | |
---|---|
ChannelPublishingJmsMessageListener()
|
Method Summary | |
---|---|
void |
afterPropertiesSet()
|
void |
onMessage(javax.jms.Message jmsMessage,
javax.jms.Session session)
|
void |
setDefaultReplyDestination(javax.jms.Destination defaultReplyDestination)
Set the default reply destination to send reply messages to. |
void |
setDefaultReplyQueueName(java.lang.String destinationName)
Set the name of the default reply queue to send reply messages to. |
void |
setDefaultReplyTopicName(java.lang.String destinationName)
Set the name of the default reply topic to send reply messages to. |
void |
setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
Set the DestinationResolver that should be used to resolve reply destination names for this listener. |
void |
setExpectReply(boolean expectReply)
Specify whether a JMS reply Message is expected. |
void |
setExtractReplyPayload(boolean extractReplyPayload)
Specify whether the Spring Integration reply Message's payload should be extracted prior to converting into a JMS Message. |
void |
setExtractRequestPayload(boolean extractRequestPayload)
Specify whether the JMS request Message's body should be extracted prior to converting into a Spring Integration Message. |
void |
setHeaderMapper(JmsHeaderMapper headerMapper)
Provide a JmsHeaderMapper implementation to use when
converting between JMS Messages and Spring Integration Messages. |
void |
setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
Provide a MessageConverter implementation to use when
converting between JMS Messages and Spring Integration Messages. |
void |
setReplyTimeout(long replyTimeout)
Specify the maximum time to wait for reply Messages. |
void |
setRequestChannel(MessageChannel requestChannel)
Specify the channel to which request Messages should be sent. |
void |
setRequestTimeout(long requestTimeout)
Specify the maximum time to wait when sending a request message to the request channel. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ChannelPublishingJmsMessageListener()
Method Detail |
---|
public void setRequestChannel(MessageChannel requestChannel)
public void setExpectReply(boolean expectReply)
public void setRequestTimeout(long requestTimeout)
MessageChannelTemplate
.
public void setReplyTimeout(long replyTimeout)
expectReply
is true
. The default
value will be that of MessageChannelTemplate
.
public void setDefaultReplyDestination(javax.jms.Destination defaultReplyDestination)
public void setDefaultReplyQueueName(java.lang.String destinationName)
Alternatively, specify a JMS Destination object as "defaultReplyDestination".
setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver)
,
setDefaultReplyDestination(javax.jms.Destination)
public void setDefaultReplyTopicName(java.lang.String destinationName)
Alternatively, specify a JMS Destination object as "defaultReplyDestination".
setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver)
,
setDefaultReplyDestination(javax.jms.Destination)
public void setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
The default resolver is a DynamicDestinationResolver. Specify a JndiDestinationResolver for resolving destination names as JNDI locations.
DynamicDestinationResolver
,
JndiDestinationResolver
public void setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
MessageConverter
implementation to use when
converting between JMS Messages and Spring Integration Messages.
If none is provided, a HeaderMappingMessageConverter
will
be used and the JmsHeaderMapper
instance provided to the
setHeaderMapper(JmsHeaderMapper)
method will be included
in the conversion process.
public void setHeaderMapper(JmsHeaderMapper headerMapper)
JmsHeaderMapper
implementation to use when
converting between JMS Messages and Spring Integration Messages.
If none is provided, a DefaultJmsHeaderMapper
will be used.
This property will be ignored if a MessageConverter
is
provided to the setMessageConverter(MessageConverter)
method.
However, you may provide your own implementation of the delegating
HeaderMappingMessageConverter
implementation.
public void setExtractRequestPayload(boolean extractRequestPayload)
true
by default. To send the JMS Message itself as a
Spring Integration Message payload, set this to false
.
public void setExtractReplyPayload(boolean extractReplyPayload)
true
by default. To send the Spring Integration Message
itself as the JMS Message's body, set this to false
.
public final void afterPropertiesSet()
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
public void onMessage(javax.jms.Message jmsMessage, javax.jms.Session session) throws javax.jms.JMSException
onMessage
in interface org.springframework.jms.listener.SessionAwareMessageListener
javax.jms.JMSException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |