Class AmqpOutboundEndpoint
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.handler.AbstractMessageProducingHandler
org.springframework.integration.handler.AbstractReplyProducingMessageHandler
org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint
org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint
- All Implemented Interfaces:
org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>,org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback,org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnsCallback,org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.context.ApplicationContextAware,org.springframework.context.Lifecycle,org.springframework.core.Ordered,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.context.Orderable,org.springframework.integration.core.MessageProducer,org.springframework.integration.handler.HeaderPropagationAware,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.IntegrationManagement,org.springframework.integration.support.management.ManageableLifecycle,org.springframework.integration.support.management.TrackableComponent,org.springframework.messaging.MessageHandler,reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>
public class AmqpOutboundEndpoint
extends AbstractAmqpOutboundEndpoint
implements org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback, org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnsCallback
Adapter that converts and sends Messages to an AMQP Exchange.
- Since:
- 2.1
-
Nested Class Summary
Nested classes/interfaces inherited from class org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint
AbstractAmqpOutboundEndpoint.CorrelationDataWrapperNested classes/interfaces inherited from class org.springframework.integration.handler.AbstractReplyProducingMessageHandler
org.springframework.integration.handler.AbstractReplyProducingMessageHandler.RequestHandlerNested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement
org.springframework.integration.support.management.IntegrationManagement.ManagementOverrides -
Field Summary
Fields inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler
messagingTemplateFields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, loggerFields inherited from interface org.springframework.integration.support.management.IntegrationManagement
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEFields inherited from interface org.springframework.core.Ordered
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE -
Constructor Summary
ConstructorsConstructorDescriptionAmqpOutboundEndpoint(org.springframework.amqp.core.AmqpTemplate amqpTemplate) -
Method Summary
Modifier and TypeMethodDescriptionvoidconfirm(org.springframework.amqp.rabbit.connection.CorrelationData correlationData, boolean ack, String cause) protected voiddoStop()protected voidSubclasses can override to perform any additional initialization.org.springframework.integration.IntegrationPatternTypeorg.springframework.amqp.rabbit.core.RabbitTemplateprotected ObjecthandleRequestMessage(org.springframework.messaging.Message<?> requestMessage) voidreturnedMessage(org.springframework.amqp.core.ReturnedMessage returnedMessage) voidsetExpectReply(boolean expectReply) Set to true if this endpoint is a gateway.voidsetMultiSend(boolean multiSend) If true, and the message payload is anIterableofMessage, send the messages in a single invocation of the template (same channel) and optionally wait for the confirms or die or perform all sends within a transaction (existing or new).voidsetWaitForConfirm(boolean waitForConfirm) Set to true if you want to block the calling thread until a publisher confirm has been received.Methods inherited from class org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint
addDelayProperty, buildReply, buildReturnedMessage, doInit, doStart, generateCorrelationData, generateExchangeName, generateRoutingKey, getConfirmAckChannel, getConfirmCorrelationExpression, getConfirmNackChannel, getConfirmTimeout, getCorrelationDataGenerator, getDefaultDeliveryMode, getExchangeName, getExchangeNameExpression, getExchangeNameGenerator, getHeaderMapper, getReturnChannel, getRoutingKey, getRoutingKeyExpression, getRoutingKeyGenerator, handleConfirm, isHeadersMappedLast, isLazyConnect, isRunning, setConfirmAckChannel, setConfirmAckChannelName, setConfirmCorrelationExpression, setConfirmCorrelationExpressionString, setConfirmNackChannel, setConfirmNackChannelName, setConfirmTimeout, setConnectionFactory, setDefaultDeliveryMode, setDelay, setDelayExpression, setDelayExpressionString, setErrorMessageStrategy, setExchangeName, setExchangeNameExpression, setExchangeNameExpressionString, setHeaderMapper, setHeadersMappedLast, setLazyConnect, setReturnChannel, setRoutingKey, setRoutingKeyExpression, setRoutingKeyExpressionString, start, stopMethods inherited from class org.springframework.integration.handler.AbstractReplyProducingMessageHandler
doInvokeAdvisedRequestHandler, getBeanClassLoader, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReplyMethods inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeadersMethods inherited from class org.springframework.integration.handler.AbstractMessageHandler
handleMessage, onComplete, onError, onNext, onSubscribe, setObservationConventionMethods inherited from class org.springframework.integration.handler.MessageHandlerSupport
buildSendTimer, destroy, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface reactor.core.CoreSubscriber
currentContextMethods inherited from interface org.springframework.integration.support.management.IntegrationManagement
getThisAsMethods inherited from interface org.springframework.integration.support.context.NamedComponent
getBeanName, getComponentName
-
Constructor Details
-
AmqpOutboundEndpoint
public AmqpOutboundEndpoint(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
-
-
Method Details
-
setExpectReply
public void setExpectReply(boolean expectReply) Set to true if this endpoint is a gateway.- Parameters:
expectReply- true for a gateway.
-
setWaitForConfirm
public void setWaitForConfirm(boolean waitForConfirm) Set to true if you want to block the calling thread until a publisher confirm has been received. Requires a template configured for returns. If a confirm is not received within the confirm timeout or a negative acknowledgment or returned message is received, an exception will be thrown. Does not apply to the gateway since it blocks awaiting the reply.- Parameters:
waitForConfirm- true to block until the confirmation or timeout is received.- Since:
- 5.2
- See Also:
-
getComponentType
- Specified by:
getComponentTypein interfaceorg.springframework.integration.support.context.NamedComponent- Overrides:
getComponentTypein classorg.springframework.integration.handler.MessageHandlerSupport
-
setMultiSend
public void setMultiSend(boolean multiSend) If true, and the message payload is anIterableofMessage, send the messages in a single invocation of the template (same channel) and optionally wait for the confirms or die or perform all sends within a transaction (existing or new).- Parameters:
multiSend- true to send multiple messages.- Since:
- 5.3
- See Also:
-
getIntegrationPatternType
public org.springframework.integration.IntegrationPatternType getIntegrationPatternType()- Specified by:
getIntegrationPatternTypein interfaceorg.springframework.integration.IntegrationPattern- Overrides:
getIntegrationPatternTypein classorg.springframework.integration.handler.AbstractReplyProducingMessageHandler
-
getRabbitTemplate
public org.springframework.amqp.rabbit.core.RabbitTemplate getRabbitTemplate()- Specified by:
getRabbitTemplatein classAbstractAmqpOutboundEndpoint
-
endpointInit
protected void endpointInit()Description copied from class:AbstractAmqpOutboundEndpointSubclasses can override to perform any additional initialization. Called from afterPropertiesSet().- Overrides:
endpointInitin classAbstractAmqpOutboundEndpoint
-
doStop
protected void doStop()- Overrides:
doStopin classAbstractAmqpOutboundEndpoint
-
handleRequestMessage
- Specified by:
handleRequestMessagein classorg.springframework.integration.handler.AbstractReplyProducingMessageHandler
-
confirm
public void confirm(org.springframework.amqp.rabbit.connection.CorrelationData correlationData, boolean ack, String cause) - Specified by:
confirmin interfaceorg.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback
-
returnedMessage
public void returnedMessage(org.springframework.amqp.core.ReturnedMessage returnedMessage) - Specified by:
returnedMessagein interfaceorg.springframework.amqp.rabbit.core.RabbitTemplate.ReturnsCallback
-