クラス 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)