Class RabbitStreamMessageHandlerSpec
java.lang.Object
org.springframework.integration.dsl.IntegrationComponentSpec<S,H>
org.springframework.integration.dsl.MessageHandlerSpec<RabbitStreamMessageHandlerSpec,RabbitStreamMessageHandler>
org.springframework.integration.amqp.dsl.RabbitStreamMessageHandlerSpec
- All Implemented Interfaces:
DisposableBean
,FactoryBean<RabbitStreamMessageHandler>
,InitializingBean
,Lifecycle
,Phased
,SmartLifecycle
public class RabbitStreamMessageHandlerSpec
extends MessageHandlerSpec<RabbitStreamMessageHandlerSpec,RabbitStreamMessageHandler>
The base
MessageHandlerSpec
for RabbitStreamMessageHandler
s.- Since:
- 6.0
- Author:
- Gary Russell
-
Field Summary
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
logger, PARSER, target
Fields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTE
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE
-
Method Summary
Modifier and TypeMethodDescriptionconfirmTimeout
(long timeout) Set a timeout for the confirm result.headerMapper
(AmqpHeaderMapper headerMapper) Set a customAmqpHeaderMapper
for mapping request and reply headers.headersMappedLast
(boolean headersLast) Determine whether the headers are mapped before the message is converted, or afterwards.mappedRequestHeaders
(String... headers) Provide the header names that should be mapped from a request to aMessageHeaders
.sendFailureChannel
(String channel) Set the failure channel.sendFailureChannel
(MessageChannel channel) Set the failure channel.sendSuccessChannel
(String channel) Set the success channel.sendSuccessChannel
(MessageChannel channel) Set the success channel.sync
(boolean sync) Set to true to wait for a confirmation.Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.beans.factory.FactoryBean
isSingleton
-
Method Details
-
headerMapper
Set a customAmqpHeaderMapper
for mapping request and reply headers.- Parameters:
headerMapper
- theAmqpHeaderMapper
to use.- Returns:
- this spec.
-
mappedRequestHeaders
Provide the header names that should be mapped from a request to aMessageHeaders
.- Parameters:
headers
- The request header names.- Returns:
- this spec.
-
headersMappedLast
Determine whether the headers are mapped before the message is converted, or afterwards.- Parameters:
headersLast
- true to map headers last.- Returns:
- this spec.
- See Also:
-
sendSuccessChannel
Set the success channel.- Parameters:
channel
- the channel.- Returns:
- this spec.
-
sendFailureChannel
Set the failure channel. After a send failure, anErrorMessage
will be sent to this channel with a payload of the exception with the failed message.- Parameters:
channel
- the channel.- Returns:
- this spec.
-
sendSuccessChannel
Set the success channel.- Parameters:
channel
- the channel.- Returns:
- this spec.
-
sendFailureChannel
Set the failure channel. After a send failure, anErrorMessage
will be sent to this channel with a payload of the exception with the failed message.- Parameters:
channel
- the channel.- Returns:
- this spec.
-
sync
Set to true to wait for a confirmation.- Parameters:
sync
- true to wait.- Returns:
- this spec.
- See Also:
-
confirmTimeout
Set a timeout for the confirm result.- Parameters:
timeout
- the approximate timeout.- Returns:
- this spec.
- See Also:
-