org.springframework.integration.adapter.jms
Class JmsGateway

java.lang.Object
  org.springframework.integration.gateway.MessagingGatewaySupport
      org.springframework.integration.gateway.SimpleMessagingGateway
          org.springframework.integration.adapter.jms.JmsGateway

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean, org.springframework.context.Lifecycle, MessageBusAware, MessagingGateway

public class JmsGateway
extends SimpleMessagingGateway
implements org.springframework.context.Lifecycle, org.springframework.beans.factory.DisposableBean

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

Author:

Mark Fisher

Field Summary

private int	concurrentConsumers
private javax.jms.ConnectionFactory	connectionFactory
private org.springframework.jms.listener.AbstractMessageListenerContainer	container
private javax.jms.Destination	destination
private java.lang.String	destinationName
private boolean	expectReply
private int	idleTaskExecutionLimit
private int	maxConcurrentConsumers
private int	maxMessagesPerTask
private org.springframework.jms.support.converter.MessageConverter	messageConverter
private int	sessionAcknowledgeMode
private boolean	sessionTransacted
private org.springframework.core.task.TaskExecutor	taskExecutor
private org.springframework.transaction.PlatformTransactionManager	transactionManager

Constructor Summary

JmsGateway()

Method Summary

private org.springframework.jms.listener.AbstractMessageListenerContainer	createDefaultContainer()
void	destroy()
private void	initialize()
boolean	isRunning()
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	setExpectReply(boolean expectReply)
void	setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
void	setMaxConcurrentConsumers(int maxConcurrentConsumers)
void	setMaxMessagesPerTask(int maxMessagesPerTask)
void	setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
void	setSessionAcknowledgeMode(int sessionAcknowledgeMode)
void	setSessionTransacted(boolean sessionTransacted)
void	setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
void	setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
void	start()
void	stop()

Methods inherited from class org.springframework.integration.gateway.SimpleMessagingGateway

receive, receiveAndForward, send, sendAndReceive, sendAndReceiveMessage, setMessageBus, setMessageCreator, setMessageMapper, setReplyChannel, setReplyMapCapacity, setReplyTimeout, setRequestChannel

Methods inherited from class org.springframework.integration.gateway.MessagingGatewaySupport

getMessageExchangeTemplate, setRequestTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

container

private volatile org.springframework.jms.listener.AbstractMessageListenerContainer container

connectionFactory

private volatile javax.jms.ConnectionFactory connectionFactory

destination

private volatile javax.jms.Destination destination

destinationName

private volatile java.lang.String destinationName

messageConverter

private volatile org.springframework.jms.support.converter.MessageConverter messageConverter

taskExecutor

private volatile org.springframework.core.task.TaskExecutor taskExecutor

transactionManager

private volatile org.springframework.transaction.PlatformTransactionManager transactionManager

sessionTransacted

private volatile boolean sessionTransacted

sessionAcknowledgeMode

private volatile int sessionAcknowledgeMode

concurrentConsumers

private volatile int concurrentConsumers

maxConcurrentConsumers

private volatile int maxConcurrentConsumers

maxMessagesPerTask

private volatile int maxMessagesPerTask

idleTaskExecutionLimit

private volatile int idleTaskExecutionLimit

expectReply

private boolean expectReply

Constructor Detail

JmsGateway

public JmsGateway()

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)

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)

setExpectReply

public void setExpectReply(boolean expectReply)

setConcurrentConsumers

public void setConcurrentConsumers(int concurrentConsumers)

setMaxConcurrentConsumers

public void setMaxConcurrentConsumers(int maxConcurrentConsumers)

setMaxMessagesPerTask

public void setMaxMessagesPerTask(int maxMessagesPerTask)

setIdleTaskExecutionLimit

public void setIdleTaskExecutionLimit(int idleTaskExecutionLimit)

initialize

private void initialize()

createDefaultContainer

private org.springframework.jms.listener.AbstractMessageListenerContainer createDefaultContainer()

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

destroy

public void destroy()

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean