public class AmqpOutboundEndpoint extends AbstractReplyProducingMessageHandler implements org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback, org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnCallback
AbstractReplyProducingMessageHandler.RequestHandlerlogger| 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()
Subclasses may implement this method to provide component type information.
|
protected java.lang.Object |
handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
Subclasses must implement this method to handle the request Message.
|
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 |
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, setAdviceChain, setBeanClassLoader, setChannelResolver, setOutputChannel, setRequiresReply, setSendTimeout, shouldCopyRequestHeadersgetOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic AmqpOutboundEndpoint(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
protected void doInit()
doInit in class 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.messaging.MessageChannel ackChannel)
public void setConfirmNackChannel(org.springframework.messaging.MessageChannel nackChannel)
public void setReturnChannel(org.springframework.messaging.MessageChannel returnChannel)
public java.lang.String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class AbstractMessageHandlerprotected java.lang.Object handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
AbstractReplyProducingMessageHandlerhandleRequestMessage in class 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