Package org.springframework.integration.amqp.dsl

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 Type	Method	Description
RabbitStreamMessageListenerContainerSpec	adviceChain(Advice... adviceChain)
RabbitStreamMessageListenerContainerSpec	configure(Consumer<StreamListenerContainer> consumer)	Perform additional configuration of the container.
RabbitStreamMessageListenerContainerSpec	consumerCustomizer(ConsumerCustomizer customizer)	Set a consumer customizer.
RabbitStreamMessageListenerContainerSpec	streamConverter(StreamMessageConverter converter)	Set a stream message converter.
RabbitStreamMessageListenerContainerSpec	superStream(String superStream, String name)	Enable Single Active Consumer on a Super Stream.
RabbitStreamMessageListenerContainerSpec	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

public RabbitStreamMessageListenerContainerSpec superStream(String superStream,
 String name)

Enable Single Active Consumer on a Super Stream. Mutually exclusive with MessageListenerContainerSpec.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 with MessageListenerContainerSpec.queueName(String...).

Parameters:

superStream - the stream.

name - the consumer name.

consumers - the number of consumers.

Returns:

this spec.

Since:

6.1

streamConverter

public RabbitStreamMessageListenerContainerSpec streamConverter(StreamMessageConverter converter)

Set a stream message converter.

Parameters:

converter - the converter.

Returns:

this spec.

consumerCustomizer

public RabbitStreamMessageListenerContainerSpec consumerCustomizer(ConsumerCustomizer customizer)

Set a consumer customizer.

Parameters:

customizer - the customizer.

Returns:

this spec.

adviceChain

public RabbitStreamMessageListenerContainerSpec adviceChain(Advice... adviceChain)

Parameters:

adviceChain - the adviceChain.

Returns:

the spec.

See Also:

• StreamListenerContainer.setAdviceChain(Advice[])

configure

public RabbitStreamMessageListenerContainerSpec configure(Consumer<StreamListenerContainer> consumer)

Perform additional configuration of the container.

Parameters:

consumer - a consumer for the container.

Returns:

this spec.