クラス RabbitTemplate

メソッドの詳細

• initDefaultStrategies

  protected void initDefaultStrategies()

  デフォルトの戦略を設定します。必要に応じてサブクラスでこのメソッドをオーバーライドできます。

• setConnectionFactory

  public final void setConnectionFactory(ConnectionFactory connectionFactory)

  クラスからコピーされた説明: RabbitAccessor

  RabbitMQ Connections の取得に使用する ConnectionFactory を設定します。

  オーバーライド:

  クラス RabbitAccessor の setConnectionFactory 

  パラメーター:

  connectionFactory - 接続ファクトリ。

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  例外:

  BeansException

• setObservationEnabled

  public void setObservationEnabled(boolean observationEnabled)

  micrometer による観測を有効にします。

  パラメーター:

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

  導入:

  3.0

• setObservationConvention

  public void setObservationConvention(RabbitTemplateObservationConvention observationConvention)

  観測規則を設定します。観測に追加のキー / 値を追加するために使用されます。

  パラメーター:

  observationConvention - 大会。

  導入:

  3.0

• setExchange

  public void setExchange(@Nullable StringSE exchange)

  何も指定されていない場合に送信操作に使用するデフォルトの交換の名前。デフォルトは、ブローカーのデフォルト交換である "" です (AMQP 仕様による)。

  パラメーター:

  exchange - 送信操作に使用する交換名

• getExchange

  public StringSE getExchange()

  戻り値:

  このテンプレートで使用されるデフォルトの取引所の名前。

  導入:

  1.6

• setRoutingKey

  public void setRoutingKey(StringSE routingKey)

  何も指定されていない場合に送信操作に使用するデフォルトのルーティングキーの値。デフォルトは空であり、デフォルト (または任意の直接) 交換を使用する場合には役に立ちませんが、たとえば交換がヘッダー交換である場合は問題ありません。

  パラメーター:

  routingKey - 送信操作に使用するデフォルトのルーティングキー

• getRoutingKey

  public StringSE getRoutingKey()

  戻り値:

  このテンプレートで使用されるデフォルトのルーティングキー。

  導入:

  1.6

• setDefaultReceiveQueue

  public void setDefaultReceiveQueue(StringSE queue)

  明示的に指定されていない場合にメッセージを受信するデフォルトのキューの名前。

  パラメーター:

  queue - receive 操作に使用するデフォルトのキュー名。

  導入:

  2.1.2

• getDefaultReceiveQueue

  public @Nullable StringSE getDefaultReceiveQueue()

  構成されたデフォルトの受信キューを返します。

  戻り値:

  キューまたは構成されていない場合は null。

  導入:

  2.2.22

• setEncoding

  public void setEncoding(StringSE encoding)

  メッセージプロパティでバイト配列と文字列を変換するときに使用するエンコーディング。

  パラメーター:

  encoding - 設定するエンコーディング

• getEncoding

  public StringSE getEncoding()

  メッセージプロパティでバイト配列と文字列を変換するときに使用されるエンコーディング。

  戻り値:

  エンコーディング。

• setReplyAddress

  public void setReplyAddress(StringSE replyAddress)

  返信用のアドレス。指定しない場合、RabbitMQ が 'amq.rabbitmq. 返信先 ' をサポートしない限り、各応答に一時的な排他的な自動削除キューが使用されます。

  アドレスは、単純なキュー名 (この場合、応答はデフォルトの交換を介してルーティングされます) にするか、明示的な交換およびルーティングキーを使用して応答をルーティングする exchange/routingKey の形式にすることができます。

  パラメーター:

  replyAddress - 設定する replyAddress

• setReceiveTimeout

  public void setReceiveTimeout(long receiveTimeout)

  receive() メソッドを使用する場合、receive 操作のタイムアウトをミリ秒単位で指定します（sendAndReceive() メソッドについては、replyTimeout を参照してください）。デフォルトでは値は 0 で、receive() メソッドは利用可能なメッセージがない場合、直ちに null を返します。0 未満の値を設定すると、メッセージを無期限に待機します。

  パラメーター:

  receiveTimeout - タイムアウト。

  導入:

  1.5

• setReplyTimeout

  public void setReplyTimeout(long replyTimeout)

  sendAndReceive メソッドのいずれかを使用するときに、応答メッセージを待機するときに使用するタイムアウトをミリ秒単位で指定します。デフォルト値は DEFAULT_REPLY_TIMEOUT として定義されます。負の値は、無期限のタイムアウトを示します。プロトコルでブロッキング受信操作が定義されていないため、プレーン受信メソッドでは使用されません。

  パラメーター:

  replyTimeout - ミリ秒単位の応答タイムアウト

  関連事項:

  • sendAndReceive(String, String, Message)
  • convertSendAndReceive(String, String, Object)

• setMessageConverter

  public void setMessageConverter(MessageConverter messageConverter)

  このテンプレートのメッセージコンバーターを設定します。オブジェクトパラメーターを convertAndSend メソッドに解決し、オブジェクト結果を receiveAndConvert メソッドから解決するために使用されます。

  デフォルトのコンバーターは SimpleMessageConverter で、メッセージコンテンツ型 ヘッダーに応じて、バイト配列、文字列、シリアライズ可能なオブジェクトを処理できます。

  パラメーター:

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

  関連事項:

  • convertAndSend(java.lang.Object)
  • receiveAndConvert()
  • SimpleMessageConverter

• setMessagePropertiesConverter

  public void setMessagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter)

  このテンプレートの MessagePropertiesConverter を設定します。このコンバーターは、メッセージヘッダー内の生のバイトコンテンツとプレーン Java オブジェクト間の変換に使用されます。特に、非常に長い文字列ヘッダーを扱う際には制限があります。これは実際には稀なケースですが、長いヘッダーを使用する必要がある場合は、ここで特別なコンバーターを挿入する必要があるかもしれません。

  パラメーター:

  messagePropertiesConverter - メッセージプロパティコンバーター。

• getMessagePropertiesConverter

  protected MessagePropertiesConverter getMessagePropertiesConverter()

  プロパティのコンバーターを返します。

  戻り値:

  コンバーター。

  導入:

  2.0

• getMessageConverter

  public MessageConverter getMessageConverter()

  このテンプレートのメッセージコンバーターを返します。ChannelCallback 実装でコンバーターを利用したいクライアントに役立ちます。

  戻り値:

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

• setConfirmCallback

  public void setConfirmCallback(RabbitTemplate.ConfirmCallback confirmCallback)

• setReturnsCallback

  public void setReturnsCallback(RabbitTemplate.ReturnsCallback returnCallback)

  返されたメッセージを受信するようにコールバックを設定します。

  パラメーター:

  returnCallback - コールバック。

• setMandatory

  public void setMandatory(boolean mandatory)

  メッセージの送信時に必須フラグを設定します。returnCallback が提供された場合にのみ適用されます。

  パラメーター:

  mandatory - 設定必須。

• setMandatoryExpression

  public void setMandatoryExpression(Expression mandatoryExpression)

  パラメーター:

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

  導入:

  1.4

• setMandatoryExpressionString

  public void setMandatoryExpressionString(StringSE mandatoryExpression)

  パラメーター:

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

  導入:

  2.0

• setSendConnectionFactorySelectorExpression

  public void setSendConnectionFactorySelectorExpression(Expression sendConnectionFactorySelectorExpression)

  指定された RabbitAccessor.getConnectionFactory() が AbstractRoutingConnectionFactory のインスタンスである場合、各リクエストメッセージに対して評価する SpEL Expression。

  この式の結果は、AbstractRoutingConnectionFactory からターゲット ConnectionFactory を直接取得するための lookupKey として使用されます。

  この式が null に評価された場合、通常の AbstractRoutingConnectionFactory ロジックに戻ります。

  評価された lookupKey を持つターゲット ConnectionFactory がない場合、そのプロパティが lenientFallback == true である場合にのみ、通常の AbstractRoutingConnectionFactory ロジックにフォールバックします。

  この式は、send 操作に使用されます。

  パラメーター:

  sendConnectionFactorySelectorExpression - 評価する SpEL Expression

  導入:

  1.4

• setReceiveConnectionFactorySelectorExpression

  public void setReceiveConnectionFactorySelectorExpression(Expression receiveConnectionFactorySelectorExpression)

  指定された RabbitAccessor.getConnectionFactory() が AbstractRoutingConnectionFactory のインスタンスである場合、各 receive queueName に対して評価する SpEL Expression。

  この式の結果は、AbstractRoutingConnectionFactory からターゲット ConnectionFactory を直接取得するための lookupKey として使用されます。

  この式が null に評価された場合、通常の AbstractRoutingConnectionFactory ロジックに戻ります。

  評価された lookupKey を持つターゲット ConnectionFactory がない場合、そのプロパティが lenientFallback == true である場合にのみ、通常の AbstractRoutingConnectionFactory ロジックにフォールバックします。

  この式は、receive 操作に使用されます。

  パラメーター:

  receiveConnectionFactorySelectorExpression - 評価する SpEL Expression

  導入:

  1.4

• setCorrelationKey

  public void setCorrelationKey(StringSE correlationKey)

  "correlationId" （デフォルト）に設定すると、correlationId プロパティが使用されます。それ以外の場合は、指定されたキーが使用されます。

  パラメーター:

  correlationKey - 設定する correlationKey

• setRetryTemplate

  public void setRetryTemplate(RetryTemplate retryTemplate)

  すべての rabbit 操作に使用される RetryTemplate を追加します。

  パラメーター:

  retryTemplate - 再試行テンプレート。

• setRecoveryCallback

  public void setRecoveryCallback(RabbitTemplate.RecoveryCallback recoveryCallback)

  execution が再試行ポリシーを使い果たした際に使用されるリカバリコールバックを追加します。指定されたコールバックは、execute(ChannelCallback) によって生成される戻り値の型と互換性のある結果を生成する必要があります。

  パラメーター:

  recoveryCallback - リカバリコールバック

  導入:

  4.0

• setBeanFactory

  public void setBeanFactory(BeanFactory beanFactory) throws BeansException

  次で指定:

  インターフェース BeanFactoryAware の setBeanFactory 

  例外:

  BeansException

• getBeforePublishPostProcessors

  public @Nullable CollectionSE<MessagePostProcessor> getBeforePublishPostProcessors()

  ポスト MessagePostProcessor または null の前に構成された値を返します。

  戻り値:

  MessagePostProcessor または null を投稿する前に構成します。

  導入:

  3.2

• setBeforePublishPostProcessors

  public void setBeforePublishPostProcessors(MessagePostProcessor... beforePublishPostProcessors)

  MessageProperties から AMQP.BasicProperties を作成する以外のすべての処理の後、Channel#basicPublish() を呼び出す直前に呼び出される MessagePostProcessor を設定します。圧縮などの操作に使用できます。プロセッサーは、PriorityOrder、Order に応じて順番に呼び出され、最後に順不同で呼び出されます。

  パラメーター:

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

  導入:

  1.4.2

  関連事項:

  • addBeforePublishPostProcessors(MessagePostProcessor...)

• addBeforePublishPostProcessors

  public void addBeforePublishPostProcessors(MessagePostProcessor... beforePublishPostProcessors)

  MessageProperties から AMQP.BasicProperties を作成する以外のすべての処理の後、Channel#basicPublish() を呼び出す直前に呼び出される MessagePostProcessor を追加します。圧縮などの操作に使用できます。プロセッサーは、PriorityOrder、Order に応じて順番に呼び出され、最後に順不同で呼び出されます。

  setBeforePublishPostProcessors(MessagePostProcessor...) とは対照的に、このメソッドは以前に追加された beforePublishPostProcessors をオーバーライドしません。

  パラメーター:

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

  導入:

  2.1.4

• removeBeforePublishPostProcessor

  public boolean removeBeforePublishPostProcessor(MessagePostProcessor beforePublishPostProcessor)

  提供された MessagePostProcessor を beforePublishPostProcessors リストから削除します。

  パラメーター:

  beforePublishPostProcessor - 削除する MessagePostProcessor。

  戻り値:

  提供されたポストプロセッサーが削除されているかどうかを示すブール値。

  導入:

  2.1.4

  関連事項:

  • addBeforePublishPostProcessors(MessagePostProcessor...)

• setAfterReceivePostProcessors

  public void setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)

  Channel#basicGet() の直後、メッセージ変換が実行される前に呼び出される MessagePostProcessor を設定します。減圧などの操作に使用できます。プロセッサーは、PriorityOrder、Order に応じて順番に呼び出され、最後に順不同で呼び出されます。

  パラメーター:

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

  導入:

  1.5

  関連事項:

  • addAfterReceivePostProcessors(MessagePostProcessor...)

• getAfterReceivePostProcessors

  public @Nullable CollectionSE<MessagePostProcessor> getAfterReceivePostProcessors()

  MessagePostProcessor または null を受信した後に構成を返します。

  戻り値:

  MessagePostProcessor または null の受信後に設定されます。

  導入:

  2.1.5

• addAfterReceivePostProcessors

  public void addAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)

  Channel#basicGet() の直後、メッセージ変換が実行される前に呼び出される MessagePostProcessor を追加します。減圧などの操作に使用できます。プロセッサーは、PriorityOrder、Order に応じて順番に呼び出され、最後に順不同で呼び出されます。

  setAfterReceivePostProcessors(MessagePostProcessor...) とは対照的に、このメソッドは以前に追加された afterReceivePostProcessors をオーバーライドしません。

  パラメーター:

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

  導入:

  2.1.4

• removeAfterReceivePostProcessor

  public boolean removeAfterReceivePostProcessor(MessagePostProcessor afterReceivePostProcessor)

  提供された MessagePostProcessor を afterReceivePostProcessors リストから削除します。

  パラメーター:

  afterReceivePostProcessor - 削除する MessagePostProcessor。

  戻り値:

  提供されたポストプロセッサーが削除されているかどうかを示すブール値。

  導入:

  2.1.4

  関連事項:

  • addAfterReceivePostProcessors(MessagePostProcessor...)

• setCorrelationDataPostProcessor

  public void setCorrelationDataPostProcessor(CorrelationDataPostProcessor correlationDataPostProcessor)

  メッセージをパブリッシュする前に、CorrelationDataPostProcessor が呼び出されるように設定します。相関データは、発行者の確認を相関させるために使用されます。

  パラメーター:

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

  導入:

  1.6.7

  関連事項:

  • setConfirmCallback(ConfirmCallback)

• setUseTemporaryReplyQueues

  public void setUseTemporaryReplyQueues(boolean value)

  デフォルトでは、ブローカーがサポートしていて replyAddress が提供されていない場合、送受信メソッドは直接返信先を使用します。このプロパティを true に設定すると、その動作がオーバーライドされ、代わりにリクエストごとに一時的な自動削除キューが使用されます。最初のリクエストが処理されると、このプロパティを変更しても効果はありません。

  パラメーター:

  value - 一時キューを使用する場合は true。

  導入:

  1.6

• setUseDirectReplyToContainer

  public void setUseDirectReplyToContainer(boolean useDirectReplyToContainer)

  直接返信が可能かつ使用中の場合に、DirectReplyToMessageListenerContainer を使用するかどうかを設定します。false の場合、リクエストごとに新しいコンシューマーが作成されます (2.0 より前のバージョンで使用されていたメカニズム)。デフォルトは true。

  パラメーター:

  useDirectReplyToContainer - リクエストごとにコンシューマーを使用するには、false に設定します。

  導入:

  2.0

  関連事項:

  • setUseTemporaryReplyQueues(boolean)

• setUserIdExpression

  public void setUserIdExpression(Expression userIdExpression)

  userId メッセージプロパティを設定するために評価する式を設定します。評価結果が非 NULL 値で、かつ送信するメッセージにそのプロパティがまだ設定されていない場合に評価されます。validated -user-id を参照してください。

  パラメーター:

  userIdExpression - 表現。

  導入:

  1.6

• setUserIdExpressionString

  public void setUserIdExpressionString(StringSE userIdExpression)

  userId メッセージプロパティを設定するために評価する式を設定します。評価結果が非 NULL 値で、かつ送信するメッセージにそのプロパティがまだ設定されていない場合に評価されます。validated -user-id を参照してください。

  パラメーター:

  userIdExpression - 表現。

  導入:

  1.6

• setBeanName

  public void setBeanName(StringSE name)

  次で指定:

  インターフェース BeanNameAware の setBeanName 

• setTaskExecutor

  public void setTaskExecutor(ExecutorSE taskExecutor)

  DirectReplyToMessageListenerContainer を使用するときに使用するタスクエグゼキュータを設定します。

  パラメーター:

  taskExecutor - 執行者。

  導入:

  2.0

• setUserCorrelationId

  public void setUserCorrelationId(boolean userCorrelationId)

  true に設定すると、リクエスト / リプライシナリオで相関 ID を生成する代わりに、メッセージによって提供される相関 ID が使用されます。相関 ID は、クロストークを避けるため、すべてのインプロセスリクエストで一意である必要があります。

  そのため、ユーザーは一意性を確保するために細心の注意を払う必要があります。

  パラメーター:

  userCorrelationId - ユーザー相関データを使用する場合は true。

• isUsePublisherConnection

  public boolean isUsePublisherConnection()

  個別のパブリッシャー接続が使用されている場合は true。

  戻り値:

  正しいか間違っているか。

  導入:

  2.0.2

  関連事項:

  • setUsePublisherConnection(boolean)

• setUsePublisherConnection

  public void setUsePublisherConnection(boolean usePublisherConnection)

  接続のデッドロックを回避するために、通常、パブリッシャーとコンシューマーに別々の接続を使用することをお勧めします (パブリッシャーがコンシューマートランザクションに参加している場合を除く)。デフォルトは "false" です。これを true に設定するときは、このテンプレートを使用する RabbitAdmin がパブリッシャー接続でキューを宣言することに注意してください。これは、特にこのアプリケーションで消費される可能性のある排他的なキューでは、期待どおりではない可能性があります。

  パラメーター:

  usePublisherConnection - パブリッシャー接続を使用する場合は true。

  導入:

  2.0.2

• setNoLocalReplyConsumer

  public void setNoLocalReplyConsumer(boolean noLocalReplyConsumer)

  非ローカルコンシューマーの場合は true に設定します。デフォルトは false です。

  パラメーター:

  noLocalReplyConsumer - ローカルでないコンシューマーの場合は true。

  導入:

  2.1

  関連事項:

  • AbstractMessageListenerContainer.setNoLocal(boolean)
  • Channel.basicConsume(String, boolean, String, boolean, boolean, Map, com.rabbitmq.client.Consumer)

• setReplyErrorHandler

  public void setReplyErrorHandler(ErrorHandler replyErrorHandler)

  リクエスト / リプライ操作に直接リプライ先コンテナーを使用する場合は、リプライ配信が失敗した場合 (リプライの遅延など) にエラーハンドラーが呼び出されるように設定します。

  パラメーター:

  replyErrorHandler - 応答エラーハンドラー

  導入:

  2.0.11

  関連事項:

  • setUseDirectReplyToContainer(boolean)

• setUseChannelForCorrelation

  public void setUseChannelForCorrelation(boolean useChannelForCorrelation)

  直接返信先を使用する場合は、これを true に設定して、サーバーが返信ヘッダーで相関 ID を送信する必要がないようにします。代わりに、チャネルを使用して応答をリクエストに関連付けます。

  パラメーター:

  useChannelForCorrelation - チャネルを使用する場合は true。

  導入:

  2.3.7

• expectedQueueNames

  public @Nullable CollectionSE<StringSE> expectedQueueNames()

  起動時にコンテナーによって呼び出され、キューが正しく構成されていることを確認できます (exchange/routingKey の代わりに単純な応答キュー名が使用されている場合)。

  次で指定:

  インターフェース ListenerContainerAware の expectedQueueNames 

  戻り値:

  キュー名 (構成されている場合)。

  導入:

  1.5

• getUnconfirmed

  public @Nullable CollectionSE<CorrelationData> getUnconfirmed(long age)

  age よりも古い未確認の相関データを取得して削除します。

  パラメーター:

  age - ミリ秒単位

  戻り値:

  確認が受信されていない相関データのコレクション、またはそのような確認が存在しない場合は null。

• getUnconfirmedCount

  public int getUnconfirmedCount()

  未確認メッセージ数を取得します。

  戻り値:

  RabbitMQ によってまだ確認されていないメッセージの数。

  導入:

  2.0

• addConsumerArg

  public void addConsumerArg(StringSE arg, ObjectSE value)

  ゼロ以外のタイムアウトで受信メソッドを使用すると、メッセージを受信するために Consumer が作成されます。このプロパティを使用して、コンシューマーに引数を追加します (例: x-priority)。

  パラメーター:

  arg - basicConsume 操作に渡す引数名。

  value - basicConsume 操作に渡す引数値。

  導入:

  2.4.8

  関連事項:

  • removeConsumerArg(String)

• removeConsumerArg

  public ObjectSE removeConsumerArg(StringSE arg)

  ゼロ以外のタイムアウトで受信メソッドを使用すると、メッセージを受信するために Consumer が作成されます。このメソッドを使用して、basicConsume 操作に渡される引数から引数を削除します。

  パラメーター:

  arg - 引数名。

  戻り値:

  前の値。

  導入:

  2.4.8

  関連事項:

  • addConsumerArg(String, Object)

• start

  public void start()

  次で指定:

  インターフェース Lifecycle の start 

  次で指定:

  インターフェース RabbitOperations の start 

• doStart

  protected void doStart()

  追加の開始アクションを実行します。

  導入:

  2.0

• stop

  public void stop()

  次で指定:

  インターフェース Lifecycle の stop 

  次で指定:

  インターフェース RabbitOperations の stop 

• doStop

  protected void doStop()

  追加の停止アクションを実行します。

  導入:

  2.0

• isRunning

  public boolean isRunning()

  次で指定:

  インターフェース Lifecycle の isRunning 

  次で指定:

  インターフェース RabbitOperations の isRunning 

• destroy

  public void destroy()

  次で指定:

  インターフェース DisposableBean の destroy 

• useDirectReplyTo

  protected boolean useDirectReplyTo()

  ( direct Reply-to ) を使用するかどうかを決定するために他の条件を使用して、このメソッドをオーバーライドします。デフォルトの実装は、ブローカーがサポートしており、replyAddress が設定されておらず、useTemporaryReplyQueues が false の場合に true を返します。直接返信先が使用されない場合、テンプレートは返信用の一時的で排他的な自動削除キューを作成します。

  このメソッドは、最初のメッセージがロックされたブロックから送信されるときに 1 回だけ呼び出されます。

  戻り値:

  直接返信を使用する場合は true。

• send

  public void send(Message message) throws AmqpException

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

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

  次で指定:

  インターフェース AmqpTemplate の send 

  パラメーター:

  message - 送信するメッセージ

  例外:

  AmqpException - 問題がある場合

• send

  public void send(@Nullable StringSE routingKey, Message message) throws AmqpException

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

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

  次で指定:

  インターフェース AmqpTemplate の send 

  パラメーター:

  routingKey - ルーティングキー

  message - 送信するメッセージ

  例外:

  AmqpException - 問題がある場合

• send

  public void send(@Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) throws AmqpException

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

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

  次で指定:

  インターフェース RabbitOperations の send 

  パラメーター:

  routingKey - ルーティングキー

  message - 送信するメッセージ

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  例外:

  AmqpException - 問題がある場合

• send

  public void send(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message) throws AmqpException

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

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

  次で指定:

  インターフェース AmqpTemplate の send 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  message - 送信するメッセージ

  例外:

  AmqpException - 問題がある場合

• send

  public void send(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) throws AmqpException

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

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

  次で指定:

  インターフェース RabbitOperations の send 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  message - 送信するメッセージ

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  public void convertAndSend(ObjectSE object) throws AmqpException

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

  Java オブジェクトを Amqp Message に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。

  次で指定:

  インターフェース AmqpTemplate の convertAndSend 

  パラメーター:

  object - 送信するメッセージ

  例外:

  AmqpException - 問題がある場合

• correlationConvertAndSend

  public void correlationConvertAndSend(ObjectSE object, CorrelationData correlationData) throws AmqpException

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

  Java オブジェクトを Amqp Message に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。

  次で指定:

  インターフェース RabbitOperations の correlationConvertAndSend 

  パラメーター:

  object - 送信するメッセージ

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  public void convertAndSend(@Nullable StringSE routingKey, ObjectSE object) throws AmqpException

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

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

  次で指定:

  インターフェース AmqpTemplate の convertAndSend 

  パラメーター:

  routingKey - ルーティングキー

  object - 送信するメッセージ

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  public void convertAndSend(@Nullable StringSE routingKey, ObjectSE object, @Nullable CorrelationData correlationData) throws AmqpException

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

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

  次で指定:

  インターフェース RabbitOperations の convertAndSend 

  パラメーター:

  routingKey - ルーティングキー

  object - 送信するメッセージ

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  public void convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE object) throws AmqpException

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

  Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用して特定の取引所に送信します。

  次で指定:

  インターフェース AmqpTemplate の convertAndSend 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  object - 送信するメッセージ

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  public void convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE object, @Nullable CorrelationData correlationData) throws AmqpException

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

  Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用して特定の取引所に送信します。

  次で指定:

  インターフェース RabbitOperations の convertAndSend 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  object - 送信するメッセージ

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  public void convertAndSend(ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException

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

  Java オブジェクトを Amqp Message に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。

  次で指定:

  インターフェース AmqpTemplate の convertAndSend 

  パラメーター:

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  public void convertAndSend(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException

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

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

  次で指定:

  インターフェース AmqpTemplate の convertAndSend 

  パラメーター:

  routingKey - ルーティングキー

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  public void convertAndSend(ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) throws AmqpException

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

  Java オブジェクトを Amqp Message に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。

  次で指定:

  インターフェース RabbitOperations の convertAndSend 

  パラメーター:

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  public void convertAndSend(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) throws AmqpException

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

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

  次で指定:

  インターフェース RabbitOperations の convertAndSend 

  パラメーター:

  routingKey - ルーティングキー

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  public void convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException

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

  Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用して特定の取引所に送信します。

  次で指定:

  インターフェース AmqpTemplate の convertAndSend 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  public void convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) throws AmqpException

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

  Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用して特定の取引所に送信します。

  次で指定:

  インターフェース RabbitOperations の convertAndSend 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  例外:

  AmqpException - 問題がある場合

• receive

  public @Nullable Message receive() throws AmqpException

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

  デフォルトキューからのメッセージがある場合は、メッセージを受信します。おそらく null 値で、すぐに戻ります。

  次で指定:

  インターフェース AmqpTemplate の receive 

  戻り値:

  待っているメッセージがない場合はメッセージまたは null

  例外:

  AmqpException - 問題がある場合

• receive

  public @Nullable Message receive(StringSE queueName)

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

  特定のキューからのメッセージがある場合、メッセージを受信します。おそらく null 値で、すぐに戻ります。

  次で指定:

  インターフェース AmqpTemplate の receive 

  パラメーター:

  queueName - ポーリングするキューの名前

  戻り値:

  待っているメッセージがない場合はメッセージまたは null

• doReceiveNoWait

  protected @Nullable Message doReceiveNoWait(StringSE queueName)

  ノンブロッキング受信。

  パラメーター:

  queueName - 受信するキュー。

  戻り値:

  メッセージ、またはすぐに利用できるメッセージがない場合は null。

  導入:

  1.5

• receive

  public @Nullable Message receive(long timeoutMillis) throws AmqpException

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

  デフォルトのキューからメッセージを受信し、メッセージが利用可能になるまで必要に応じて指定された待機時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の receive 

  パラメーター:

  timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。

  戻り値:

  期限が切れた場合はメッセージまたは null

  例外:

  AmqpException - 問題がある場合

• receive

  public @Nullable Message receive(StringSE queueName, long timeoutMillis)

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

  特定のキューからメッセージを受信し、メッセージが使用可能になるまで必要に応じて指定された待機時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の receive 

  パラメーター:

  queueName - 受信するキュー

  timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。

  戻り値:

  期限が切れた場合はメッセージまたは null

• receiveAndConvert

  public @Nullable ObjectSE receiveAndConvert() throws AmqpException

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

  デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。

  次で指定:

  インターフェース AmqpTemplate の receiveAndConvert 

  戻り値:

  待っているメッセージがない場合はメッセージまたは null

  例外:

  AmqpException - 問題がある場合

• receiveAndConvert

  public @Nullable ObjectSE receiveAndConvert(StringSE queueName) throws AmqpException

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

  特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。

  次で指定:

  インターフェース AmqpTemplate の receiveAndConvert 

  パラメーター:

  queueName - ポーリングするキューの名前

  戻り値:

  待っているメッセージがない場合はメッセージまたは null

  例外:

  AmqpException - 問題がある場合

• receiveAndConvert

  public @Nullable ObjectSE receiveAndConvert(long timeoutMillis) throws AmqpException

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

  デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の receiveAndConvert 

  パラメーター:

  timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。

  戻り値:

  期限が切れた場合はメッセージまたは null

  例外:

  AmqpException - 問題がある場合

• receiveAndConvert

  public @Nullable ObjectSE receiveAndConvert(StringSE queueName, long timeoutMillis) throws AmqpException

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

  特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の receiveAndConvert 

  パラメーター:

  queueName - ポーリングするキューの名前

  timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。

  戻り値:

  期限が切れた場合はメッセージまたは null

  例外:

  AmqpException - 問題がある場合

• receiveAndConvert

  public <T> @Nullable T receiveAndConvert(ParameterizedTypeReference<T> type) throws AmqpException

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

  デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。SmartMessageConverter が必要です。

  次で指定:

  インターフェース AmqpTemplate の receiveAndConvert 

  型パラメーター:

  T - 型。

  パラメーター:

  type - 変換する型。

  戻り値:

  メッセージ、または待機していない場合は null。

  例外:

  AmqpException - 問題がある場合。

• receiveAndConvert

  public <T> @Nullable T receiveAndConvert(StringSE queueName, ParameterizedTypeReference<T> type) throws AmqpException

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

  特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。SmartMessageConverter が必要です。

  次で指定:

  インターフェース AmqpTemplate の receiveAndConvert 

  型パラメーター:

  T - 型。

  パラメーター:

  queueName - ポーリングするキューの名前

  type - 変換する型。

  戻り値:

  待っているメッセージがない場合はメッセージまたは null

  例外:

  AmqpException - 問題がある場合

• receiveAndConvert

  public <T> @Nullable T receiveAndConvert(long timeoutMillis, ParameterizedTypeReference<T> type) throws AmqpException

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

  デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース AmqpTemplate の receiveAndConvert 

  型パラメーター:

  T - 型。

  パラメーター:

  timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。

  type - 変換する型。

  戻り値:

  期限が切れた場合はメッセージまたは null

  例外:

  AmqpException - 問題がある場合

• receiveAndConvert

  public <T> @Nullable T receiveAndConvert(StringSE queueName, long timeoutMillis, ParameterizedTypeReference<T> type) throws AmqpException

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

  特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース AmqpTemplate の receiveAndConvert 

  型パラメーター:

  T - 型。

  パラメーター:

  queueName - ポーリングするキューの名前

  timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。

  type - 変換する型。

  戻り値:

  期限が切れた場合はメッセージまたは null

  例外:

  AmqpException - 問題がある場合

• receiveAndReply

  public <R, S> boolean receiveAndReply(ReceiveAndReplyCallback<R,S> callback) throws AmqpException

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

  デフォルトキューからメッセージがある場合はそれを受信し、提供された ReceiveAndReplyCallback を呼び出して、callback が応答メッセージを返した場合は、MessageProperties から replyTo Address に、またはデフォルト交換とデフォルト routingKey に応答メッセージを送信します。

  次で指定:

  インターフェース AmqpTemplate の receiveAndReply 

  型パラメーター:

  R - Message からの変換後のリクエストの型。

  S - レスポンスの型。

  パラメーター:

  callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。

  戻り値:

  true、メッセージが受信された場合

  例外:

  AmqpException - 問題がある場合

• receiveAndReply

  public <R, S> boolean receiveAndReply(StringSE queueName, ReceiveAndReplyCallback<R,S> callback) throws AmqpException

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

  指定されたキューからメッセージがある場合はそれを受信し、指定された ReceiveAndReplyCallback を呼び出して、callback が応答メッセージを返した場合は、MessageProperties から replyTo Address に、またはデフォルトの交換とデフォルトの routingKey に応答メッセージを送信します。

  次で指定:

  インターフェース AmqpTemplate の receiveAndReply 

  型パラメーター:

  R - Message からの変換後のリクエストの型。

  S - レスポンスの型。

  パラメーター:

  queueName - メッセージを受信するキュー名。

  callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。

  戻り値:

  true、メッセージが受信された場合。

  例外:

  AmqpException - 問題がある場合。

• receiveAndReply

  public <R, S> boolean receiveAndReply(ReceiveAndReplyCallback<R,S> callback, StringSE exchange, StringSE routingKey) throws AmqpException

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

  デフォルトキューからメッセージがある場合はメッセージを受信し、提供された ReceiveAndReplyCallback を呼び出し、callback がメッセージを返す場合は、提供された exchange および routingKey に応答メッセージを送信します。

  次で指定:

  インターフェース AmqpTemplate の receiveAndReply 

  型パラメーター:

  R - Message からの変換後のリクエストの型。

  S - レスポンスの型。

  パラメーター:

  callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。

  exchange - 返信メッセージを送信する交換名。

  routingKey - 応答メッセージを送信するためのルーティングキー。

  戻り値:

  true、メッセージが受信された場合。

  例外:

  AmqpException - 問題がある場合。

• receiveAndReply

  public <R, S> boolean receiveAndReply(StringSE queueName, ReceiveAndReplyCallback<R,S> callback, StringSE replyExchange, StringSE replyRoutingKey) throws AmqpException

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

  提供されたキューからメッセージがある場合はメッセージを受信し、提供された ReceiveAndReplyCallback を呼び出し、callback がメッセージを返す場合は、提供された exchange および routingKey に応答メッセージを送信します。

  次で指定:

  インターフェース AmqpTemplate の receiveAndReply 

  型パラメーター:

  R - Message からの変換後のリクエストの型。

  S - レスポンスの型。

  パラメーター:

  queueName - メッセージを受信するキュー名。

  callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。

  replyExchange - 返信メッセージを送信する交換名。

  replyRoutingKey - 応答メッセージを送信するためのルーティングキー。

  戻り値:

  true、メッセージが受信された場合

  例外:

  AmqpException - 問題がある場合

• receiveAndReply

  public <R, S> boolean receiveAndReply(ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback) throws AmqpException

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

  デフォルトのキューからメッセージがあれば受信し、提供された ReceiveAndReplyCallback を呼び出し、callback がメッセージを返す場合は、応答メッセージを ReplyToAddressCallback の結果から replyTo Address に送信します。

  次で指定:

  インターフェース AmqpTemplate の receiveAndReply 

  型パラメーター:

  R - Message からの変換後のリクエストの型。

  S - レスポンスの型。

  パラメーター:

  callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。

  replyToAddressCallback - 実行時に replyTo アドレスを決定するコールバック。

  戻り値:

  true、メッセージが受信された場合。

  例外:

  AmqpException - 問題がある場合。

• receiveAndReply

  public <R, S> boolean receiveAndReply(StringSE queueName, ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback) throws AmqpException

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

  指定されたキューからメッセージがあれば受信し、指定された ReceiveAndReplyCallback を呼び出し、callback がメッセージを返す場合は、応答メッセージを ReplyToAddressCallback の結果から replyTo Address に送信します。

  次で指定:

  インターフェース AmqpTemplate の receiveAndReply 

  型パラメーター:

  R - Message からの変換後のリクエストの型。

  S - レスポンスの型。

  パラメーター:

  queueName - メッセージを受信するキュー名。

  callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。

  replyToAddressCallback - 実行時に replyTo アドレスを決定するコールバック。

  戻り値:

  true、メッセージが受信された場合

  例外:

  AmqpException - 問題がある場合

• logReceived

  protected void logReceived(StringSE prefix, @Nullable Message message)

  受信したメッセージをログに記録します。デフォルトの実装では、完全なメッセージが DEBUG レベルでログに記録されます。このメソッドをオーバーライドして、その動作を変更します。

  パラメーター:

  prefix - 接頭辞。「受信:」または「返信:」。

  message - メッセージ。

  導入:

  2.4.6

• sendAndReceive

  public @Nullable Message sendAndReceive(Message message) throws AmqpException

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

  基本的な RPC パターン。デフォルトのルーティングキーを使用してデフォルトの交換にメッセージを送信し、レスポンスの受信を試みます。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の sendAndReceive 

  パラメーター:

  message - 送信するメッセージ。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• sendAndReceive

  public @Nullable Message sendAndReceive(Message message, @Nullable CorrelationData correlationData) throws AmqpException

  例外:

  AmqpException

• sendAndReceive

  public @Nullable Message sendAndReceive(@Nullable StringSE routingKey, Message message) throws AmqpException

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

  基本的な RPC パターン。特定のルーティングキーを使用してデフォルトの交換にメッセージを送信し、レスポンスの受信を試みます。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の sendAndReceive 

  パラメーター:

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• sendAndReceive

  public @Nullable Message sendAndReceive(@Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) throws AmqpException

  例外:

  AmqpException

• sendAndReceive

  public @Nullable Message sendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message) throws AmqpException

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

  基本的な RPC パターン。特定のルーティングキーを使用して特定の交換機にメッセージを送信し、レスポンスの受信を試みます。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の sendAndReceive 

  パラメーター:

  exchange - 取引所の名前。

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• sendAndReceive

  public @Nullable Message sendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) throws AmqpException

  例外:

  AmqpException

• convertSendAndReceive

  public @Nullable ObjectSE convertSendAndReceive(ObjectSE message) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の convertSendAndReceive 

  パラメーター:

  message - 送信するメッセージ。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceive

  public @Nullable ObjectSE convertSendAndReceive(ObjectSE message, @Nullable CorrelationData correlationData) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース RabbitOperations の convertSendAndReceive 

  パラメーター:

  message - 送信するメッセージ。

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  戻り値:

  ある場合のレスポンス

  例外:

  AmqpException - 問題がある場合

• convertSendAndReceive

  public @Nullable ObjectSE convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の convertSendAndReceive 

  パラメーター:

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceive

  public @Nullable ObjectSE convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース RabbitOperations の convertSendAndReceive 

  パラメーター:

  routingKey - ルーティングキー

  message - 送信するメッセージ

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  戻り値:

  ある場合のレスポンス

  例外:

  AmqpException - 問題がある場合

• convertSendAndReceive

  public @Nullable ObjectSE convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の convertSendAndReceive 

  パラメーター:

  exchange - 取引所の名前。

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceive

  public @Nullable ObjectSE convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース RabbitOperations の convertSendAndReceive 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  message - 送信するメッセージ

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  戻り値:

  ある場合のレスポンス

  例外:

  AmqpException - 問題がある場合

• convertSendAndReceive

  public @Nullable ObjectSE convertSendAndReceive(ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の convertSendAndReceive 

  パラメーター:

  message - 送信するメッセージ。

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceive

  public @Nullable ObjectSE convertSendAndReceive(ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース RabbitOperations の convertSendAndReceive 

  パラメーター:

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  戻り値:

  ある場合のレスポンス

  例外:

  AmqpException - 問題がある場合

• convertSendAndReceive

  public @Nullable ObjectSE convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の convertSendAndReceive 

  パラメーター:

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceive

  public @Nullable ObjectSE convertSendAndReceive(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース RabbitOperations の convertSendAndReceive 

  パラメーター:

  routingKey - ルーティングキー

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  戻り値:

  ある場合のレスポンス

  例外:

  AmqpException - 問題がある場合

• convertSendAndReceive

  public @Nullable ObjectSE convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース AmqpTemplate の convertSendAndReceive 

  パラメーター:

  exchange - 取引所の名前。

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceive

  public @Nullable ObjectSE convertSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  次で指定:

  インターフェース RabbitOperations の convertSendAndReceive 

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  戻り値:

  ある場合のレスポンス

  例外:

  AmqpException - 問題がある場合

• convertSendAndReceiveAsType

  public <T> @Nullable T convertSendAndReceiveAsType(ObjectSE message, ParameterizedTypeReference<T> responseType) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース AmqpTemplate の convertSendAndReceiveAsType 

  型パラメーター:

  T - 型。

  パラメーター:

  message - 送信するメッセージ。

  responseType - 返信を変換する型。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceiveAsType

  public <T> @Nullable T convertSendAndReceiveAsType(ObjectSE message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース RabbitOperations の convertSendAndReceiveAsType 

  型パラメーター:

  T - 型。

  パラメーター:

  message - 送信するメッセージ。

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  responseType - 返信を変換する型。

  戻り値:

  ある場合のレスポンス。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceiveAsType

  public <T> @Nullable T convertSendAndReceiveAsType(@Nullable StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース AmqpTemplate の convertSendAndReceiveAsType 

  型パラメーター:

  T - 型。

  パラメーター:

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  responseType - 返信を変換する型。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceiveAsType

  public <T> @Nullable T convertSendAndReceiveAsType(@Nullable StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース RabbitOperations の convertSendAndReceiveAsType 

  型パラメーター:

  T - 型。

  パラメーター:

  routingKey - ルーティングキー

  message - 送信するメッセージ

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  responseType - 返信を変換する型。

  戻り値:

  ある場合のレスポンス

  例外:

  AmqpException - 問題がある場合

• convertSendAndReceiveAsType

  public <T> @Nullable T convertSendAndReceiveAsType(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース AmqpTemplate の convertSendAndReceiveAsType 

  型パラメーター:

  T - 型。

  パラメーター:

  exchange - 取引所の名前。

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  responseType - 返信を変換する型。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceiveAsType

  public <T> @Nullable T convertSendAndReceiveAsType(ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース AmqpTemplate の convertSendAndReceiveAsType 

  型パラメーター:

  T - 型。

  パラメーター:

  message - 送信するメッセージ。

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー。

  responseType - 返信を変換する型。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceiveAsType

  public <T> @Nullable T convertSendAndReceiveAsType(ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース RabbitOperations の convertSendAndReceiveAsType 

  型パラメーター:

  T - 型。

  パラメーター:

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  responseType - 返信を変換する型。

  戻り値:

  ある場合のレスポンス

  例外:

  AmqpException - 問題がある場合

• convertSendAndReceiveAsType

  public <T> @Nullable T convertSendAndReceiveAsType(@Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース AmqpTemplate の convertSendAndReceiveAsType 

  型パラメーター:

  T - 型。

  パラメーター:

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー。

  responseType - 返信を変換する型。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceiveAsType

  public <T> @Nullable T convertSendAndReceiveAsType(@Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース RabbitOperations の convertSendAndReceiveAsType 

  型パラメーター:

  T - 型。

  パラメーター:

  routingKey - ルーティングキー

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  responseType - 返信を変換する型。

  戻り値:

  ある場合のレスポンス

  例外:

  AmqpException - 問題がある場合

• convertSendAndReceiveAsType

  public <T> @Nullable T convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース AmqpTemplate の convertSendAndReceiveAsType 

  型パラメーター:

  T - 型。

  パラメーター:

  exchange - 取引所の名前。

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー。

  responseType - 返信を変換する型。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceiveAsType

  public <T> @Nullable T convertSendAndReceiveAsType(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException

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

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  次で指定:

  インターフェース RabbitOperations の convertSendAndReceiveAsType 

  型パラメーター:

  T - 型。

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  correlationData - パブリッシャーの確認を関連付けるためのデータ。

  responseType - 返信を変換する型。

  戻り値:

  ある場合のレスポンス

  例外:

  AmqpException - 問題がある場合

• convertSendAndReceiveRaw

  protected @Nullable Message convertSendAndReceiveRaw(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)

  メッセージを変換して送信し、生の返信メッセージまたは null を返します。サブクラスは、送信メッセージで変換を実行したいが、変換前に応答メッセージに直接アクセスできる場合、このメソッドを呼び出すことができます。

  パラメーター:

  exchange - 交換。

  routingKey - ルーティングキー。

  message - 送信するデータ。

  messagePostProcessor - メッセージポストプロセッサー (null の場合もあります)。

  correlationData - 相関データ (null の場合もあります)。

  戻り値:

  応答メッセージ、またはタイムアウトが発生した場合は null。

  導入:

  1.6.6

• convertMessageIfNecessary

  protected Message convertMessageIfNecessary(ObjectSE object)

• doSendAndReceive

  protected @Nullable Message doSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData)

  メッセージを送信し、返信を待ちます。

  パラメーター:

  exchange - 取引所名

  routingKey - ルーティングキー

  message - 送信するメッセージ

  correlationData - confirms の相関データ

  戻り値:

  返信で受け取ったメッセージ

• doSendAndReceiveWithTemporary

  protected @Nullable Message doSendAndReceiveWithTemporary(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData)

• doSendAndReceiveWithFixed

  protected @Nullable Message doSendAndReceiveWithFixed(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData)

• replyTimedOut

  protected void replyTimedOut(@Nullable StringSE correlationId)

  サブクラスでこのメソッドを実装することで、応答がタイムアウトしたことを通知できます。デフォルトの実装では、保留中の応答のカウンタも解放されます。サブクラスでこのメソッドをオーバーライドし、この動作を維持したい場合は、super.replyTimedOut(correlationId) を呼び出す必要があります。

  パラメーター:

  correlationId - correlationId

  導入:

  2.1.2

• isMandatoryFor

  public BooleanSE isMandatoryFor(Message message)

  指定されたメッセージを必須フラグを設定して送信する必要があるかどうかを返します。

  パラメーター:

  message - メッセージ。

  戻り値:

  必須の場合は true。

  導入:

  2.0

• execute

  public <T extends @Nullable ObjectSE> T execute(ChannelCallback<T> action)

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

  チャネルを使用してコールバックを実行し、その後チャネルを確実に閉じます。

  次で指定:

  インターフェース RabbitOperations の execute 

  型パラメーター:

  T - 戻り値の型。

  パラメーター:

  action - コールバック。

  戻り値:

  ChannelCallback.doInRabbit(com.rabbitmq.client.Channel) からの結果。

• invoke

  public <T extends @Nullable ObjectSE> T invoke(RabbitOperations.OperationsCallback<T> action, @Nullable com.rabbitmq.client.ConfirmCallback acks, @Nullable com.rabbitmq.client.ConfirmCallback nacks)

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

  同じチャネルで操作を呼び出します。コールバックが必要な場合は、両方のコールバックを指定する必要があります。

  次で指定:

  インターフェース RabbitOperations の invoke 

  型パラメーター:

  T - 戻り値の型。

  パラメーター:

  action - コールバック。

  acks - ack の確認コールバック。

  nacks - nacks 用の confirm コールバック。

  戻り値:

  アクションメソッドの結果。

• waitForConfirms

  public boolean waitForConfirms(long timeout)

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

  confirms を待機するために、基盤となる専用チャネルに委譲します。接続ファクトリはパブリッシャー confirms 用に設定され、このメソッドは RabbitOperations.invoke(OperationsCallback) 操作のスコープ内で呼び出される必要があります。CachingConnectionFactory#setPublisherConfirms(true) が必要です。

  次で指定:

  インターフェース RabbitOperations の waitForConfirms 

  パラメーター:

  timeout - タイムアウト

  戻り値:

  ack を受信し、nacks を受信しない場合は true。

  関連事項:

  • Channel.waitForConfirms(long)

• waitForConfirmsOrDie

  public void waitForConfirmsOrDie(long timeout)

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

  基礎となる専用チャネルに委譲して、確認を待ちます。パブリッシャーの確認用に接続ファクトリを構成する必要があり、このメソッドは RabbitOperations.invoke(OperationsCallback) 操作の範囲内で呼び出す必要があります。CachingConnectionFactory#setPublisherConfirms(true) が必要です。

  次で指定:

  インターフェース RabbitOperations の waitForConfirmsOrDie 

  パラメーター:

  timeout - タイムアウト

  関連事項:

  • Channel.waitForConfirmsOrDie(long)

• doSend

  public void doSend(com.rabbitmq.client.Channel channel, @Nullable StringSE exchangeArg, @Nullable StringSE routingKeyArg, Message message, boolean mandatory, @Nullable CorrelationData correlationData)

  指定されたメッセージを指定された交換に送信します。

  パラメーター:

  channel - 内部で動作する RabbitMQ チャネル。

  exchangeArg - 送信先の RabbitMQ 交換の名前。

  routingKeyArg - ルーティングキー。

  message - 送信するメッセージ。

  mandatory - 必須フラグ。

  correlationData - 相関データ。

• observeTheSend

  protected void observeTheSend(com.rabbitmq.client.Channel channel, Message message, boolean mandatory, StringSE exch, StringSE rKey)

• nullSafeExchange

  public StringSE nullSafeExchange(@Nullable StringSE exchange)

  null の場合、取引所またはデフォルトの取引所を返します。

  パラメーター:

  exchange - 交換。

  戻り値:

  結果。

  導入:

  2.3.4

• nullSafeRoutingKey

  public StringSE nullSafeRoutingKey(@Nullable StringSE rk)

  null の場合は、ルーティングキーまたはデフォルトのルーティングキーを返します。

  パラメーター:

  rk - ルーティングキー。

  戻り値:

  結果。

  導入:

  2.3.4

• sendToRabbit

  protected void sendToRabbit(com.rabbitmq.client.Channel channel, StringSE exchange, StringSE routingKey, boolean mandatory, Message message)

• isChannelLocallyTransacted

  protected boolean isChannelLocallyTransacted(com.rabbitmq.client.Channel channel)

  指定されたチャネルがローカルで処理されているかどうか、つまり、そのトランザクションが外部トランザクションコーディネーターではなく、このテンプレートのチャネル処理によって管理されているかどうかを確認します。

  パラメーター:

  channel - チェックするチャンネル

  戻り値:

  指定されたチャネルがローカルで処理されるかどうか

  関連事項:

  • ConnectionFactoryUtils.isChannelTransactional(com.rabbitmq.client.Channel, org.springframework.amqp.rabbit.connection.ConnectionFactory)
  • RabbitAccessor.isChannelTransacted()

• addListener

  public void addListener(com.rabbitmq.client.Channel channel)

  このテンプレートを、提供されたチャネルの確認リスナーとして追加します。

  パラメーター:

  channel - チャンネル。

  導入:

  2.0

• handleConfirm

  public void handleConfirm(PendingConfirm pendingConfirm, boolean ack)

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

  確認を受信したときにチャネルによって呼び出されます。

  次で指定:

  インターフェース PublisherCallbackChannel.Listener の handleConfirm 

  パラメーター:

  pendingConfirm - 相関データを含む保留中の確認。

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

• handleReturn

  public void handleReturn(com.rabbitmq.client.Return returned)

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

  返されたメッセージを処理します。

  次で指定:

  インターフェース PublisherCallbackChannel.Listener の handleReturn 

  パラメーター:

  returned - メッセージとメタデータ。

• isConfirmListener

  public boolean isConfirmListener()

  次で指定:

  インターフェース PublisherCallbackChannel.Listener の isConfirmListener 

• isReturnListener

  public boolean isReturnListener()

  次で指定:

  インターフェース PublisherCallbackChannel.Listener の isReturnListener 

• revoke

  public void revoke(com.rabbitmq.client.Channel channel)

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

  呼び出されると、このリスナーはチャネルへのすべての参照を削除する必要があります。チャネルによって呼び出されることはありません。

  次で指定:

  インターフェース PublisherCallbackChannel.Listener の revoke 

  パラメーター:

  channel - チャンネル。

• getUUID

  public StringSE getUUID()

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

  この Listener を識別するために使用される UUID を返します。

  次で指定:

  インターフェース PublisherCallbackChannel.Listener の getUUID 

  戻り値:

  UUID の文字列表現。

• getPendingReplyCounter

  public ActiveObjectCounter<ObjectSE> getPendingReplyCounter()

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

  保留中の返信がある場合は、そのカウンターを返します。

  次で指定:

  インターフェース ListenerContainerAware の getPendingReplyCounter 

  戻り値:

  カウンター、または null。

• onMessage

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

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

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

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

  次で指定:

  インターフェース ChannelAwareMessageListener の onMessage 

  パラメーター:

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

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