クラス RabbitMessagingTemplate

メソッドの詳細

• setRabbitTemplate

  public void setRabbitTemplate(RabbitTemplate rabbitTemplate)

  使用する RabbitTemplate を設定します。

  パラメーター:

  rabbitTemplate - テンプレート。

• getRabbitTemplate

  public RabbitTemplate getRabbitTemplate()

  戻り値:

  構成された RabbitTemplate

• setAmqpMessageConverter

  public void setAmqpMessageConverter(MessageConverter amqpMessageConverter)

  Message をメッセージングから Message へ、または Message から変換するために使用する MessageConverter を設定します。デフォルトでは、MessagingMessageConverter は、提供されている RabbitTemplate のメッセージコンバーター (デフォルトでは SimpleMessageConverter) を使用して定義され、メッセージのペイロードを変換します。

  より高度なシナリオでは、MessagingMessageConverter を異なる payload converter で構成することを検討してください。

  パラメーター:

  amqpMessageConverter - メッセージコンバーター。

  関連事項:

  • MessagingMessageConverter

• getAmqpMessageConverter

  public MessageConverter getAmqpMessageConverter()

  戻り値:

  Message をメッセージングから Message に変換するために使用する MessageConverter。

• setUseTemplateDefaultReceiveQueue

  public void setUseTemplateDefaultReceiveQueue(boolean useTemplateDefaultReceiveQueue)

  true の場合、このテンプレートで構成された defaultDestination の代わりに、基になる RabbitTemplate の defaultReceiveQueue プロパティ (構成されている場合) を受信専用メソッドに使用します。代わりにテンプレートのキューを使用するには、これを true に設定します。デフォルトは false ですが、将来のリリースでは true になる予定です。

  パラメーター:

  useTemplateDefaultReceiveQueue - テンプレートのキューを使用する場合は true。

  導入:

  2.2.22

• afterPropertiesSet

  public void afterPropertiesSet()

  次で指定:

  インターフェース InitializingBean の afterPropertiesSet 

• send

  public void send(StringSE exchange, StringSE routingKey, Message<?> message) throws MessagingException

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

  特定のルーティングキーを使用して、特定の交換にメッセージを送信します。

  次で指定:

  インターフェース RabbitMessageOperations の send 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  message - 送信するメッセージ

  例外:

  MessagingException - メッセージングの例外。

• convertAndSend

  public void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload) throws MessagingException

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

  おそらく MessageConverter を使用して、指定されたオブジェクトを直列化された形式に変換し、メッセージとしてラップして、特定のルーティングキーを使用して特定の交換に送信します。

  次で指定:

  インターフェース RabbitMessageOperations の convertAndSend 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  payload - ペイロードとして使用するオブジェクト

  例外:

  MessagingException - メッセージングの例外。

• convertAndSend

  public void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, @Nullable MapSE<StringSE,ObjectSE> headers) throws MessagingException

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

  おそらく MessageConverter を使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用してメッセージとしてラップし、特定のルーティングキーを使用して特定の交換に送信します。

  次で指定:

  インターフェース RabbitMessageOperations の convertAndSend 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  payload - ペイロードとして使用するオブジェクト

  headers - 送信するメッセージのヘッダー

  例外:

  MessagingException - メッセージングの例外。

• convertAndSend

  public void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, @Nullable MessagePostProcessor postProcessor) throws MessagingException

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

  おそらく MessageConverter を使用して、指定されたオブジェクトを直列化された形式に変換し、それをメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。

  次で指定:

  インターフェース RabbitMessageOperations の convertAndSend 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  payload - ペイロードとして使用するオブジェクト

  postProcessor - メッセージに適用するポストプロセッサー

  例外:

  MessagingException - メッセージングの例外。

• convertAndSend

  public void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, @Nullable MapSE<StringSE,ObjectSE> headers, @Nullable MessagePostProcessor postProcessor) throws MessagingException

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

  おそらく MessageConverter を使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。

  次で指定:

  インターフェース RabbitMessageOperations の convertAndSend 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  payload - ペイロードとして使用するオブジェクト

  headers - 送信するメッセージのヘッダー

  postProcessor - メッセージに適用するポストプロセッサー

  例外:

  MessagingException - メッセージングの例外。

