クラス RabbitStreamTemplate

メソッドの詳細

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  例外:

  BeansException

• setBeanName

  public void setBeanName(StringSE name)

  次で指定:

  インターフェース BeanNameAware の setBeanName 

• setSuperStreamRouting

  public void setSuperStreamRouting(FunctionSE<com.rabbitmq.stream.Message,StringSE> superStreamRouting)

  ルーティング機能を追加して、ストリームをスーパーストリームにします。

  パラメーター:

  superStreamRouting - ルーティング機能。

  導入:

  3.0

• 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 - カスタマイザー ;

• setObservationEnabled

  public void setObservationEnabled(boolean observationEnabled)

  Micrometer 観測を有効にするには true に設定します。

  パラメーター:

  observationEnabled - 有効にする場合は true。

  導入:

  3.0.5

• setObservationConvention

  public void setObservationConvention(RabbitStreamTemplateObservationConvention observationConvention)

  カスタム RabbitStreamTemplateObservationConvention を設定します。

  パラメーター:

  observationConvention - 大会。

  導入:

  3.2.6

• getStreamName

  public StringSE getStreamName()

  戻り値:

  ストリーム名

  導入:

  3.2.6

• messageConverter

  public MessageConverter messageConverter()

  インターフェースからコピーされた説明: RabbitStreamOperations

  メッセージコンバーターを返します。

  次で指定:

  インターフェース RabbitStreamOperations の messageConverter 

  戻り値:

  コンバーター。

• streamMessageConverter

  public StreamMessageConverter streamMessageConverter()

  インターフェースからコピーされた説明: RabbitStreamOperations

  ストリームメッセージコンバーターを返します。

  次で指定:

  インターフェース RabbitStreamOperations の streamMessageConverter 

  戻り値:

  コンバーター ;

• send

  public CompletableFutureSE<BooleanSE> send(Message message)

  インターフェースからコピーされた説明: RabbitStreamOperations

  Spring AMQP メッセージを送信します。

  次で指定:

  インターフェース RabbitStreamOperations の send 

  パラメーター:

  message - メッセージ。

  戻り値:

  成功 / 失敗を示す未来。

• convertAndSend

  public CompletableFutureSE<BooleanSE> convertAndSend(ObjectSE message)

  インターフェースからコピーされた説明: RabbitStreamOperations

  Spring AMQP メッセージに変換して送信します。

  次で指定:

  インターフェース RabbitStreamOperations の convertAndSend 

  パラメーター:

  message - ペイロード。

  戻り値:

  成功 / 失敗を示す未来。

• convertAndSend

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

  インターフェースからコピーされた説明: RabbitStreamOperations

  Spring AMQP メッセージに変換して送信します。MessagePostProcessor が提供され、null が返された場合、メッセージは送信されず、未来は false で完了します。

  次で指定:

  インターフェース RabbitStreamOperations の convertAndSend 

  パラメーター:

  message - ペイロード。

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

  戻り値:

  成功 / 失敗を示す未来。

• send

  public CompletableFutureSE<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