org.springframework.integration.amqp.inbound
Class AmqpInboundGateway

java.lang.Object
  extended by org.springframework.integration.context.IntegrationObjectSupport
      extended by org.springframework.integration.endpoint.AbstractEndpoint
          extended by org.springframework.integration.gateway.MessagingGatewaySupport
              extended by org.springframework.integration.amqp.inbound.AmqpInboundGateway
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.context.NamedComponent, org.springframework.integration.history.TrackableComponent

public class AmqpInboundGateway
extends org.springframework.integration.gateway.MessagingGatewaySupport

Adapter that receives Messages from an AMQP Queue, converts them into Spring Integration Messages, and sends the results to a Message Channel. If a reply Message is received, it will be converted and sent back to the AMQP 'replyTo'.

Since:
2.1

Field Summary
 
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
logger
 
Constructor Summary
AmqpInboundGateway(org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer listenerContainer)
           
 
Method Summary
protected  void doStart()
           
protected  void doStop()
           
protected  void onInit()
           
 void setHeaderMapper(AmqpHeaderMapper headerMapper)
           
 void setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
           
 
Methods inherited from class org.springframework.integration.gateway.MessagingGatewaySupport
getComponentType, receive, send, sendAndReceive, sendAndReceiveMessage, setErrorChannel, setReplyChannel, setReplyMapper, setReplyTimeout, setRequestChannel, setRequestMapper, setRequestTimeout, 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, 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.integration.context.NamedComponent
getComponentName
 

Constructor Detail

AmqpInboundGateway

public AmqpInboundGateway(org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer listenerContainer)
Method Detail

setMessageConverter

public void setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)

setHeaderMapper

public void setHeaderMapper(AmqpHeaderMapper headerMapper)

onInit

protected void onInit()
               throws java.lang.Exception
Overrides:
onInit in class org.springframework.integration.gateway.MessagingGatewaySupport
Throws:
java.lang.Exception

doStart

protected void doStart()
Overrides:
doStart in class org.springframework.integration.gateway.MessagingGatewaySupport

doStop

protected void doStop()
Overrides:
doStop in class org.springframework.integration.gateway.MessagingGatewaySupport