public class AmqpOutboundEndpoint
extends org.springframework.integration.handler.AbstractReplyProducingMessageHandler
implements org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback, org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnCallback, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>
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,
java.lang.String cause) |
protected void |
doInit() |
java.lang.String |
getComponentType() |
protected java.lang.Object |
handleRequestMessage(org.springframework.messaging.Message<?> requestMessage) |
void |
onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent event) |
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 |
setLazyConnect(boolean lazyConnect)
Set to
false to attempt to connect during endpoint start;
default true , meaning the connection will be attempted
to be established on the arrival of the first message. |
void |
setReturnChannel(org.springframework.messaging.MessageChannel returnChannel) |
void |
setRoutingKey(java.lang.String routingKey) |
void |
setRoutingKeyExpression(java.lang.String routingKeyExpression) |
doInvokeAdvisedRequestHandler, handleMessageInternal, hasAdviceChain, onInit, produceReply, setAdviceChain, setBeanClassLoader, setChannelResolver, setRequiresReply, shouldCopyRequestHeaders
getOutputChannel, setOutputChannel, setOutputChannelName, setSendTimeout
getOrder, handleMessage, setOrder, setShouldTrack
afterPropertiesSet, getApplicationContext, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
public 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 void setLazyConnect(boolean lazyConnect)
false
to attempt to connect during endpoint start;
default true
, meaning the connection will be attempted
to be established on the arrival of the first message.lazyConnect
- the lazyConnect to setpublic java.lang.String getComponentType()
getComponentType
in interface org.springframework.integration.support.context.NamedComponent
getComponentType
in class org.springframework.integration.handler.AbstractMessageHandler
protected void doInit()
doInit
in class org.springframework.integration.handler.AbstractReplyProducingMessageHandler
public void onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent event)
onApplicationEvent
in interface org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>
protected java.lang.Object handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
handleRequestMessage
in class org.springframework.integration.handler.AbstractReplyProducingMessageHandler
public void confirm(org.springframework.amqp.rabbit.support.CorrelationData correlationData, boolean ack, java.lang.String cause)
confirm
in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback
public 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