Package org.springframework.integration.amqp.dsl

Class RabbitStream

java.lang.Object

org.springframework.integration.amqp.dsl.RabbitStream

public final class RabbitStream
extends Object

Factory class for RabbitMQ components.

Since:

6.0

Author:

Gary Russell, Artem Bilan

Method Summary

Modifier and Type	Method	Description
static RabbitStreamInboundChannelAdapterSpec	inboundAdapter(com.rabbitmq.stream.Environment environment)	Create an initial RabbitStreamInboundChannelAdapterSpec with the provided Environment.
static RabbitStreamInboundChannelAdapterSpec	inboundAdapter(com.rabbitmq.stream.Environment environment, com.rabbitmq.stream.Codec codec)	Create an initial RabbitStreamInboundChannelAdapterSpec with the provided Environment.
static RabbitStreamInboundChannelAdapterSpec	inboundAdapter(StreamListenerContainer listenerContainer)	Create an initial RabbitStreamInboundChannelAdapterSpec with the provided StreamListenerContainer.
static RabbitStreamMessageHandlerSpec	outboundStreamAdapter(com.rabbitmq.stream.Environment environment, String streamName)	Create an initial RabbitStreamMessageHandlerSpec (adapter).
static RabbitStreamMessageHandlerSpec	outboundStreamAdapter(RabbitStreamTemplate template)	Create an initial RabbitStreamMessageHandlerSpec (adapter).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

inboundAdapter

public static RabbitStreamInboundChannelAdapterSpec inboundAdapter(StreamListenerContainer listenerContainer)

Create an initial RabbitStreamInboundChannelAdapterSpec with the provided StreamListenerContainer. The streamName or superStream must be provided after creation of this spec; or the listenerContainer options should be specified on the provided StreamListenerContainer using RabbitStreamInboundChannelAdapterSpec.configureContainer(java.util.function.Consumer).

Parameters:

listenerContainer - the listenerContainer.

Returns:

the RabbitInboundChannelAdapterSLCSpec.

inboundAdapter

public static RabbitStreamInboundChannelAdapterSpec inboundAdapter(com.rabbitmq.stream.Environment environment)

Create an initial RabbitStreamInboundChannelAdapterSpec with the provided Environment. The streamName or superStream must be provided after creation of this spec; or the listenerContainer options should be specified on the provided StreamListenerContainer using RabbitStreamInboundChannelAdapterSpec.configureContainer(java.util.function.Consumer).

Parameters:

environment - the environment.

Returns:

the RabbitInboundChannelAdapterSLCSpec.

inboundAdapter

public static RabbitStreamInboundChannelAdapterSpec inboundAdapter(com.rabbitmq.stream.Environment environment,
 @Nullable
 com.rabbitmq.stream.Codec codec)

Create an initial RabbitStreamInboundChannelAdapterSpec with the provided Environment. The streamName or superStream must be provided after creation of this spec; or the listenerContainer options should be specified on the provided StreamListenerContainer using RabbitStreamInboundChannelAdapterSpec.configureContainer(java.util.function.Consumer).

Parameters:

environment - the environment.

codec - the codec.

Returns:

the RabbitInboundChannelAdapterSLCSpec.

outboundStreamAdapter

public static RabbitStreamMessageHandlerSpec outboundStreamAdapter(com.rabbitmq.stream.Environment environment,
 String streamName)

Create an initial RabbitStreamMessageHandlerSpec (adapter).

Parameters:

environment - the environment.

streamName - the name of stream to produce.

Returns:

the RabbitStreamMessageHandlerSpec.

Since:

6.1

outboundStreamAdapter

public static RabbitStreamMessageHandlerSpec outboundStreamAdapter(RabbitStreamTemplate template)

Create an initial RabbitStreamMessageHandlerSpec (adapter).

Parameters:

template - the amqpTemplate.

Returns:

the RabbitStreamMessageHandlerSpec.