Uses of Class
org.springframework.integration.amqp.dsl.RabbitStreamMessageHandlerSpec
Packages that use RabbitStreamMessageHandlerSpec
Package
Description
Provides AMQP Component support for the Java DSL.
-
Uses of RabbitStreamMessageHandlerSpec in org.springframework.integration.amqp.dsl
Subclasses with type arguments of type RabbitStreamMessageHandlerSpec in org.springframework.integration.amqp.dslModifier and TypeClassDescriptionclassThe baseMessageHandlerSpecforRabbitStreamMessageHandlers.Methods in org.springframework.integration.amqp.dsl that return RabbitStreamMessageHandlerSpecModifier and TypeMethodDescriptionRabbitStreamMessageHandlerSpec.confirmTimeout(long timeout) Set a timeout for the confirm result.RabbitStreamMessageHandlerSpec.headerMapper(AmqpHeaderMapper headerMapper) Set a customAmqpHeaderMapperfor 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 aMessageHeaders.RabbitStream.outboundStreamAdapter(com.rabbitmq.stream.Environment environment, String streamName) Create an initialRabbitStreamMessageHandlerSpec(adapter).RabbitStream.outboundStreamAdapter(RabbitStreamTemplate template) Create an initialRabbitStreamMessageHandlerSpec(adapter).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.