org.springframework.integration.jms
Class JmsInboundGateway

java.lang.Object
  org.springframework.integration.context.IntegrationObjectSupport
      org.springframework.integration.endpoint.AbstractEndpoint
          org.springframework.integration.gateway.AbstractMessagingGateway
              org.springframework.integration.gateway.SimpleMessagingGateway
                  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