クラス RabbitStreamTemplate
java.lang.ObjectSE
org.springframework.rabbit.stream.producer.RabbitStreamTemplate
- 実装されたすべてのインターフェース:
AutoCloseableSE
、Aware
、BeanNameAware
、ApplicationContextAware
、RabbitStreamOperations
public class RabbitStreamTemplate
extends ObjectSE
implements RabbitStreamOperations, ApplicationContextAware, BeanNameAware
RabbitStreamOperations
のデフォルト実装。- 導入:
- 2.4
- 作成者:
- Gary Russell, Christian Tzolov
フィールドサマリー
コンストラクターのサマリー
コンストラクター説明RabbitStreamTemplate
(com.rabbitmq.stream.Environment environment, StringSE streamName) 提供されたEnvironment
を使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明void
close()
convertAndSend
(ObjectSE message) Spring AMQP メッセージに変換して送信します。convertAndSend
(ObjectSE message, MessagePostProcessor mpp) Spring AMQP メッセージに変換して送信します。com.rabbitmq.stream.MessageBuilder
プロデューサーのMessageBuilder
を返して、ネイティブストリームメッセージを作成します。メッセージコンバーターを返します。send
(com.rabbitmq.stream.Message message) ネイティブストリームメッセージを送信します。Spring AMQP メッセージを送信します。void
setApplicationContext
(ApplicationContext applicationContext) void
setBeanName
(StringSE name) void
setMessageConverter
(MessageConverter messageConverter) convertAndSend(Object)
操作用のコンバーターを設定します。void
setObservationEnabled
(boolean observationEnabled) Micrometer 観察を有効にするには true に設定します。void
setProducerCustomizer
(ProducerCustomizer producerCustomizer) Producer
を構築する前にProducerBuilder
をカスタマイズするために使用されます。void
setStreamConverter
(StreamMessageConverter streamConverter) void
setSuperStreamRouting
(FunctionSE<com.rabbitmq.stream.Message, StringSE> superStreamRouting) ルーティング機能を追加して、ストリームをスーパーストリームにします。ストリームメッセージコンバーターを返します。
フィールドの詳細
logger
コンストラクターの詳細
RabbitStreamTemplate
提供されたEnvironment
を使用してインスタンスを構築します。- パラメーター:
environment
- 環境。streamName
- ストリーム名。
メソッドの詳細
setApplicationContext
- 次で指定:
- インターフェース
ApplicationContextAware
のsetApplicationContext
- 例外:
BeansException
setBeanName
- 次で指定:
- インターフェース
BeanNameAware
のsetBeanName
setSuperStreamRouting
public void setSuperStreamRouting(FunctionSE<com.rabbitmq.stream.Message, StringSE> superStreamRouting) ルーティング機能を追加して、ストリームをスーパーストリームにします。- パラメーター:
superStreamRouting
- ルーティング機能。- 導入:
- 3.0
setMessageConverter
convertAndSend(Object)
操作用のコンバーターを設定します。- パラメーター:
messageConverter
- コンバーター。
setStreamConverter
- パラメーター:
streamConverter
- コンバーター。
setProducerCustomizer
Producer
を構築する前にProducerBuilder
をカスタマイズするために使用されます。- パラメーター:
producerCustomizer
- カスタマイザー ;
setObservationEnabled
public void setObservationEnabled(boolean observationEnabled) Micrometer 観察を有効にするには true に設定します。- パラメーター:
observationEnabled
- 有効にする場合は true。- 導入:
- 3.0.5
messageConverter
インターフェースからコピーされた説明:RabbitStreamOperations
メッセージコンバーターを返します。- 次で指定:
- インターフェース
RabbitStreamOperations
のmessageConverter
- 戻り値:
- コンバーター。
streamMessageConverter
インターフェースからコピーされた説明:RabbitStreamOperations
ストリームメッセージコンバーターを返します。- 次で指定:
- インターフェース
RabbitStreamOperations
のstreamMessageConverter
- 戻り値:
- コンバーター ;
send
インターフェースからコピーされた説明:RabbitStreamOperations
Spring AMQP メッセージを送信します。- 次で指定:
- インターフェース
RabbitStreamOperations
のsend
- パラメーター:
message
- メッセージ。- 戻り値:
- 成功 / 失敗を示す未来。
convertAndSend
インターフェースからコピーされた説明:RabbitStreamOperations
Spring AMQP メッセージに変換して送信します。- 次で指定:
- インターフェース
RabbitStreamOperations
のconvertAndSend
- パラメーター:
message
- ペイロード。- 戻り値:
- 成功 / 失敗を示す未来。
convertAndSend
public CompletableFutureSE<BooleanSE> convertAndSend(ObjectSE message, @Nullable MessagePostProcessor mpp) インターフェースからコピーされた説明:RabbitStreamOperations
- 次で指定:
- インターフェース
RabbitStreamOperations
のconvertAndSend
- パラメーター:
message
- ペイロード。mpp
- メッセージポストプロセッサー。- 戻り値:
- 成功 / 失敗を示す未来。
send
インターフェースからコピーされた説明:RabbitStreamOperations
ネイティブストリームメッセージを送信します。- 次で指定:
- インターフェース
RabbitStreamOperations
のsend
- パラメーター:
message
- メッセージ。- 戻り値:
- 成功 / 失敗を示す未来。
- 関連事項:
messageBuilder
public com.rabbitmq.stream.MessageBuilder messageBuilder()インターフェースからコピーされた説明:RabbitStreamOperations
プロデューサーのMessageBuilder
を返して、ネイティブストリームメッセージを作成します。- 次で指定:
- インターフェース
RabbitStreamOperations
のmessageBuilder
- 戻り値:
- ビルダー。
- 関連事項:
close
public void close()基になるプロデューサーを閉じます。新しいプロデューサーは、それを必要とする次の操作で作成されます。
- 次で指定:
- インターフェース
AutoCloseableSE
のclose
- 次で指定:
- インターフェース
RabbitStreamOperations
のclose