|
Spring Integration | ||||||||
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.
Field Summary | |
---|---|
protected org.apache.commons.logging.Log |
logger
|
Constructor Summary | |
---|---|
ChannelPublishingJmsMessageListener()
|
Method Summary | |
---|---|
void |
afterPropertiesSet()
|
java.lang.String |
getComponentName()
|
java.lang.String |
getComponentType()
|
void |
onMessage(javax.jms.Message jmsMessage,
javax.jms.Session session)
|
void |
setComponentName(java.lang.String componentName)
|
void |
setCorrelationKey(java.lang.String correlationKey)
Provide the name of a JMS property that should be copied from the request Message to the reply Message. |
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 |
setErrorChannel(MessageChannel errorChannel)
|
void |
setExpectReply(boolean expectReply)
Specify whether a JMS reply Message is expected. |
void |
setExplicitQosEnabledForReplies(boolean explicitQosEnabledForReplies)
Specify whether explicit QoS should be enabled for replies (for timeToLive, priority, and deliveryMode settings). |
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 |
setReplyChannel(MessageChannel replyChannel)
|
void |
setReplyDeliveryPersistent(boolean replyDeliveryPersistent)
Specify the delivery mode for JMS reply Messages. |
void |
setReplyPriority(int replyPriority)
Specify the priority value for JMS reply Messages. |
void |
setReplyTimeout(long replyTimeout)
|
void |
setReplyTimeToLive(long replyTimeToLive)
Specify the time-to-live property for JMS reply Messages. |
void |
setRequestChannel(MessageChannel requestChannel)
|
void |
setRequestTimeout(long requestTimeout)
|
void |
setShouldTrack(boolean shouldTrack)
|
protected void |
start()
|
protected void |
stop()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final org.apache.commons.logging.Log logger
Constructor Detail |
---|
public ChannelPublishingJmsMessageListener()
Method Detail |
---|
public void setExpectReply(boolean expectReply)
public void setComponentName(java.lang.String componentName)
public void setRequestChannel(MessageChannel requestChannel)
public void setReplyChannel(MessageChannel replyChannel)
public void setErrorChannel(MessageChannel errorChannel)
public void setRequestTimeout(long requestTimeout)
public void setReplyTimeout(long replyTimeout)
public void setShouldTrack(boolean shouldTrack)
setShouldTrack
in interface TrackableComponent
public java.lang.String getComponentName()
getComponentName
in interface NamedComponent
public java.lang.String getComponentType()
getComponentType
in interface NamedComponent
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 setReplyTimeToLive(long replyTimeToLive)
MessageProducer.setTimeToLive(long)
public void setReplyPriority(int replyPriority)
MessageProducer.setPriority(int)
public void setReplyDeliveryPersistent(boolean replyDeliveryPersistent)
MessageProducer.setDeliveryMode(int)
public void setCorrelationKey(java.lang.String correlationKey)
public void setExplicitQosEnabledForReplies(boolean explicitQosEnabledForReplies)
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 SimpleMessageConverter
will
be used.
messageConverter
- 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.
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 void onMessage(javax.jms.Message jmsMessage, javax.jms.Session session) throws javax.jms.JMSException
onMessage
in interface org.springframework.jms.listener.SessionAwareMessageListener<javax.jms.Message>
javax.jms.JMSException
public void afterPropertiesSet()
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
protected void start()
protected void stop()
|
Spring Integration | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |