Uses of Class
org.springframework.integration.amqp.dsl.RabbitStreamMessageHandlerSpec

Packages that use RabbitStreamMessageHandlerSpec

Package	Description
org.springframework.integration.amqp.dsl	Provides AMQP Component support for the Java DSL.

Uses of RabbitStreamMessageHandlerSpec in org.springframework.integration.amqp.dsl

Methods in org.springframework.integration.amqp.dsl that return RabbitStreamMessageHandlerSpec

Modifier and Type	Method	Description
RabbitStreamMessageHandlerSpec	RabbitStreamMessageHandlerSpec.confirmTimeout(long timeout)	Set a timeout for the confirm result.
RabbitStreamMessageHandlerSpec	RabbitStreamMessageHandlerSpec.headerMapper(AmqpHeaderMapper headerMapper)	Set a custom AmqpHeaderMapper for mapping request and reply headers.
RabbitStreamMessageHandlerSpec	RabbitStreamMessageHandlerSpec.headersMappedLast(boolean headersLast)	Determine whether the headers are mapped before the message is converted, or afterwards.
RabbitStreamMessageHandlerSpec	RabbitStreamMessageHandlerSpec.mappedRequestHeaders(String... headers)	Provide the header names that should be mapped from a request to a MessageHeaders.
static RabbitStreamMessageHandlerSpec	RabbitStream.outboundStreamAdapter(com.rabbitmq.stream.Environment environment, String streamName)	Create an initial RabbitStreamMessageHandlerSpec (adapter).
static RabbitStreamMessageHandlerSpec	RabbitStream.outboundStreamAdapter(RabbitStreamTemplate template)	Create an initial RabbitStreamMessageHandlerSpec (adapter).
RabbitStreamMessageHandlerSpec	RabbitStreamMessageHandlerSpec.sendFailureChannel(String channel)	Set the failure channel.
RabbitStreamMessageHandlerSpec	RabbitStreamMessageHandlerSpec.sendFailureChannel(MessageChannel channel)	Set the failure channel.
RabbitStreamMessageHandlerSpec	RabbitStreamMessageHandlerSpec.sendSuccessChannel(String channel)	Set the success channel.
RabbitStreamMessageHandlerSpec	RabbitStreamMessageHandlerSpec.sendSuccessChannel(MessageChannel channel)	Set the success channel.
RabbitStreamMessageHandlerSpec	RabbitStreamMessageHandlerSpec.sync(boolean sync)	Set to true to wait for a confirmation.