public class AmqpOutboundEndpoint
extends org.springframework.integration.handler.AbstractReplyProducingMessageHandler
implements org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback, org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnCallback
| Constructor and Description |
|---|
AmqpOutboundEndpoint(org.springframework.amqp.core.AmqpTemplate amqpTemplate) |
| Modifier and Type | Method and Description |
|---|---|
void |
confirm(org.springframework.amqp.rabbit.support.CorrelationData correlationData,
boolean ack) |
protected void |
doInit() |
java.lang.String |
getComponentType() |
protected java.lang.Object |
handleRequestMessage(org.springframework.integration.Message<?> requestMessage) |
void |
returnedMessage(org.springframework.amqp.core.Message message,
int replyCode,
java.lang.String replyText,
java.lang.String exchange,
java.lang.String routingKey) |
void |
setConfirmAckChannel(org.springframework.integration.MessageChannel ackChannel) |
void |
setConfirmCorrelationExpression(java.lang.String confirmCorrelationExpression) |
void |
setConfirmNackChannel(org.springframework.integration.MessageChannel nackChannel) |
void |
setExchangeName(java.lang.String exchangeName) |
void |
setExchangeNameExpression(java.lang.String exchangeNameExpression) |
void |
setExpectReply(boolean expectReply) |
void |
setHeaderMapper(AmqpHeaderMapper headerMapper) |
void |
setReturnChannel(org.springframework.integration.MessageChannel returnChannel) |
void |
setRoutingKey(java.lang.String routingKey) |
void |
setRoutingKeyExpression(java.lang.String routingKeyExpression) |
doInvokeAdvisedRequestHandler, getMessagingTemplate, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setChannelResolver, setOutputChannel, setRequiresReply, setSendTimeout, shouldCopyRequestHeadersgetOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, toStringpublic AmqpOutboundEndpoint(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
protected void doInit()
doInit in class org.springframework.integration.handler.AbstractReplyProducingMessageHandlerpublic void setHeaderMapper(AmqpHeaderMapper headerMapper)
public void setExchangeName(java.lang.String exchangeName)
public void setExchangeNameExpression(java.lang.String exchangeNameExpression)
public void setRoutingKey(java.lang.String routingKey)
public void setRoutingKeyExpression(java.lang.String routingKeyExpression)
public void setExpectReply(boolean expectReply)
public void setConfirmCorrelationExpression(java.lang.String confirmCorrelationExpression)
public void setConfirmAckChannel(org.springframework.integration.MessageChannel ackChannel)
public void setConfirmNackChannel(org.springframework.integration.MessageChannel nackChannel)
public void setReturnChannel(org.springframework.integration.MessageChannel returnChannel)
public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.handler.AbstractMessageHandlerprotected java.lang.Object handleRequestMessage(org.springframework.integration.Message<?> requestMessage)
handleRequestMessage in class org.springframework.integration.handler.AbstractReplyProducingMessageHandlerpublic void confirm(org.springframework.amqp.rabbit.support.CorrelationData correlationData,
boolean ack)
confirm in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallbackpublic void returnedMessage(org.springframework.amqp.core.Message message,
int replyCode,
java.lang.String replyText,
java.lang.String exchange,
java.lang.String routingKey)
returnedMessage in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnCallback