Class RabbitStreamMessageListenerContainerSpec
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,C>
org.springframework.integration.amqp.dsl.MessageListenerContainerSpec<RabbitStreamMessageListenerContainerSpec,StreamListenerContainer>
org.springframework.integration.amqp.dsl.RabbitStreamMessageListenerContainerSpec
- All Implemented Interfaces:
Aware,BeanClassLoaderAware,BeanFactoryAware,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
PARSER, targetFields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
loggerFields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTEFields 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.Methods inherited from class org.springframework.integration.amqp.dsl.MessageListenerContainerSpec
queueNameMethods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopMethods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
-
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.
-
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.
-