|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.integration.context.IntegrationObjectSupport org.springframework.integration.endpoint.AbstractEndpoint org.springframework.integration.gateway.MessagingGatewaySupport 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 |
---|
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport |
---|
logger |
Constructor Summary | |
---|---|
ChannelPublishingJmsMessageListener()
|
Method Summary | |
---|---|
java.lang.String |
getComponentType()
Subclasses may implement this method to provide component type information. |
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(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 |
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(MessageConverter messageConverter)
Provide a MessageConverter implementation to use when
converting between JMS Messages and Spring Integration Messages. |
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 |
setReplyTimeToLive(long replyTimeToLive)
Specify the time-to-live property for JMS reply Messages. |
Methods inherited from class org.springframework.integration.gateway.MessagingGatewaySupport |
---|
doStart, doStop, onInit, receive, send, sendAndReceive, sendAndReceiveMessage, setErrorChannel, setReplyChannel, setReplyMapper, setReplyTimeout, setRequestChannel, setRequestMapper, setRequestTimeout, setShouldTrack |
Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint |
---|
getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop |
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport |
---|
afterPropertiesSet, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setComponentName, setConversionService, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.springframework.beans.factory.InitializingBean |
---|
afterPropertiesSet |
Methods inherited from interface org.springframework.integration.context.NamedComponent |
---|
getComponentName |
Constructor Detail |
---|
public ChannelPublishingJmsMessageListener()
Method Detail |
---|
public java.lang.String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class MessagingGatewaySupport
public void setExpectReply(boolean expectReply)
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 setExplicitQosEnabledForReplies(boolean explicitQosEnabledForReplies)
public void setDestinationResolver(DestinationResolver destinationResolver)
The default resolver is a DynamicDestinationResolver. Specify a JndiDestinationResolver for resolving destination names as JNDI locations.
DynamicDestinationResolver
,
JndiDestinationResolver
public void setMessageConverter(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 SessionAwareMessageListener<javax.jms.Message>
javax.jms.JMSException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |