クラス RabbitStream

メソッドの詳細

• inboundAdapter

  public static RabbitStreamInboundChannelAdapterSpec inboundAdapter(StreamListenerContainer listenerContainer)

  提供された StreamListenerContainer を使用して初期 RabbitStreamInboundChannelAdapterSpec を作成します。streamName または superStream は、この仕様の作成後に提供する必要があります。または、提供された StreamListenerContainer で RabbitStreamInboundChannelAdapterSpec.configureContainer(java.util.function.Consumer) を使用して listenerContainer オプションを指定する必要があります。

  パラメーター:

  listenerContainer - listenerContainer。

  戻り値:

  RabbitInboundChannelAdapterSLCSpec。

• inboundAdapter

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

  提供された Environment を使用して初期 RabbitStreamInboundChannelAdapterSpec を作成します。streamName または superStream は、この仕様の作成後に提供する必要があります。または、提供された StreamListenerContainer で RabbitStreamInboundChannelAdapterSpec.configureContainer(java.util.function.Consumer) を使用して listenerContainer オプションを指定する必要があります。

  パラメーター:

  environment - 環境。

  戻り値:

  RabbitInboundChannelAdapterSLCSpec。

• inboundAdapter

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

  提供された Environment を使用して初期 RabbitStreamInboundChannelAdapterSpec を作成します。streamName または superStream は、この仕様の作成後に提供する必要があります。または、提供された StreamListenerContainer で RabbitStreamInboundChannelAdapterSpec.configureContainer(java.util.function.Consumer) を使用して listenerContainer オプションを指定する必要があります。

  パラメーター:

  environment - 環境。

  codec - コーデック。

  戻り値:

  RabbitInboundChannelAdapterSLCSpec。

• outboundStreamAdapter

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

  初期 RabbitStreamMessageHandlerSpec (アダプター) を作成します。

  パラメーター:

  environment - 環境。

  streamName - 生成するストリームの名前。

  戻り値:

  RabbitStreamMessageHandlerSpec。

  導入:

  6.1

• outboundStreamAdapter

  public static RabbitStreamMessageHandlerSpec outboundStreamAdapter(RabbitStreamTemplate template)

  初期 RabbitStreamMessageHandlerSpec (アダプター) を作成します。

  パラメーター:

  template - amqpTemplate。

  戻り値:

  RabbitStreamMessageHandlerSpec。