org.springframework.integration.jms
Class JmsInboundGateway

java.lang.Object
  extended by org.springframework.integration.context.IntegrationObjectSupport
      extended by org.springframework.integration.endpoint.AbstractEndpoint
          extended by org.springframework.integration.gateway.AbstractMessagingGateway
              extended by org.springframework.integration.gateway.SimpleMessagingGateway
                  extended by org.springframework.integration.jms.JmsInboundGateway
All Implemented Interfaces:
org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, MessagingGateway

public class JmsInboundGateway
extends SimpleMessagingGateway
implements org.springframework.beans.factory.DisposableBean

A message-driven adapter for receiving JMS messages and sending to a channel.

Author:
Mark Fisher

Field Summary
 
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
logger
 
Constructor Summary
JmsInboundGateway()
           
 
Method Summary
 void destroy()
           
protected  void doStart()
          Subclasses must implement this method with the start behavior.
protected  void doStop()
          Subclasses must implement this method with the stop behavior.
 void setConcurrentConsumers(int concurrentConsumers)
           
 void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
           
 void setContainer(org.springframework.jms.listener.AbstractMessageListenerContainer container)
           
 void setDestination(javax.jms.Destination destination)
           
 void setDestinationName(java.lang.String destinationName)
           
 void setExtractReplyPayload(boolean extractReplyPayload)
           
 void setExtractRequestPayload(boolean extractRequestPayload)
           
 void setHeaderMapper(JmsHeaderMapper headerMapper)
          Provide a JmsHeaderMapper implementation to use when converting between JMS Messages and Spring Integration Messages.
 void setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
           
 void setMaxConcurrentConsumers(int maxConcurrentConsumers)
           
 void setMaxMessagesPerTask(int maxMessagesPerTask)
           
 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 setSessionAcknowledgeMode(int sessionAcknowledgeMode)
           
 void setSessionTransacted(boolean sessionTransacted)
           
 void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
           
 void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
           
 
Methods inherited from class org.springframework.integration.gateway.SimpleMessagingGateway
fromMessage, toMessage
 
Methods inherited from class org.springframework.integration.gateway.AbstractMessagingGateway
receive, send, sendAndReceive, sendAndReceiveMessage, setReplyChannel, setReplyTimeout, setRequestChannel, setRequestTimeout, setShouldThrowErrors
 
Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
afterPropertiesSet, isRunning, onInit, setAutoStartup, setTaskScheduler, start, stop
 
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport
getBeanFactory, getChannelResolver, getTaskScheduler, setBeanFactory, setBeanName, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

JmsInboundGateway

public JmsInboundGateway()
Method Detail

setContainer

public void setContainer(org.springframework.jms.listener.AbstractMessageListenerContainer container)

setConnectionFactory

public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)

setDestination

public void setDestination(javax.jms.Destination destination)

setDestinationName

public void setDestinationName(java.lang.String destinationName)

setMessageConverter

public void setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
Provide a 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.


setHeaderMapper

public void setHeaderMapper(JmsHeaderMapper headerMapper)
Provide a 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.


setExtractRequestPayload

public void setExtractRequestPayload(boolean extractRequestPayload)

setExtractReplyPayload

public void setExtractReplyPayload(boolean extractReplyPayload)

setTaskExecutor

public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)

setTransactionManager

public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)

setSessionTransacted

public void setSessionTransacted(boolean sessionTransacted)

setSessionAcknowledgeMode

public void setSessionAcknowledgeMode(int sessionAcknowledgeMode)

setConcurrentConsumers

public void setConcurrentConsumers(int concurrentConsumers)

setMaxConcurrentConsumers

public void setMaxConcurrentConsumers(int maxConcurrentConsumers)

setMaxMessagesPerTask

public void setMaxMessagesPerTask(int maxMessagesPerTask)

setIdleTaskExecutionLimit

public void setIdleTaskExecutionLimit(int idleTaskExecutionLimit)

doStart

protected void doStart()
Description copied from class: AbstractEndpoint
Subclasses must implement this method with the start behavior. This method will be invoked while holding the AbstractEndpoint.lifecycleLock.

Overrides:
doStart in class AbstractMessagingGateway

doStop

protected void doStop()
Description copied from class: AbstractEndpoint
Subclasses must implement this method with the stop behavior. This method will be invoked while holding the AbstractEndpoint.lifecycleLock.

Overrides:
doStop in class AbstractMessagingGateway

destroy

public void destroy()
Specified by:
destroy in interface org.springframework.beans.factory.DisposableBean