• sendAndReceive

  @Nullable public Message<?> sendAndReceive(StringSE exchange, StringSE routingKey, Message<?> requestMessage) throws MessagingException

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

  特定のルーティングキーを使用して特定の交換機にリクエストメッセージを送信し、応答を待ちます。

  次で指定:

  インターフェース RabbitMessageOperations の sendAndReceive 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  requestMessage - 送信するメッセージ

  戻り値:

  応答。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 

  例外:

  MessagingException - メッセージングの例外。

• convertSendAndReceive

  @Nullable public <T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, ClassSE<T> targetClass) throws MessagingException

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

  おそらく MessageConverter を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、特定のルーティングキーを使用して特定の交換に Message として送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。

  次で指定:

  インターフェース RabbitMessageOperations の convertSendAndReceive 

  型パラメーター:

  T - 戻りの型

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  request - 送信するリクエストメッセージのペイロード

  targetClass - 応答のペイロードを変換するターゲット型

  戻り値:

  応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 

  例外:

  MessagingException - メッセージングの例外。

• convertSendAndReceive

  @Nullable public <T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, @Nullable MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass) throws MessagingException

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

  おそらく MessageConverter を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用して Message として送信し、特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。

  次で指定:

  インターフェース RabbitMessageOperations の convertSendAndReceive 

  型パラメーター:

  T - 戻りの型

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  request - 送信するリクエストメッセージのペイロード

  headers - 送信するリクエストメッセージのヘッダー

  targetClass - 応答のペイロードを変換するターゲット型

  戻り値:

  応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 

  例外:

  MessagingException - メッセージングの例外。

• convertSendAndReceive

  @Nullable public <T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, ClassSE<T> targetClass, @Nullable MessagePostProcessor requestPostProcessor) throws MessagingException

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

  おそらく MessageConverter を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたポストプロセッサーを適用し、結果の Message を特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。

  次で指定:

  インターフェース RabbitMessageOperations の convertSendAndReceive 

  型パラメーター:

  T - 戻りの型

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  request - 送信するリクエストメッセージのペイロード

  targetClass - 応答のペイロードを変換するターゲット型

  requestPostProcessor - リクエストメッセージに適用するポストプロセス

  戻り値:

  応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 

  例外:

  MessagingException - メッセージングの例外。

• convertSendAndReceive

  @Nullable public <T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, @Nullable MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass, @Nullable MessagePostProcessor requestPostProcessor) throws MessagingException

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

  おそらく MessageConverter を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果の Message を特定のルーティングキーを使用して特定の交換に送信し、応答を受信して変換します。指定されたターゲットクラスの本体。

  次で指定:

  インターフェース RabbitMessageOperations の convertSendAndReceive 

  型パラメーター:

  T - 戻りの型

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  request - 送信するリクエストメッセージのペイロード

  headers - 送信するメッセージのヘッダー

  targetClass - 応答のペイロードを変換するターゲット型

  requestPostProcessor - リクエストメッセージに適用するポストプロセス

  戻り値:

  応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は null 

  例外:

  MessagingException - メッセージングの例外。

• doSend

  protected void doSend(StringSE destination, Message<?> message)

  次で指定:

  クラス AbstractMessageSendingTemplate<StringSE> の doSend 

• doSend

  protected void doSend(StringSE exchange, StringSE routingKey, Message<?> message)

• receive

  @Nullable public Message<?> receive()

  次で指定:

  インターフェース MessageReceivingOperations<StringSE> の receive 

  オーバーライド:

  クラス AbstractMessageReceivingTemplate<StringSE> の receive 

• receiveAndConvert

  @Nullable public <T> T receiveAndConvert(ClassSE<T> targetClass)

  次で指定:

  インターフェース MessageReceivingOperations<StringSE> の receiveAndConvert 

  オーバーライド:

  クラス AbstractMessageReceivingTemplate<StringSE> の receiveAndConvert 

• doReceive

  protected Message<?> doReceive(StringSE destination)

  次で指定:

  クラス AbstractMessageReceivingTemplate<StringSE> の doReceive 

• doSendAndReceive

  @Nullable protected Message<?> doSendAndReceive(StringSE destination, Message<?> requestMessage)

  次で指定:

  クラス AbstractMessagingTemplate<StringSE> の doSendAndReceive 

• doSendAndReceive

  @Nullable protected Message<?> doSendAndReceive(StringSE exchange, StringSE routingKey, Message<?> requestMessage)

• convertAmqpMessage

  @Nullable protected Message<?> convertAmqpMessage(@Nullable Message message)

• convertAmqpException

  protected MessagingException convertAmqpException(RuntimeExceptionSE ex)