Spring Integration

org.springframework.integration.amqp.outbound
Class AmqpOutboundEndpoint

java.lang.Object
  extended by org.springframework.integration.context.IntegrationObjectSupport
      extended by org.springframework.integration.handler.AbstractMessageHandler
          extended by org.springframework.integration.handler.AbstractReplyProducingMessageHandler
              extended by org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint
All Implemented Interfaces:
org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.core.Ordered, NamedComponent, Orderable, MessageHandler, MessageProducer, TrackableComponent

public class AmqpOutboundEndpoint
extends AbstractReplyProducingMessageHandler

Adapter that converts and sends Messages to an AMQP Exchange.

Since:
2.1
Author:
Mark Fisher, Oleg Zhurakousky, Gary Russell

Field Summary
 
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
logger
 
Fields inherited from interface org.springframework.core.Ordered
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
 
Constructor Summary
AmqpOutboundEndpoint(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
           
 
Method Summary
 java.lang.String getComponentType()
          Subclasses may implement this method to provide component type information.
protected  java.lang.Object handleRequestMessage(Message<?> requestMessage)
          Subclasses must implement this method to handle the request Message.
protected  void onInit()
          Subclasses may implement this for initialization logic.
 void setExchangeName(java.lang.String exchangeName)
           
 void setExchangeNameExpression(java.lang.String exchangeNameExpression)
           
 void setExpectReply(boolean expectReply)
           
 void setHeaderMapper(AmqpHeaderMapper headerMapper)
           
 void setRoutingKey(java.lang.String routingKey)
           
 void setRoutingKeyExpression(java.lang.String routingKeyExpression)
           
 
Methods inherited from class org.springframework.integration.handler.AbstractReplyProducingMessageHandler
getMessagingTemplate, handleMessageInternal, setChannelResolver, setOutputChannel, setRequiresReply, setSendTimeout, shouldCopyRequestHeaders
 
Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler
getOrder, handleMessage, setOrder, setShouldTrack
 
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, 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

AmqpOutboundEndpoint

public AmqpOutboundEndpoint(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
Method Detail

onInit

protected void onInit()
Description copied from class: IntegrationObjectSupport
Subclasses may implement this for initialization logic.

Overrides:
onInit in class AbstractReplyProducingMessageHandler

setHeaderMapper

public void setHeaderMapper(AmqpHeaderMapper headerMapper)

setExchangeName

public void setExchangeName(java.lang.String exchangeName)

setExchangeNameExpression

public void setExchangeNameExpression(java.lang.String exchangeNameExpression)

setRoutingKey

public void setRoutingKey(java.lang.String routingKey)

setRoutingKeyExpression

public void setRoutingKeyExpression(java.lang.String routingKeyExpression)

setExpectReply

public void setExpectReply(boolean expectReply)

getComponentType

public java.lang.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 AbstractMessageHandler

handleRequestMessage

protected java.lang.Object handleRequestMessage(Message<?> requestMessage)
Description copied from class: AbstractReplyProducingMessageHandler
Subclasses must implement this method to handle the request Message. The return value may be a Message, a MessageBuilder, or any plain Object. The base class will handle the final creation of a reply Message from any of those starting points. If the return value is null, the Message flow will end here.

Specified by:
handleRequestMessage in class AbstractReplyProducingMessageHandler

Spring Integration