Class RabbitStreamMessageListenerContainerSpec
java.lang.Object
org.springframework.integration.dsl.IntegrationComponentSpec<S,C>
org.springframework.integration.amqp.dsl.MessageListenerContainerSpec<RabbitStreamMessageListenerContainerSpec,StreamListenerContainer>
org.springframework.integration.amqp.dsl.RabbitStreamMessageListenerContainerSpec
- All Implemented Interfaces:
DisposableBean
,FactoryBean<StreamListenerContainer>
,InitializingBean
,Lifecycle
,Phased
,SmartLifecycle
public class RabbitStreamMessageListenerContainerSpec
extends MessageListenerContainerSpec<RabbitStreamMessageListenerContainerSpec,StreamListenerContainer>
Spec for
StreamListenerContainer
.- Since:
- 6.0
- Author:
- Gary Russell, Artem Bilan
-
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 TypeMethodDescriptionadviceChain
(Advice... adviceChain) configure
(Consumer<StreamListenerContainer> consumer) Perform additional configuration of the container.consumerCustomizer
(ConsumerCustomizer customizer) Set a consumer customizer.streamConverter
(StreamMessageConverter converter) Set a stream message converter.superStream
(String superStream, String name) Enable Single Active Consumer on a Super Stream.superStream
(String superStream, String name, int consumers) Enable Single Active Consumer on a Super Stream.Methods inherited from class org.springframework.integration.amqp.dsl.MessageListenerContainerSpec
queueName
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
-
superStream
Enable Single Active Consumer on a Super Stream. Mutually exclusive withMessageListenerContainerSpec.queueName(String...)
.- Parameters:
superStream
- the stream.name
- the consumer name.- Returns:
- this spec.
-
superStream
public RabbitStreamMessageListenerContainerSpec superStream(String superStream, String name, int consumers) Enable Single Active Consumer on a Super Stream. Mutually exclusive withMessageListenerContainerSpec.queueName(String...)
.- Parameters:
superStream
- the stream.name
- the consumer name.consumers
- the number of consumers.- Returns:
- this spec.
- Since:
- 6.1
-
streamConverter
Set a stream message converter.- Parameters:
converter
- the converter.- Returns:
- this spec.
-
consumerCustomizer
Set a consumer customizer.- Parameters:
customizer
- the customizer.- Returns:
- this spec.
-
adviceChain
- Parameters:
adviceChain
- the adviceChain.- Returns:
- the spec.
- See Also:
-
configure
public RabbitStreamMessageListenerContainerSpec configure(Consumer<StreamListenerContainer> consumer) Perform additional configuration of the container.- Parameters:
consumer
- a consumer for the container.- Returns:
- this spec.
-