org.springframework.integration.gateway
Class AbstractMessagingGateway

java.lang.Object
  org.springframework.integration.context.IntegrationObjectSupport
      org.springframework.integration.endpoint.AbstractEndpoint
          org.springframework.integration.gateway.AbstractMessagingGateway

All Implemented Interfaces:

BeanFactoryAware, BeanNameAware, InitializingBean, Lifecycle, Phased, SmartLifecycle, NamedComponent

Direct Known Subclasses:

ChannelPublishingJmsMessageListener, HttpRequestHandlingController, HttpRequestHandlingMessagingGateway, SimpleMessagingGateway, SimpleTcpNetInboundGateway

public abstract class AbstractMessagingGateway
extends AbstractEndpoint

A convenient base class for connecting application code to MessageChannels for sending, receiving, or request-reply operations. Exposes setters for configuring request and reply MessageChannels as well as the timeout values for sending and receiving Messages.

Author:

Mark Fisher

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Constructor Summary

AbstractMessagingGateway()

Method Summary

protected void	doStart() Subclasses must implement this method with the start behavior.
protected void	doStop() Subclasses must implement this method with the stop behavior.
protected Object	fromMessage(Message<?> message)
String	getComponentType() Subclasses may implement this method to provide component type information.
protected void	onInit() Subclasses may implement this for initialization logic.
protected Object	receive()
protected void	send(Object object)
protected Object	sendAndReceive(Object object)
protected Message<?>	sendAndReceiveMessage(Object object)
void	setExceptionMapper(InboundMessageMapper<Throwable> exceptionMapper) Provide an InboundMessageMapper for creating a reply Message from an Exception that occurs downstream from this gateway.
void	setReplyChannel(MessageChannel replyChannel) Set the reply channel.
void	setReplyTimeout(long replyTimeout) Set the timeout value for receiving reply messages.
void	setRequestChannel(MessageChannel requestChannel) Set the request channel.
void	setRequestTimeout(long requestTimeout) Set the timeout value for sending request messages.
void	setShouldThrowErrors(boolean shouldThrowErrors) Specify whether the Throwable payload of a received ErrorMessage should be extracted and thrown from a send-and-receive operation.
protected Message<?>	toMessage(Object object)

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, getChannelResolver, getComponentName, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, toString, writeMessageHistory

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractMessagingGateway

public AbstractMessagingGateway()

Method Detail

getComponentType

public String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class IntegrationObjectSupport

setRequestChannel

public void setRequestChannel(MessageChannel requestChannel)

Set the request channel.

Parameters:

requestChannel - the channel to which request messages will be sent

setReplyChannel

public void setReplyChannel(MessageChannel replyChannel)

Set the reply channel. If no reply channel is provided, this template will always use an anonymous, temporary channel for handling replies.

Parameters:

replyChannel - the channel from which reply messages will be received

setRequestTimeout

public void setRequestTimeout(long requestTimeout)

Set the timeout value for sending request messages. If not explicitly configured, the default is an indefinite timeout.

Parameters:

requestTimeout - the timeout value in milliseconds

setReplyTimeout

public void setReplyTimeout(long replyTimeout)

Set the timeout value for receiving reply messages. If not explicitly configured, the default is an indefinite timeout.

Parameters:

replyTimeout - the timeout value in milliseconds

setShouldThrowErrors

public void setShouldThrowErrors(boolean shouldThrowErrors)

Specify whether the Throwable payload of a received ErrorMessage should be extracted and thrown from a send-and-receive operation. Otherwise, the ErrorMessage would be returned just like any other reply Message. The default is true.

setExceptionMapper

public void setExceptionMapper(InboundMessageMapper<Throwable> exceptionMapper)

Provide an InboundMessageMapper for creating a reply Message from an Exception that occurs downstream from this gateway. If no exceptionMapper is provided, then the shouldThrowErrors property will dictate whether the error is rethrown or returned as an ErrorMessage.

onInit

protected void onInit()
               throws Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class IntegrationObjectSupport

Throws:

Exception

send

protected void send(Object object)

receive

protected Object receive()

sendAndReceive

protected Object sendAndReceive(Object object)

sendAndReceiveMessage

protected Message<?> sendAndReceiveMessage(Object object)

fromMessage

protected Object fromMessage(Message<?> message)

toMessage

protected Message<?> toMessage(Object object)

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.

Specified by:

doStart in class AbstractEndpoint

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.

Specified by:

doStop in class AbstractEndpoint