Uses of Class
org.springframework.integration.amqp.dsl.RabbitStreamInboundChannelAdapterSpec
Package
Description
Provides AMQP Component support for the Java DSL.
-
Uses of RabbitStreamInboundChannelAdapterSpec in org.springframework.integration.amqp.dsl
Modifier and TypeMethodDescriptionRabbitStreamInboundChannelAdapterSpec.configureContainer
(Consumer<RabbitStreamMessageListenerContainerSpec> configurer) RabbitStream.inboundAdapter
(com.rabbitmq.stream.Environment environment) Create an initialRabbitStreamInboundChannelAdapterSpec
with the providedEnvironment
.RabbitStream.inboundAdapter
(com.rabbitmq.stream.Environment environment, com.rabbitmq.stream.Codec codec) Create an initialRabbitStreamInboundChannelAdapterSpec
with the providedEnvironment
.RabbitStream.inboundAdapter
(StreamListenerContainer listenerContainer) Create an initialRabbitStreamInboundChannelAdapterSpec
with the providedStreamListenerContainer
.RabbitStreamInboundChannelAdapterSpec.streamName
(String streamName) Configure a name for Rabbit stream to consume from.RabbitStreamInboundChannelAdapterSpec.superStream
(String superStream, String consumerName) Configure a name for Rabbit super stream to consume from.RabbitStreamInboundChannelAdapterSpec.superStream
(String superStream, String consumerName, int consumers) Configure a name for Rabbit super stream to consume from.