Package org.springframework.integration.amqp.dsl

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 RabbitStreamMessageHandlers.

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 Type	Method	Description
RabbitStreamMessageHandlerSpec	confirmTimeout(long timeout)	Set a timeout for the confirm result.
RabbitStreamMessageHandlerSpec	headerMapper(AmqpHeaderMapper headerMapper)	Set a custom AmqpHeaderMapper for mapping request and reply headers.
RabbitStreamMessageHandlerSpec	headersMappedLast(boolean headersLast)	Determine whether the headers are mapped before the message is converted, or afterwards.
RabbitStreamMessageHandlerSpec	mappedRequestHeaders(String... headers)	Provide the header names that should be mapped from a request to a MessageHeaders.
RabbitStreamMessageHandlerSpec	sendFailureChannel(String channel)	Set the failure channel.
RabbitStreamMessageHandlerSpec	sendFailureChannel(MessageChannel channel)	Set the failure channel.
RabbitStreamMessageHandlerSpec	sendSuccessChannel(String channel)	Set the success channel.
RabbitStreamMessageHandlerSpec	sendSuccessChannel(MessageChannel channel)	Set the success channel.
RabbitStreamMessageHandlerSpec	sync(boolean sync)	Set to true to wait for a confirmation.

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, afterPropertiesSet, destroy, doGet, 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

public RabbitStreamMessageHandlerSpec headerMapper(AmqpHeaderMapper headerMapper)

Set a custom AmqpHeaderMapper for mapping request and reply headers.

Parameters:

headerMapper - the AmqpHeaderMapper to use.

Returns:

this spec.

mappedRequestHeaders

public RabbitStreamMessageHandlerSpec mappedRequestHeaders(String... headers)

Provide the header names that should be mapped from a request to a MessageHeaders.

Parameters:

headers - The request header names.

Returns:

this spec.

headersMappedLast

public RabbitStreamMessageHandlerSpec headersMappedLast(boolean headersLast)

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:

• RabbitStreamMessageHandler.setHeadersMappedLast(boolean)

sendSuccessChannel

public RabbitStreamMessageHandlerSpec sendSuccessChannel(MessageChannel channel)

Set the success channel.

Parameters:

channel - the channel.

Returns:

this spec.

sendFailureChannel

public RabbitStreamMessageHandlerSpec sendFailureChannel(MessageChannel channel)

Set the failure channel. After a send failure, an ErrorMessage will be sent to this channel with a payload of the exception with the failed message.

Parameters:

channel - the channel.

Returns:

this spec.

sendSuccessChannel

public RabbitStreamMessageHandlerSpec sendSuccessChannel(String channel)

Set the success channel.

Parameters:

channel - the channel.

Returns:

this spec.

sendFailureChannel

public RabbitStreamMessageHandlerSpec sendFailureChannel(String channel)

Set the failure channel. After a send failure, an ErrorMessage will be sent to this channel with a payload of the exception with the failed message.

Parameters:

channel - the channel.

Returns:

this spec.

sync

public RabbitStreamMessageHandlerSpec sync(boolean sync)

Set to true to wait for a confirmation.

Parameters:

sync - true to wait.

Returns:

this spec.

See Also:

• confirmTimeout(long)

confirmTimeout

public RabbitStreamMessageHandlerSpec confirmTimeout(long timeout)

Set a timeout for the confirm result.

Parameters:

timeout - the approximate timeout.

Returns:

this spec.

See Also:

• sync(boolean)