クラス RabbitStreamInboundChannelAdapterSpec

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<RabbitStreamInboundChannelAdapterSpec, AmqpInboundChannelAdapter>
org.springframework.integration.dsl.MessageProducerSpec<RabbitStreamInboundChannelAdapterSpec, AmqpInboundChannelAdapter>
org.springframework.integration.amqp.dsl.AmqpBaseInboundChannelAdapterSpec<RabbitStreamInboundChannelAdapterSpec>
org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterSpec<RabbitStreamInboundChannelAdapterSpec, StreamListenerContainer>
org.springframework.integration.amqp.dsl.RabbitStreamInboundChannelAdapterSpec
実装済みのインターフェース一覧:
DisposableBean, FactoryBean<AmqpInboundChannelAdapter>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration
public class RabbitStreamInboundChannelAdapterSpec extends AmqpInboundChannelAdapterSpec<RabbitStreamInboundChannelAdapterSpec, StreamListenerContainer>
StreamListenerContainer を備えた受信チャネルアダプターの仕様。
導入:
6.0
作成者:
Gary Russell, Artem Bilan

  • コンストラクターの詳細

    • RabbitStreamInboundChannelAdapterSpec

      protected RabbitStreamInboundChannelAdapterSpec(StreamListenerContainer listenerContainer)

    • RabbitStreamInboundChannelAdapterSpec

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

  • 方法の詳細

    • streamName

      public RabbitStreamInboundChannelAdapterSpec streamName(StringSE streamName)
      消費する Rabbit ストリームの名前を構成します。
      パラメーター:
      streamName - Rabbit ストリームの名前。
      戻り値:
      スペック
      導入:
      6.1

    • superStream

      public RabbitStreamInboundChannelAdapterSpec superStream(StringSE superStream, StringSE consumerName)
      消費する Rabbit スーパーストリームの名前を構成します。
      パラメーター:
      superStream - その名も Rabbit スーパーストリーム。
      consumerName - オフセット追跡を有効にするための論理名。
      戻り値:
      スペック
      導入:
      6.1

    • superStream

      public RabbitStreamInboundChannelAdapterSpec superStream(StringSE superStream, StringSE consumerName, int consumers)
      消費する Rabbit スーパーストリームの名前を構成します。
      パラメーター:
      superStream - その名も Rabbit スーパーストリーム。
      consumerName - オフセット追跡を有効にするための論理名。
      consumers - コンシューマーの数。
      戻り値:
      スペック
      導入:
      6.1

    • configureContainer

      public RabbitStreamInboundChannelAdapterSpec configureContainer(ConsumerSE<RabbitStreamMessageListenerContainerSpec> configurer)