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.messaging.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.messaging.MessageChannel ackChannel) |
void |
setConfirmCorrelationExpression(java.lang.String confirmCorrelationExpression) |
void |
setConfirmNackChannel(org.springframework.messaging.MessageChannel nackChannel) |
void |
setDefaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDeliveryMode) |
void |
setExchangeName(java.lang.String exchangeName) |
void |
setExchangeNameExpression(java.lang.String exchangeNameExpression) |
void |
setExpectReply(boolean expectReply) |
void |
setHeaderMapper(AmqpHeaderMapper headerMapper) |
void |
setReturnChannel(org.springframework.messaging.MessageChannel returnChannel) |
void |
setRoutingKey(java.lang.String routingKey) |
void |
setRoutingKeyExpression(java.lang.String routingKeyExpression) |
doInvokeAdvisedRequestHandler, getMessagingTemplate, handleMessageInternal, hasAdviceChain, onInit, produceReply, setAdviceChain, setBeanClassLoader, setChannelResolver, setOutputChannel, setOutputChannelName, setRequiresReply, setSendTimeout, shouldCopyRequestHeadersgetOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toStringpublic AmqpOutboundEndpoint(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
public 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.messaging.MessageChannel ackChannel)
public void setConfirmNackChannel(org.springframework.messaging.MessageChannel nackChannel)
public void setReturnChannel(org.springframework.messaging.MessageChannel returnChannel)
public void setDefaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDeliveryMode)
public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.handler.AbstractMessageHandlerprotected void doInit()
doInit in class org.springframework.integration.handler.AbstractReplyProducingMessageHandlerprotected java.lang.Object handleRequestMessage(org.springframework.messaging.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