クラス AsyncRabbitTemplate

メソッドの詳細

• setAutoStartup

  public void setAutoStartup(boolean autoStartup)

  パラメーター:

  autoStartup - 自動開始の場合は true。

  関連事項:

  • isAutoStartup()

• setPhase

  public void setPhase(int phase)

  パラメーター:

  phase - フェーズ。

  関連事項:

  • getPhase()

• setMandatory

  public void setMandatory(boolean mandatory)

  AmqpMessageReturnedException の形式で配信できない返されたメッセージの受信を有効にするには、true に設定します。

  パラメーター:

  mandatory - return を有効にする場合は true。

• setMandatoryExpression

  public void setMandatoryExpression(Expression mandatoryExpression)

  パラメーター:

  mandatoryExpression - 各リクエストメッセージに対して評価する SpEL Expression。評価の結果は、boolean 値でなければなりません。

  導入:

  2.0

• setMandatoryExpressionString

  public void setMandatoryExpressionString(StringSE mandatoryExpression)

  パラメーター:

  mandatoryExpression - 各リクエストメッセージに対して評価する SpEL Expression。評価の結果は、boolean 値でなければなりません。

  導入:

  2.0

• setEnableConfirms

  public void setEnableConfirms(boolean enableConfirms)

  パブリッシャーの確認を有効にするには、true に設定します。有効にすると、送受信操作によって返される RabbitFuture の confirm プロパティに CompletableFuture<Boolean> が含まれます。

  パラメーター:

  enableConfirms - パブリッシャーの確認を有効にする場合は true。

• getBeanName

  public StringSE getBeanName()

• setBeanName

  public void setBeanName(StringSE beanName)

  次で指定:

  インターフェース BeanNameAware の setBeanName 

• getConnectionFactory

  public ConnectionFactory getConnectionFactory()

  戻り値:

  RabbitTemplate 内の基礎となる接続ファクトリへの参照。

• setReceiveTimeout

  public void setReceiveTimeout(long receiveTimeout)

  受信タイムアウトを設定します。このタイムアウトが期限切れになると、send および receive メソッドによって返される未来はキャンセルされます。<= 0 は、先物が期限切れにならないことを意味します。応答が受信されない場合、これによりメモリリークが発生することに注意してください。デフォルト: 30000 (30 秒)。

  パラメーター:

  receiveTimeout - ミリ秒単位のタイムアウト。

• setTaskScheduler

  public void setTaskScheduler(TaskScheduler taskScheduler)

  タスクスケジューラを設定して、タイムアウトした先物を期限切れにします。

  パラメーター:

  taskScheduler - タスクスケジューラ

  関連事項:

  • setReceiveTimeout(long)

• getMessageConverter

  public MessageConverter getMessageConverter()

  戻り値:

  基礎となる RabbitTemplate の MessageConverter への参照。

• getRabbitTemplate

  public RabbitTemplate getRabbitTemplate()

  送信に使用される基礎となる RabbitTemplate を返します。

  戻り値:

  テンプレート。

  導入:

  2.2

• sendAndReceive

  public RabbitMessageFuture sendAndReceive(Message message)

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

  デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。メッセージに correlationId プロパティが含まれている場合は、一意である必要があります。

  次で指定:

  インターフェース AsyncAmqpTemplate の sendAndReceive 

  パラメーター:

  message - メッセージ。

  戻り値:

  CompletableFutureSE

• sendAndReceive

  public RabbitMessageFuture sendAndReceive(StringSE routingKey, Message message)

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

  指定されたルーティングキーを使用して、デフォルトの交換にメッセージを送信します。メッセージに correlationId プロパティが含まれている場合は、一意である必要があります。

  次で指定:

  インターフェース AsyncAmqpTemplate の sendAndReceive 

  パラメーター:

  routingKey - ルーティングキー。

  message - メッセージ。

  戻り値:

  CompletableFutureSE

• sendAndReceive

  public RabbitMessageFuture sendAndReceive(StringSE exchange, StringSE routingKey, Message message)

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

  指定された交換およびルーティングキーにメッセージを送信します。メッセージに correlationId プロパティが含まれている場合は、一意である必要があります。

  次で指定:

  インターフェース AsyncAmqpTemplate の sendAndReceive 

  パラメーター:

  exchange - 交換。

  routingKey - ルーティングキー。

  message - メッセージ。

  戻り値:

  CompletableFutureSE

• convertSendAndReceive

  public <C> RabbitConverterFuture<C> convertSendAndReceive(ObjectSE object)

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

  オブジェクトをメッセージに変換し、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。

  次で指定:

  インターフェース AsyncAmqpTemplate の convertSendAndReceive 

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  object - 変換するオブジェクト。

  戻り値:

  CompletableFutureSE

• convertSendAndReceive

  public <C> RabbitConverterFuture<C> convertSendAndReceive(StringSE routingKey, ObjectSE object)

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

  オブジェクトをメッセージに変換し、指定されたルーティングキーを使用してデフォルトの交換に送信します。

  次で指定:

  インターフェース AsyncAmqpTemplate の convertSendAndReceive 

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  戻り値:

  CompletableFutureSE

• convertSendAndReceive

  public <C> RabbitConverterFuture<C> convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE object)

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

  オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。

  次で指定:

  インターフェース AsyncAmqpTemplate の convertSendAndReceive 

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  exchange - 交換。

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  戻り値:

  CompletableFutureSE

