org.springframework.integration.amqp.outbound
Class AmqpOutboundEndpoint
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.handler.AbstractReplyProducingMessageHandler
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, org.springframework.integration.context.NamedComponent, org.springframework.integration.context.Orderable, org.springframework.integration.core.MessageHandler, org.springframework.integration.core.MessageProducer, org.springframework.integration.history.TrackableComponent
public class AmqpOutboundEndpoint
- extends org.springframework.integration.handler.AbstractReplyProducingMessageHandler
Adapter that converts and sends Messages to an AMQP Exchange.
- Since:
- 2.1
| Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport |
logger |
| Fields inherited from interface org.springframework.core.Ordered |
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE |
| 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 |
AmqpOutboundEndpoint
public AmqpOutboundEndpoint(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
onInit
protected void onInit()
- Overrides:
onInit in class org.springframework.integration.handler.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()
- Specified by:
getComponentType in interface org.springframework.integration.context.NamedComponent- Overrides:
getComponentType in class org.springframework.integration.handler.AbstractMessageHandler
handleRequestMessage
protected java.lang.Object handleRequestMessage(org.springframework.integration.Message<?> requestMessage)
- Specified by:
handleRequestMessage in class org.springframework.integration.handler.AbstractReplyProducingMessageHandler