|
Spring Integration | |||||||||
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 | |
---|---|
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(String destinationName)
Set the name of the default reply queue to send reply messages to. |
void |
setDefaultReplyTopicName(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, setExceptionMapper, setReplyChannel, setReplyMapper, setReplyTimeout, setRequestChannel, setRequestMapper, setRequestTimeout, setShouldThrowErrors, 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, getRequiredMetadataPersister, 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 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(String destinationName)
Alternatively, specify a JMS Destination object as "defaultReplyDestination".
setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver)
,
setDefaultReplyDestination(javax.jms.Destination)
public void setDefaultReplyTopicName(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 DefaultMessageConverter
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
DefaultMessageConverter
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 void onMessage(javax.jms.Message jmsMessage, javax.jms.Session session) throws javax.jms.JMSException
onMessage
in interface SessionAwareMessageListener<javax.jms.Message>
javax.jms.JMSException
|
Spring Integration | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |