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.amqp.rabbit.core.RabbitTemplate.ConfirmCallback, org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnCallback, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, 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
- implements org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback, org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnCallback
Adapter that converts and sends Messages to an AMQP Exchange.
- Since:
- 2.1
| Nested classes/interfaces inherited from class org.springframework.integration.handler.AbstractReplyProducingMessageHandler |
org.springframework.integration.handler.AbstractReplyProducingMessageHandler.RequestHandler |
| 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, setAdviceChain, setBeanClassLoader, 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)
setConfirmCorrelationExpression
public void setConfirmCorrelationExpression(java.lang.String confirmCorrelationExpression)
setConfirmAckChannel
public void setConfirmAckChannel(org.springframework.integration.MessageChannel ackChannel)
setConfirmNackChannel
public void setConfirmNackChannel(org.springframework.integration.MessageChannel nackChannel)
setReturnChannel
public void setReturnChannel(org.springframework.integration.MessageChannel returnChannel)
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
confirm
public void confirm(org.springframework.amqp.rabbit.support.CorrelationData correlationData,
boolean ack)
- Specified by:
confirm in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback
returnedMessage
public void returnedMessage(org.springframework.amqp.core.Message message,
int replyCode,
java.lang.String replyText,
java.lang.String exchange,
java.lang.String routingKey)
- Specified by:
returnedMessage in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnCallback