パッケージ org.springframework.amqp.rabbit

クラス AsyncRabbitTemplate

    • フィールドの詳細

    • コンストラクターの詳細

      • AsyncRabbitTemplate

        public AsyncRabbitTemplate​(ConnectionFactory connectionFactory,
                           StringSE exchange,
                           StringSE routingKey,
                           StringSE replyQueue)
        提供された引数を使用してインスタンスを構築します。返信は、返信キュー名をルーティングキーとして使用して、デフォルトの交換にルーティングされます。
        パラメーター:
        connectionFactory - 接続ファクトリ。
        exchange - リクエストが送信されるデフォルトの交換。
        routingKey - デフォルトのルーティングキー。
        replyQueue - 応答をリッスンする応答キューの名前。

      • AsyncRabbitTemplate

        public AsyncRabbitTemplate​(ConnectionFactory connectionFactory,
                           StringSE exchange,
                           StringSE routingKey,
                           StringSE replyQueue,
                           StringSE replyAddress)
        指定された引数を使用してインスタンスを構築します。'replyAddress' が null の場合、応答は応答キュー名をルーティングキーとして使用してデフォルトの Exchange にルーティングされます。それ以外の場合は、exchange/routingKey の形式を持ち、メッセージが応答キューにルーティングされるようにする必要があります。
        パラメーター:
        connectionFactory - 接続ファクトリ。
        exchange - リクエストが送信されるデフォルトの交換。
        routingKey - デフォルトのルーティングキー。
        replyQueue - 応答をリッスンする応答キューの名前。
        replyAddress - 返信アドレス（exchange/routingKey）。

      • AsyncRabbitTemplate

        public AsyncRabbitTemplate​(RabbitTemplate template,
                           AbstractMessageListenerContainer container)
        提供された引数を使用してインスタンスを構築します。コンテナーがリッスンするように構成されている最初のキューは、応答キューとして使用されます。返信は、ルーティングキーとしてそのキュー名を持つデフォルトの交換を使用してルーティングされます。
        パラメーター:
        template - RabbitTemplate
        container - AbstractMessageListenerContainer。

      • AsyncRabbitTemplate

        public AsyncRabbitTemplate​(RabbitTemplate template,
                           AbstractMessageListenerContainer container,
                           StringSE replyAddress)
        指定された引数を使用してインスタンスを構築します。コンテナーがリッスンするように構成されている最初のキューが、応答キューとして使用されます。'replyAddress' が null の場合、応答は、そのキュー名をルーティングキーとして、デフォルトの exchange を使用してルーティングされます。それ以外の場合は、exchange/routingKey の形式を持ち、メッセージが応答キューにルーティングされるようにする必要があります。
        パラメーター:
        template - RabbitTemplate。
        container - AbstractMessageListenerContainer。
        replyAddress - 返信アドレス。

      • AsyncRabbitTemplate

        public AsyncRabbitTemplate​(ConnectionFactory connectionFactory,
                           StringSE exchange,
                           StringSE routingKey)
        指定された引数を使用してインスタンスを構築します。応答には "Direct replyTo" が使用されます。
        パラメーター:
        connectionFactory - 接続ファクトリ。
        exchange - リクエストが送信されるデフォルトの交換。
        routingKey - デフォルトのルーティングキー。
        導入:
        2.0

      • AsyncRabbitTemplate

        public AsyncRabbitTemplate​(RabbitTemplate template)
        指定された引数を使用してインスタンスを構築します。応答には "Direct replyTo" が使用されます。
        パラメーター:
        template - RabbitTemplate
        導入:
        2.0

    • メソッドの詳細

      • 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 に設定します。有効にすると、送受信操作によって返される AsyncRabbitTemplate.RabbitFuture の confirm プロパティに ListenableFuture<Boolean> が含まれます。
        パラメーター:
        enableConfirms - パブリッシャーの確認を有効にする場合は true。

      • getBeanName

        public StringSE getBeanName()

      • setReceiveTimeout

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

      • setTaskScheduler

        public void setTaskScheduler​(TaskScheduler taskScheduler)
        タスクスケジューラを設定して、タイムアウトした先物を期限切れにします。
        パラメーター:
        taskScheduler - タスクスケジューラ
        関連事項:
        setReceiveTimeout(long)

      • getRabbitTemplate

        public RabbitTemplate getRabbitTemplate()
        送信に使用される基礎となる RabbitTemplate を返します。
        戻り値:
        テンプレート。
        導入:
        2.2

      • sendAndReceive

        public AsyncRabbitTemplate.RabbitMessageFuture sendAndReceive​(Message message)
        インターフェースからコピーされた説明: AsyncAmqpTemplate
        デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。メッセージに correlationId プロパティが含まれている場合、そのプロパティは一意である必要があります。
        次で指定:
        インターフェース AsyncAmqpTemplate 内の sendAndReceive 
        パラメーター:
        message - メッセージ。
        戻り値:
        ListenableFuture

      • sendAndReceive

        public AsyncRabbitTemplate.RabbitMessageFuture sendAndReceive​(StringSE routingKey,
                                                              Message message)
        インターフェースからコピーされた説明: AsyncAmqpTemplate
        指定されたルーティングキーを使用して、デフォルトの交換にメッセージを送信します。メッセージに correlationId プロパティが含まれている場合、そのプロパティは一意である必要があります。
        次で指定:
        インターフェース AsyncAmqpTemplate 内の sendAndReceive 
        パラメーター:
        routingKey - ルーティングキー。
        message - メッセージ。
        戻り値:
        ListenableFuture

      • sendAndReceive

        public AsyncRabbitTemplate.RabbitMessageFuture sendAndReceive​(StringSE exchange,
                                                              StringSE routingKey,
                                                              Message message)
        インターフェースからコピーされた説明: AsyncAmqpTemplate
        指定された交換とルーティングキーにメッセージを送信します。メッセージに correlationId プロパティが含まれている場合、そのプロパティは一意である必要があります。
        次で指定:
        インターフェース AsyncAmqpTemplate 内の sendAndReceive 
        パラメーター:
        exchange - 交換。
        routingKey - ルーティングキー。
        message - メッセージ。
        戻り値:
        ListenableFuture

      • convertSendAndReceive

        public <C> AsyncRabbitTemplate.RabbitConverterFuture<C> convertSendAndReceive​(StringSE routingKey,
                                                                              ObjectSE object)
        インターフェースからコピーされた説明: AsyncAmqpTemplate
        オブジェクトをメッセージに変換し、指定されたルーティングキーを使用してデフォルトの交換に送信します。
        次で指定:
        インターフェース AsyncAmqpTemplate 内の convertSendAndReceive 
        型パラメーター:
        C - 期待される結果型。
        パラメーター:
        routingKey - ルーティングキー。
        object - 変換するオブジェクト。
        戻り値:
        ListenableFuture

      • convertSendAndReceive

        public <C> AsyncRabbitTemplate.RabbitConverterFuture<C> convertSendAndReceive​(ObjectSE object,
                                                                              MessagePostProcessor messagePostProcessor)
        インターフェースからコピーされた説明: AsyncAmqpTemplate
        オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、そのプロパティは一意である必要があります。
        次で指定:
        インターフェース AsyncAmqpTemplate 内の convertSendAndReceive 
        型パラメーター:
        C - 期待される結果型。
        パラメーター:
        object - 変換するオブジェクト。
        messagePostProcessor - ポストプロセッサー。
        戻り値:
        ListenableFuture

      • convertSendAndReceive

        public <C> AsyncRabbitTemplate.RabbitConverterFuture<C> convertSendAndReceive​(StringSE routingKey,
                                                                              ObjectSE object,
                                                                              MessagePostProcessor messagePostProcessor)
        インターフェースからコピーされた説明: AsyncAmqpTemplate
        オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、指定されたルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、そのプロパティは一意である必要があります。
        次で指定:
        インターフェース AsyncAmqpTemplate 内の convertSendAndReceive 
        型パラメーター:
        C - 期待される結果型。
        パラメーター:
        routingKey - ルーティングキー。
        object - 変換するオブジェクト。
        messagePostProcessor - ポストプロセッサー。
        戻り値:
        ListenableFuture

      • convertSendAndReceive

        public <C> AsyncRabbitTemplate.RabbitConverterFuture<C> convertSendAndReceive​(StringSE exchange,
                                                                              StringSE routingKey,
                                                                              ObjectSE object,
                                                                              MessagePostProcessor messagePostProcessor)
        インターフェースからコピーされた説明: AsyncAmqpTemplate
        オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、指定された交換およびルーティングキーに送信します。ポストプロセッサーが correlationId プロパティを追加する場合、そのプロパティは一意である必要があります。
        次で指定:
        インターフェース AsyncAmqpTemplate 内の convertSendAndReceive 
        型パラメーター:
        C - 期待される結果型。
        パラメーター:
        exchange - 交換
        routingKey - ルーティングキー。
        object - 変換するオブジェクト。
        messagePostProcessor - ポストプロセッサー。
        戻り値:
        ListenableFuture

      • convertSendAndReceiveAsType

        public <C> AsyncRabbitTemplate.RabbitConverterFuture<C> convertSendAndReceiveAsType​(ObjectSE object,
                                                                                    MessagePostProcessor messagePostProcessor,
                                                                                    ParameterizedTypeReference<C> responseType)
        インターフェースからコピーされた説明: AsyncAmqpTemplate
        オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、そのプロパティは一意である必要があります。
        次で指定:
        インターフェース AsyncAmqpTemplate 内の convertSendAndReceiveAsType 
        型パラメーター:
        C - 期待される結果型。
        パラメーター:
        object - 変換するオブジェクト。
        messagePostProcessor - ポストプロセッサー。
        responseType - レスポンス型。
        戻り値:
        ListenableFuture

      • convertSendAndReceiveAsType

        public <C> AsyncRabbitTemplate.RabbitConverterFuture<C> convertSendAndReceiveAsType​(StringSE routingKey,
                                                                                    ObjectSE object,
                                                                                    MessagePostProcessor messagePostProcessor,
                                                                                    ParameterizedTypeReference<C> responseType)
        インターフェースからコピーされた説明: AsyncAmqpTemplate
        オブジェクトをメッセージに変換し、MessagePostProcessor を呼び出した後、指定されたルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、そのプロパティは一意である必要があります。
        次で指定:
        インターフェース AsyncAmqpTemplate 内の convertSendAndReceiveAsType 
        型パラメーター:
        C - 期待される結果型。
        パラメーター:
        routingKey - ルーティングキー。
        object - 変換するオブジェクト。
        messagePostProcessor - ポストプロセッサー。
        responseType - レスポンス型。
        戻り値:
        ListenableFuture

      • convertSendAndReceiveAsType

        public <C> AsyncRabbitTemplate.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 - レスポンス型。
        戻り値:
        ListenableFuture

      • start

        public void start()
        次で指定:
        インターフェース Lifecycle 内の start 

      • stop

        public void stop()
        次で指定:
        インターフェース Lifecycle 内の stop 

      • isRunning

        public boolean isRunning()
        次で指定:
        インターフェース Lifecycle 内の isRunning 

      • onMessage

        public void onMessage​(Message message,
                      com.rabbitmq.client.Channel channel)
        インターフェースからコピーされた説明: ChannelAwareMessageListener
        受信した Rabbit メッセージを処理するためのコールバック。

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

        次で指定:
        インターフェース ChannelAwareMessageListener 内の onMessage 
        パラメーター:
        message - 受信した AMQP メッセージ (非 null)
        channel - 基盤となる Rabbit チャネル (ストリームリスナーコンテナーによって呼び出されない限り、null ではありません)。

      • 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。