フィールドの詳細

• logger

  protected final LogAccessor logger

コンストラクターの詳細

• RabbitStreamTemplate

  public RabbitStreamTemplate​(com.rabbitmq.stream.Environment environment,
                              StringSE streamName)

  提供された Environment を使用してインスタンスを構築します。

  パラメーター:

  environment - 環境。

  streamName - ストリーム名。

メソッドの詳細

• setBeanName

  public void setBeanName​(StringSE name)

  次で指定:

  インターフェース BeanNameAware の setBeanName 

• setMessageConverter

  public void setMessageConverter​(MessageConverter messageConverter)

  convertAndSend(Object) 操作用のコンバーターを設定します。

  パラメーター:

  messageConverter - コンバーター。

• setStreamConverter

  public void setStreamConverter​(StreamMessageConverter streamConverter)

  send(Message) および convertAndSend(Object) メソッドの Message から Message に変換するコンバーターを設定します。

  パラメーター:

  streamConverter - コンバーター。

• setProducerCustomizer

  public void setProducerCustomizer​(ProducerCustomizer producerCustomizer)

  Producer を構築する前に ProducerBuilder をカスタマイズするために使用されます。

  パラメーター:

  producerCustomizer - カスタマイザー ;

• messageConverter

  public MessageConverter messageConverter()

  インターフェースからコピーされた説明: RabbitStreamOperations
  メッセージコンバーターを返します。

  次で指定:

  インターフェース RabbitStreamOperations の messageConverter 

  戻り値:

  コンバーター。

• streamMessageConverter

  public StreamMessageConverter streamMessageConverter()

  インターフェースからコピーされた説明: RabbitStreamOperations
  ストリームメッセージコンバーターを返します。

  次で指定:

  インターフェース RabbitStreamOperations の streamMessageConverter 

  戻り値:

  コンバーター ;

• send

  public ListenableFuture<BooleanSE> send​(Message message)

  インターフェースからコピーされた説明: RabbitStreamOperations
  Spring AMQP メッセージを送信します。

  次で指定:

  インターフェース RabbitStreamOperations の send 

  パラメーター:

  message - メッセージ。

  戻り値:

  成功 / 失敗を示す未来。

• convertAndSend

  public ListenableFuture<BooleanSE> convertAndSend​(ObjectSE message)

  インターフェースからコピーされた説明: RabbitStreamOperations
  Spring AMQP メッセージに変換して送信します。

  次で指定:

  インターフェース RabbitStreamOperations の convertAndSend 

  パラメーター:

  message - ペイロード。

  戻り値:

  成功 / 失敗を示す未来。

• convertAndSend

  public ListenableFuture<BooleanSE> convertAndSend​(ObjectSE message,
                                                  @Nullable
                                                  MessagePostProcessor mpp)

  インターフェースからコピーされた説明: RabbitStreamOperations
  Spring AMQP メッセージに変換して送信します。MessagePostProcessor が提供され、null が返された場合、メッセージは送信されず、未来は false で完了します。

  次で指定:

  インターフェース RabbitStreamOperations の convertAndSend 

  パラメーター:

  message - ペイロード。

  mpp - メッセージポストプロセッサー。

  戻り値:

  成功 / 失敗を示す未来。

• send

  public ListenableFuture<BooleanSE> send​(com.rabbitmq.stream.Message message)

  インターフェースからコピーされた説明: RabbitStreamOperations
  ネイティブストリームメッセージを送信します。

  次で指定:

  インターフェース RabbitStreamOperations の send 

  パラメーター:

  message - メッセージ。

  戻り値:

  成功 / 失敗を示す未来。

  関連事項:

  RabbitStreamOperations.messageBuilder()

• messageBuilder

  public com.rabbitmq.stream.MessageBuilder messageBuilder()

  インターフェースからコピーされた説明: RabbitStreamOperations
  プロデューサーの MessageBuilder を返して、ネイティブストリームメッセージを作成します。

  次で指定:

  インターフェース RabbitStreamOperations の messageBuilder 

  戻り値:

  ビルダー。

  関連事項:

  RabbitStreamOperations.send(com.rabbitmq.stream.Message)

• close

  public void close()

  基になるプロデューサーを閉じます。新しいプロデューサーは、それを必要とする次の操作で作成されます。

  次で指定:

  インターフェース AutoCloseableSE の close 

  次で指定:

  インターフェース RabbitStreamOperations の close