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

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(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. Note: only endpoint options are available from spec. 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. Note: only endpoint options are available from spec. 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,
 com.rabbitmq.stream.Codec codec)

Create an initial RabbitStreamInboundChannelAdapterSpec with the provided Environment. Note: only endpoint options are available from spec. 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(RabbitStreamTemplate template)

Create an initial RabbitStreamMessageHandlerSpec (adapter).

Parameters:

template - the amqpTemplate.

Returns:

the RabbitStreamMessageHandlerSpec.