• convertSendAndReceive

  public <C> RabbitConverterFuture<C> convertSendAndReceive(ObjectSE object, MessagePostProcessor messagePostProcessor)

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

  オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。

  次で指定:

  インターフェース AsyncAmqpTemplate の convertSendAndReceive 

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  object - 変換するオブジェクト。

  messagePostProcessor - ポストプロセッサー。

  戻り値:

  CompletableFutureSE

• convertSendAndReceive

  public <C> RabbitConverterFuture<C> convertSendAndReceive(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor)

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

  オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、指定されたルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。

  次で指定:

  インターフェース AsyncAmqpTemplate の convertSendAndReceive 

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  messagePostProcessor - ポストプロセッサー。

  戻り値:

  CompletableFutureSE

• convertSendAndReceive

  public <C> RabbitConverterFuture<C> convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor)

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

  MessagePostProcessor を呼び出した後、オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。

  次で指定:

  インターフェース AsyncAmqpTemplate の convertSendAndReceive 

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  exchange - 交換

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  messagePostProcessor - ポストプロセッサー。

  戻り値:

  CompletableFutureSE

• convertSendAndReceiveAsType

  public <C> RabbitConverterFuture<C> convertSendAndReceiveAsType(ObjectSE object, ParameterizedTypeReference<C> responseType)

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

  オブジェクトをメッセージに変換し、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。

  次で指定:

  インターフェース AsyncAmqpTemplate の convertSendAndReceiveAsType 

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  object - 変換するオブジェクト。

  responseType - レスポンス型。

  戻り値:

  CompletableFutureSE

• convertSendAndReceiveAsType

  public <C> RabbitConverterFuture<C> convertSendAndReceiveAsType(StringSE routingKey, ObjectSE object, ParameterizedTypeReference<C> responseType)

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

  オブジェクトをメッセージに変換し、指定されたルーティングキーを使用してデフォルトの交換に送信します。

  次で指定:

  インターフェース AsyncAmqpTemplate の convertSendAndReceiveAsType 

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  responseType - レスポンス型。

  戻り値:

  CompletableFutureSE

• convertSendAndReceiveAsType

  public <C> RabbitConverterFuture<C> convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE object, ParameterizedTypeReference<C> responseType)

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

  オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。

  次で指定:

  インターフェース AsyncAmqpTemplate の convertSendAndReceiveAsType 

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  exchange - 交換。

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  responseType - レスポンス型。

  戻り値:

  CompletableFutureSE

• convertSendAndReceiveAsType

  public <C> RabbitConverterFuture<C> convertSendAndReceiveAsType(ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)

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

  オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。

  次で指定:

  インターフェース AsyncAmqpTemplate の convertSendAndReceiveAsType 

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  object - 変換するオブジェクト。

  messagePostProcessor - ポストプロセッサー。

  responseType - レスポンス型。

  戻り値:

  CompletableFutureSE

• convertSendAndReceiveAsType

  public <C> RabbitConverterFuture<C> convertSendAndReceiveAsType(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)

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

  オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、指定されたルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。

  次で指定:

  インターフェース AsyncAmqpTemplate の convertSendAndReceiveAsType 

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  messagePostProcessor - ポストプロセッサー。

  responseType - レスポンス型。

  戻り値:

  CompletableFutureSE

• convertSendAndReceiveAsType

  public <C> RabbitConverterFuture<C> convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)

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

  MessagePostProcessor を呼び出した後、オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。

  次で指定:

  インターフェース AsyncAmqpTemplate の convertSendAndReceiveAsType 

  型パラメーター:

  C - 期待される結果型。

  パラメーター:

  exchange - 交換

  routingKey - ルーティングキー。

  object - 変換するオブジェクト。

  messagePostProcessor - ポストプロセッサー。

  responseType - レスポンス型。

  戻り値:

  CompletableFutureSE

• start

  public void start()

  次で指定:

  インターフェース Lifecycle の start 

• stop

  public void stop()

  次で指定:

  インターフェース Lifecycle の stop 

• isRunning

  public boolean isRunning()

  次で指定:

  インターフェース Lifecycle の isRunning 

• getPhase

  public int getPhase()

  次で指定:

  インターフェース Phased の getPhase 

  次で指定:

  インターフェース SmartLifecycle の getPhase 

• isAutoStartup

  public boolean isAutoStartup()

  次で指定:

  インターフェース SmartLifecycle の isAutoStartup 

• onMessage

  public void onMessage(Message message, com.rabbitmq.client.Channel channel)

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

  受信した Rabbit メッセージを処理するためのコールバック。

  実装者は、指定されたメッセージを処理し、通常、指定されたセッションを介して応答メッセージを送信します。

  次で指定:

  インターフェース ChannelAwareMessageListener の onMessage 

  パラメーター:

  message - 受信した AMQP メッセージ (非 null)

  channel - 基盤となる Rabbit チャネル (ストリームリスナーコンテナーによって呼び出されない限り、null ではありません)。

• returnedMessage

  public void returnedMessage(ReturnedMessage returned)

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

  返されたメッセージコールバック。

  次で指定:

  インターフェース RabbitTemplate.ReturnsCallback の returnedMessage 

  パラメーター:

  returned - 返されたメッセージとメタデータ。

• confirm

  public void confirm(@NonNull CorrelationData correlationData, boolean ack, @Nullable StringSE cause)

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

  確認のコールバック。

  次で指定:

  インターフェース RabbitTemplate.ConfirmCallback の confirm 

  パラメーター:

  correlationData - コールバックの相関データ。

  ack - ack の場合は true、nack の場合は false

  cause - オプションの原因。nack の場合は利用可能な場合、それ以外の場合は null。

• toString

  public StringSE toString()

  オーバーライド:

  クラス ObjectSE の toString