Package org.springframework.integration.amqp.dsl

Class RabbitStreamInboundChannelAdapterSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,P>

org.springframework.integration.dsl.MessageProducerSpec<S,AmqpInboundChannelAdapter>

org.springframework.integration.amqp.dsl.AmqpBaseInboundChannelAdapterSpec<S>

org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterSpec<RabbitStreamInboundChannelAdapterSpec,StreamListenerContainer>

org.springframework.integration.amqp.dsl.RabbitStreamInboundChannelAdapterSpec

All Implemented Interfaces:

DisposableBean, FactoryBean<AmqpInboundChannelAdapter>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration

public class RabbitStreamInboundChannelAdapterSpec
extends AmqpInboundChannelAdapterSpec<RabbitStreamInboundChannelAdapterSpec,StreamListenerContainer>

Spec for an inbound channel adapter with a StreamListenerContainer.

Since:

6.0

Author:

Gary Russell, Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterSpec

listenerContainerSpec

Fields inherited from class org.springframework.integration.amqp.dsl.AmqpBaseInboundChannelAdapterSpec

headerMapper

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RabbitStreamInboundChannelAdapterSpec(com.rabbitmq.stream.Environment environment, com.rabbitmq.stream.Codec codec)
protected	RabbitStreamInboundChannelAdapterSpec(StreamListenerContainer listenerContainer)

Method Summary

Modifier and Type	Method	Description
RabbitStreamInboundChannelAdapterSpec	configureContainer(Consumer<RabbitStreamMessageListenerContainerSpec> configurer)
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.

Methods inherited from class org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterSpec

getComponentsToRegister

Methods inherited from class org.springframework.integration.amqp.dsl.AmqpBaseInboundChannelAdapterSpec

headerMapper, mappedRequestHeaders, messageConverter, messageRecoverer, recoveryCallback, retryTemplate

Methods inherited from class org.springframework.integration.dsl.MessageProducerSpec

autoStartup, errorChannel, errorChannel, errorMessageStrategy, id, observationConvention, outputChannel, outputChannel, phase, sendTimeout, shouldTrack

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, 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

Constructor Details

RabbitStreamInboundChannelAdapterSpec

protected RabbitStreamInboundChannelAdapterSpec(StreamListenerContainer listenerContainer)

RabbitStreamInboundChannelAdapterSpec

protected RabbitStreamInboundChannelAdapterSpec(com.rabbitmq.stream.Environment environment,
 @Nullable
 com.rabbitmq.stream.Codec codec)

Method Details

streamName

public RabbitStreamInboundChannelAdapterSpec streamName(String streamName)

Configure a name for Rabbit stream to consume from.

Parameters:

streamName - the name of Rabbit stream.

Returns:

the spec

Since:

6.1

superStream

public RabbitStreamInboundChannelAdapterSpec superStream(String superStream,
 String consumerName)

Configure a name for Rabbit super stream to consume from.

Parameters:

superStream - the name of Rabbit super stream.

consumerName - the logical name to enable offset tracking.

Returns:

the spec

Since:

6.1

superStream

public RabbitStreamInboundChannelAdapterSpec superStream(String superStream,
 String consumerName,
 int consumers)

Configure a name for Rabbit super stream to consume from.

Parameters:

superStream - the name of Rabbit super stream.

consumerName - the logical name to enable offset tracking.

consumers - the number of consumers.

Returns:

the spec

Since:

6.1

configureContainer

public RabbitStreamInboundChannelAdapterSpec configureContainer(Consumer<RabbitStreamMessageListenerContainerSpec> configurer)