クラスの使用
org.springframework.amqp.core.Message
Message を使用するパッケージ
パッケージ
説明
AMQP 1.0 プロトコル用の Spring クライアントを提供します。
AMQP 1.0 プロトコル用の Spring リスナーコンテナーを提供します。
Spring の AMQP 抽象化のためのコアクラスを提供します。
Spring AMQP 共通リスナーサポートクラス用のパッケージ。
Spring AMQP 共通リスナーアダプターサポートクラス用のパッケージ。
Spring Rabbit のトップレベルクラスを提供します。
メッセージバッチ処理用のクラスを提供します。
Spring Rabbit のコアクラスを提供します。
メッセージリスナーコンテナーのクラスを提供します。
リスナーを適応させるためのクラスを提供します。
リスナーに追加の API を提供します。
Log4j2 アペンダーをサポートするクラスを提供します。
Logback アペンダーをサポートするクラスを提供します。
再試行をサポートするクラスを提供します。
Spring Rabbit のサポートクラスを提供します。
Micrometer サポート用のクラスを提供します。
Spring AMQP アプリケーションのテスト用クラス。
RabbitMQ AMQP 1.0 クライアントに Spring サポートを提供します。
RabbitMQ AMQP 1.0 コンシューマーに Spring サポートを提供します。
メッセージ変換をサポートするためのクラスを提供します。
Spring AMQP メッセージ後処理プロセッサー用のパッケージ。
ストリームプロデューサーにクラスを提供します。
再試行をサポートするクラスを提供します。
メッセージ変換用のクラスを提供します。
org.springframework.amqp.client 内の Message 使用
Message を返す org.springframework.amqp.client のメソッド修飾子と型メソッド説明static MessageProtonUtils.fromProtonMessage(org.apache.qpid.protonj2.client.Message<?> message) ProtonJ メッセージを Spring AMQP メッセージに変換します。型 Message の引数を持つ型を返す org.springframework.amqp.client のメソッド修飾子と型メソッド説明default CompletableFutureSE<Message> AmqpClient.ReceiveSpec.receive()指定されたfromアドレスから Spring AMQP メッセージを受信してください。型 Message のパラメーターを持つ org.springframework.amqp.client のメソッド修飾子と型メソッド説明AmqpClient.sendToDefault(Message message) Spring AMQP メッセージを送信してください。static org.apache.qpid.protonj2.client.Message<?> ProtonUtils.toProtonMessage(Message message) Spring AMQP メッセージを ProtonJ メッセージに変換します。org.springframework.amqp.client.listener 内の Message 使用
型 Message のパラメーターを持つ org.springframework.amqp.client.listener のメソッドorg.springframework.amqp.core 内の Message 使用
org.springframework.amqp.core の Message 型の型引数を持つサブクラス修飾子と型クラス説明final class流れるような API を使用して、byte[] ボディまたは別のメッセージから Spring AMQP メッセージを構築します。org.springframework.amqp.core の Message 型の型引数を持つサブインターフェース修飾子と型インターフェース説明interfaceReceiveAndReplyCallbackのMessage交換契約。interfaceReceiveAndReplyCallbackのMessage交換契約。Message を返す org.springframework.amqp.core のメソッド修飾子と型メソッド説明MessageBuilder.build()ReturnedMessage.getMessage()メッセージを取得します。AmqpReplyTimeoutException.getRequestMessage()AmqpMessageReturnedException.getReturnedMessage()MessagePostProcessor.postProcessMessage(Message message) メッセージを変更 (または置換) します。default MessageMessagePostProcessor.postProcessMessage(Message message, @Nullable Correlation correlation) メッセージを変更 (または置換) し、その相関データを変更します。default MessageMessagePostProcessor.postProcessMessage(Message message, @Nullable Correlation correlation, StringSE exchange, StringSE routingKey) メッセージを変更 (または置換) し、その相関データを変更します。@Nullable MessageAmqpTemplate.receive()デフォルトキューからのメッセージがある場合は、メッセージを受信します。@Nullable MessageAmqpTemplate.receive(long timeoutMillis) デフォルトのキューからメッセージを受信し、メッセージが利用可能になるまで必要に応じて指定された待機時間まで待機します。@Nullable Message特定のキューからのメッセージがある場合、メッセージを受信します。@Nullable Message特定のキューからメッセージを受信し、メッセージが使用可能になるまで必要に応じて指定された待機時間まで待機します。@Nullable MessageAmqpTemplate.sendAndReceive(StringSE exchange, StringSE routingKey, Message message) 基本的な RPC パターン。@Nullable MessageAmqpTemplate.sendAndReceive(StringSE routingKey, Message message) 基本的な RPC パターン。@Nullable MessageAmqpTemplate.sendAndReceive(Message message) 基本的な RPC パターン。型 Message の引数を持つ型を返す org.springframework.amqp.core のメソッド修飾子と型メソッド説明default CompletableFutureSE<Message> AsyncAmqpTemplate.receive()default CompletableFutureSE<Message> AsyncAmqpTemplate.sendAndReceive(StringSE exchange, @Nullable StringSE routingKey, Message message) 指定された交換およびルーティングキーにメッセージを送信します。AsyncAmqpTemplate.sendAndReceive(StringSE routingKey, Message message) 指定されたルーティングキーを使用して、デフォルトの交換にメッセージを送信します。AsyncAmqpTemplate.sendAndReceive(Message message) デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。型 Message のパラメーターを持つ org.springframework.amqp.core のメソッド修飾子と型メソッド説明static MessageBuilderMessageBuilder.fromClonedMessage(Message message) 最終メッセージにはメッセージ本文のコピーが含まれ、MessageProperties が複製されます (最上位のみ)。static MessageBuilderMessageBuilder.fromMessage(Message message) 最終的なメッセージ本文はメッセージ本文への直接参照になり、MessageProperties は浅いコピーになります。ReplyToAddressCallback.getReplyToAddress(Message request, T reply) default voidvoid1 つのメッセージを配信します。MessagePostProcessor.postProcessMessage(Message message) メッセージを変更 (または置換) します。default MessageMessagePostProcessor.postProcessMessage(Message message, @Nullable Correlation correlation) メッセージを変更 (または置換) し、その相関データを変更します。default MessageMessagePostProcessor.postProcessMessage(Message message, @Nullable Correlation correlation, StringSE exchange, StringSE routingKey) メッセージを変更 (または置換) し、その相関データを変更します。void特定のルーティングキーを使用して、特定の交換にメッセージを送信します。void特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。voidデフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。default CompletableFutureSE<BooleanSE> default CompletableFutureSE<BooleanSE> default CompletableFutureSE<BooleanSE> @Nullable MessageAmqpTemplate.sendAndReceive(StringSE exchange, StringSE routingKey, Message message) 基本的な RPC パターン。@Nullable MessageAmqpTemplate.sendAndReceive(StringSE routingKey, Message message) 基本的な RPC パターン。@Nullable MessageAmqpTemplate.sendAndReceive(Message message) 基本的な RPC パターン。AsyncAmqpTemplate.sendAndReceive(StringSE exchange, @Nullable StringSE routingKey, Message message) 指定された交換およびルーティングキーにメッセージを送信します。AsyncAmqpTemplate.sendAndReceive(StringSE routingKey, Message message) 指定されたルーティングキーを使用して、デフォルトの交換にメッセージを送信します。AsyncAmqpTemplate.sendAndReceive(Message message) デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。型 Message の型引数を持つ org.springframework.amqp.core のメソッドパラメーター修飾子と型メソッド説明voidBatchMessageListener.onMessageBatch(ListSE<Message> messages) default voidMessageListener.onMessageBatch(ListSE<Message> messages) メッセージのバッチを配信します。型 Message のパラメーターを持つ org.springframework.amqp.core のコンストラクター修飾子コンストラクター説明AmqpReplyTimeoutException(StringSE message, Message requestMessage) ReturnedMessage(Message message, int replyCode, StringSE replyText, StringSE exchange, StringSE routingKey) org.springframework.amqp.listener 内の Message 使用
Message を返す org.springframework.amqp.listener のメソッド型 Message の引数を持つ型を返す org.springframework.amqp.listener のメソッド型 Message のパラメーターを持つ org.springframework.amqp.listener のメソッド修飾子と型メソッド説明protected voidConditionalRejectingErrorHandler.handleDiscarded(Message failed) メッセージを破棄する前に、致命的な例外を含むメッセージにx-deathヘッダーがある場合に呼び出されます。型 Message のパラメーターを持つ org.springframework.amqp.listener のコンストラクター修飾子コンストラクター説明ListenerExecutionFailedException(StringSE msg, ThrowableSE cause, Message... failedMessage) ListenerExecutionFailedException のコンストラクター。org.springframework.amqp.listener.adapter 内の Message 使用
org.springframework.amqp.listener.adapter の Message 型の型引数を持つサブインターフェース修飾子と型インターフェース説明interface返信用のポストプロセッサー。interface返信用のポストプロセッサー。interface返信用のポストプロセッサー。型 Message のパラメーターを持つ org.springframework.amqp.listener.adapter のコンストラクター修飾子コンストラクター説明ReplyExpressionRoot(Message request, @Nullable ObjectSE source, @Nullable ObjectSE result) ReplyExpressionRootレコードクラスのインスタンスを作成します。org.springframework.amqp.rabbit 内の Message 使用
org.springframework.amqp.rabbit の Message 型の型引数を持つサブクラス型 Message のパラメーターを持つ org.springframework.amqp.rabbit のメソッド修飾子と型メソッド説明voidAsyncRabbitTemplate.sendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message) AsyncRabbitTemplate.sendAndReceive(@Nullable StringSE routingKey, Message message) AsyncRabbitTemplate.sendAndReceive(Message message) 型 Message のパラメーターを持つ org.springframework.amqp.rabbit のコンストラクター修飾子コンストラクター説明protectedRabbitFuture(StringSE correlationId, Message requestMessage, BiConsumerSE<StringSE, @Nullable DirectReplyToMessageListenerContainer.ChannelHolder> canceler, FunctionSE<RabbitFuture<?>, @Nullable ScheduledFutureSE<?>> timeoutTaskFunction) org.springframework.amqp.rabbit.batch 内の Message 使用
Message を返す org.springframework.amqp.rabbit.batch のメソッド修飾子と型メソッド説明MessageBatch.getMessage()非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。MessageBatch.message()messageレコードコンポーネントの値を返します。型 Message のパラメーターを持つ org.springframework.amqp.rabbit.batch のメソッド修飾子と型メソッド説明@Nullable MessageBatchBatchingStrategy.addToBatch(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message) バッチにメッセージを追加し、必要に応じてバッチを解放します。@Nullable MessageBatchSimpleBatchingStrategy.addToBatch(@Nullable StringSE exch, @Nullable StringSE routKey, Message message) default voidBatchingStrategy.deBatch(Message message, ConsumerSE<Message> fragmentConsumer) メッセージをフラグメントにデコードします。voidSimpleBatchingStrategy.deBatch(Message message, ConsumerSE<Message> fragmentConsumer) MessageProperties.SPRING_BATCH_FORMATがMessageProperties.BATCH_FORMAT_LENGTH_HEADER4に設定されたヘッダーを持つメッセージをデバッチします。型 Message の型引数を持つ org.springframework.amqp.rabbit.batch のメソッドパラメーター修飾子と型メソッド説明default voidBatchingStrategy.deBatch(Message message, ConsumerSE<Message> fragmentConsumer) メッセージをフラグメントにデコードします。voidSimpleBatchingStrategy.deBatch(Message message, ConsumerSE<Message> fragmentConsumer) MessageProperties.SPRING_BATCH_FORMATがMessageProperties.BATCH_FORMAT_LENGTH_HEADER4に設定されたヘッダーを持つメッセージをデバッチします。型 Message のパラメーターを持つ org.springframework.amqp.rabbit.batch のコンストラクター修飾子コンストラクター説明MessageBatch(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message) MessageBatchレコードクラスのインスタンスを作成します。org.springframework.amqp.rabbit.core 内の Message 使用
Message を返す org.springframework.amqp.rabbit.core のメソッド修飾子と型メソッド説明protected MessageRabbitTemplate.convertMessageIfNecessary(ObjectSE object) protected @Nullable MessageRabbitTemplate.convertSendAndReceiveRaw(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData) メッセージを変換して送信し、生の返信メッセージまたは null を返します。protected @Nullable MessageRabbitTemplate.doReceiveNoWait(StringSE queueName) ノンブロッキング受信。protected @Nullable MessageRabbitTemplate.doSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) メッセージを送信し、返信を待ちます。protected @Nullable MessageRabbitTemplate.doSendAndReceiveWithFixed(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) protected @Nullable MessageRabbitTemplate.doSendAndReceiveWithTemporary(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) AmqpNackReceivedException.getFailedMessage()失敗したメッセージを返します。@Nullable MessageRabbitTemplate.receive()@Nullable MessageRabbitTemplate.receive(long timeoutMillis) @Nullable Message@Nullable Message@Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message) @Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) @Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE routingKey, Message message) @Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) @Nullable MessageRabbitTemplate.sendAndReceive(Message message) @Nullable MessageRabbitTemplate.sendAndReceive(Message message, @Nullable CorrelationData correlationData) 型 Message のパラメーターを持つ org.springframework.amqp.rabbit.core のメソッド修飾子と型メソッド説明protected @Nullable Message<?> RabbitMessagingTemplate.convertAmqpMessage(@Nullable Message message) voidRabbitTemplate.doSend(com.rabbitmq.client.Channel channel, @Nullable StringSE exchangeArg, @Nullable StringSE routingKeyArg, Message message, boolean mandatory, @Nullable CorrelationData correlationData) 指定されたメッセージを指定された交換に送信します。protected @Nullable MessageRabbitTemplate.doSendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) メッセージを送信し、返信を待ちます。protected @Nullable MessageRabbitTemplate.doSendAndReceiveWithFixed(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) protected @Nullable MessageRabbitTemplate.doSendAndReceiveWithTemporary(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) RabbitTemplate.isMandatoryFor(Message message) 指定されたメッセージを必須フラグを設定して送信する必要があるかどうかを返します。protected voidRabbitTemplate.logReceived(StringSE prefix, @Nullable Message message) 受信したメッセージをログに記録します。protected voidRabbitTemplate.observeTheSend(com.rabbitmq.client.Channel channel, Message message, boolean mandatory, StringSE exch, StringSE rKey) voidvoidCorrelationDataPostProcessor.postProcess(Message message, @Nullable CorrelationData correlationData) send メソッドで提供される相関データを更新または置換します。voidBatchingRabbitTemplate.send(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) voidRabbitOperations.send(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) 特定のルーティングキーを使用して、特定の交換にメッセージを送信します。default voidRabbitOperations.send(@Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) 特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。voidvoidRabbitTemplate.send(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) voidvoidRabbitTemplate.send(@Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) void@Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message) @Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) @Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE routingKey, Message message) @Nullable MessageRabbitTemplate.sendAndReceive(@Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) @Nullable MessageRabbitTemplate.sendAndReceive(Message message) @Nullable MessageRabbitTemplate.sendAndReceive(Message message, @Nullable CorrelationData correlationData) protected voidRabbitTemplate.sendToRabbit(com.rabbitmq.client.Channel channel, StringSE exchange, StringSE routingKey, boolean mandatory, Message message) 型 Message のパラメーターを持つ org.springframework.amqp.rabbit.core のコンストラクター修飾子コンストラクター説明AmqpNackReceivedException(StringSE message, Message failedMessage) 提供されたメッセージと失敗したメッセージでインスタンスを作成します。org.springframework.amqp.rabbit.listener 内の Message 使用
修飾子と型メソッド説明@Nullable MessageBlockingQueueConsumer.nextMessage()主なアプリケーション側 API: 次のメッセージ配信を待って、それを返します。@Nullable MessageBlockingQueueConsumer.nextMessage(long timeout) 主なアプリケーション側 API: 次のメッセージ配信を待って、それを返します。型 Message の引数を持つ型を返す org.springframework.amqp.rabbit.listener のメソッド修飾子と型メソッド説明型 Message のパラメーターを持つ org.springframework.amqp.rabbit.listener のメソッドorg.springframework.amqp.rabbit.listener.adapter 内の Message 使用
修飾子と型メソッド説明protected MessageAbstractAdaptableMessageListener.buildMessage(@Nullable com.rabbitmq.client.Channel channel, @Nullable ObjectSE result, @Nullable TypeSE genericType) 指定された結果オブジェクトに基づいて、レスポンスとして送信される Rabbit メッセージを構築します。protected MessageMessagingMessageListenerAdapter.buildMessage(@Nullable com.rabbitmq.client.Channel channel, @Nullable ObjectSE result, @Nullable TypeSE genericType) 指定された結果オブジェクトに基づいて、レスポンスとして送信される Rabbit メッセージを構築します。protected MessageAbstractAdaptableMessageListener.convert(@Nullable ObjectSE result, @Nullable TypeSE genericType, MessageConverter converter) 設定に基づいて、返信コンテンツ型を含むメッセージに変換します。型 Message のパラメーターを持つ org.springframework.amqp.rabbit.listener.adapter のメソッド修飾子と型メソッド説明protected voidAbstractAdaptableMessageListener.asyncFailure(Message request, @Nullable com.rabbitmq.client.Channel channel, ThrowableSE t, @Nullable ObjectSE source) protected voidMessagingMessageListenerAdapter.asyncFailure(Message request, @Nullable com.rabbitmq.client.Channel channel, ThrowableSE t, @Nullable ObjectSE source) protected voidAbstractAdaptableMessageListener.basicAck(Message request, @Nullable com.rabbitmq.client.Channel channel) protected ObjectSE[]MessageListenerAdapter.buildListenerArguments(ObjectSE extractedMessage, @Nullable com.rabbitmq.client.Channel channel, Message message) ターゲットリスナーメソッドに渡される引数の配列を作成します。protected voidAbstractAdaptableMessageListener.doHandleResult(InvocationResult resultArg, Message request, @Nullable com.rabbitmq.client.Channel channel, @Nullable ObjectSE source) protected voidAbstractAdaptableMessageListener.doPublish(com.rabbitmq.client.Channel channel, Address replyTo, Message message) protected ObjectSEAbstractAdaptableMessageListener.extractMessage(Message message) 指定された Rabbit メッセージからメッセージ本文を抽出します。protected StringSEMessageListenerAdapter.getListenerMethodName(Message originalMessage, ObjectSE extractedMessage) 指定されたメッセージを処理するリスナーメソッドの名前を決定します。protected @Nullable StringSEAbstractAdaptableMessageListener.getReceivedExchange(Message request) protected AddressAbstractAdaptableMessageListener.getReplyToAddress(Message request, @Nullable ObjectSE source, InvocationResult result) 指定されたメッセージの返信先アドレスを決定します。protected voidMessagingMessageListenerAdapter.handleException(Message amqpMessage, @Nullable com.rabbitmq.client.Channel channel, @Nullable Message<?> message, ListenerExecutionFailedException e) protected voidAbstractAdaptableMessageListener.handleResult(@Nullable InvocationResult resultArg, Message request, @Nullable com.rabbitmq.client.Channel channel, @Nullable ObjectSE source) リスナメソッドから返された結果オブジェクトを処理し、レスポンスメッセージを送り返します。protected voidAbstractAdaptableMessageListener.handleResult(InvocationResult resultArg, Message request, @Nullable com.rabbitmq.client.Channel channel) リスナメソッドから返された結果オブジェクトを処理し、レスポンスメッセージを送り返します。protected InvocationResultMessagingMessageListenerAdapter.invokeHandler(@Nullable com.rabbitmq.client.Channel channel, Message<?> message, boolean batch, Message... amqpMessages) ハンドラーを呼び出し、専用のエラーメッセージでListenerExecutionFailedExceptionへの例外をラップします。protected voidMessagingMessageListenerAdapter.invokeHandlerAndProcessResult(Message amqpMessage, @Nullable com.rabbitmq.client.Channel channel, Message<?> message) protected @Nullable ObjectSEMessageListenerAdapter.invokeListenerMethod(StringSE methodName, @Nullable ObjectSE @Nullable[] arguments, Message originalMessage) 指定されたリスナーメソッドを呼び出します。voidSpringChannelAwareMessageListenerエントリポイント。voidMessagingMessageListenerAdapter.onMessage(Message amqpMessage, @Nullable com.rabbitmq.client.Channel channel) protected voidAbstractAdaptableMessageListener.postProcessChannel(com.rabbitmq.client.Channel channel, Message response) レスポンスを送信する前に、指定されたメッセージを後処理します。protected voidAbstractAdaptableMessageListener.postProcessResponse(Message request, Message response) 指定されたレスポンスメッセージを送信する前に後処理します。protected voidAbstractAdaptableMessageListener.sendResponse(@Nullable com.rabbitmq.client.Channel channel, Address replyTo, Message messageIn) 指定されたレスポンスメッセージを指定された宛先に送信します。protected Message<?> BatchMessagingMessageListenerAdapter.toMessagingMessage(Message amqpMessage) protected Message<?> MessagingMessageListenerAdapter.toMessagingMessage(Message amqpMessage) 型 Message の型引数を持つ org.springframework.amqp.rabbit.listener.adapter のメソッドパラメーター修飾子と型メソッド説明voidBatchMessagingMessageListenerAdapter.onMessageBatch(ListSE<Message> messages, @Nullable com.rabbitmq.client.Channel channel) org.springframework.amqp.rabbit.listener.api 内の Message 使用
型 Message のパラメーターを持つ org.springframework.amqp.rabbit.listener.api のメソッド修飾子と型メソッド説明@Nullable ObjectSERabbitListenerErrorHandler.handleError(Message amqpMessage, @Nullable com.rabbitmq.client.Channel channel, @Nullable Message<?> message, ListenerExecutionFailedException exception) エラーを処理します。default voidChannelAwareBatchMessageListener.onMessage(Message message, @Nullable com.rabbitmq.client.Channel channel) default voidvoidChannelAwareMessageListener.onMessage(Message message, @Nullable com.rabbitmq.client.Channel channel) 受信した Rabbit メッセージを処理するためのコールバック。型 Message の型引数を持つ org.springframework.amqp.rabbit.listener.api のメソッドパラメーター修飾子と型メソッド説明voidChannelAwareBatchMessageListener.onMessageBatch(ListSE<Message> messages, @Nullable com.rabbitmq.client.Channel channel) default voidChannelAwareMessageListener.onMessageBatch(ListSE<Message> messages, @Nullable com.rabbitmq.client.Channel channel) org.springframework.amqp.rabbit.log4j2 内の Message 使用
修飾子と型メソッド説明protected MessageAmqpAppender.postProcessMessageBeforeSend(Message message, AmqpAppender.Event event) サブクラスは、送信前に最終メッセージを変更できます。型 Message のパラメーターを持つ org.springframework.amqp.rabbit.log4j2 のメソッド修飾子と型メソッド説明protected MessageAmqpAppender.postProcessMessageBeforeSend(Message message, AmqpAppender.Event event) サブクラスは、送信前に最終メッセージを変更できます。org.springframework.amqp.rabbit.logback 内の Message 使用
修飾子と型メソッド説明protected MessageAmqpAppender.postProcessMessageBeforeSend(Message message, AmqpAppender.Event event) サブクラスは、送信前に最終メッセージを変更できます。型 Message のパラメーターを持つ org.springframework.amqp.rabbit.logback のメソッド修飾子と型メソッド説明protected MessageAmqpAppender.postProcessMessageBeforeSend(Message message, AmqpAppender.Event event) サブクラスは、送信前に最終メッセージを変更できます。org.springframework.amqp.rabbit.retry 内の Message 使用
型 Message のパラメーターを持つ org.springframework.amqp.rabbit.retry のメソッド修飾子と型メソッド説明RepublishMessageRecoverer.additionalHeaders(Message message, @Nullable ThrowableSE cause) サブクラスは、このメソッドをオーバーライドして、再発行されたメッセージにヘッダーを追加できます。protected voidメッセージを送信します。protected voidRepublishMessageRecovererWithConfirms.doSend(@Nullable StringSE exchange, StringSE routingKey, Message message) @Nullable ObjectSE再配信時に繰り返し可能なメッセージの一意のキーを生成します。booleanメッセージをクエリして、それが以前に表示されたかどうかを確認します。protected StringSERepublishMessageRecoverer.prefixedOriginalRoutingKey(Message message) このメソッドのデフォルトの動作は、受信したルーティングキーをroutingKeyPrefixに追加することです。voidImmediateRequeueMessageRecoverer.recover(Message message, @Nullable ThrowableSE cause) default voidMessageBatchRecoverer.recover(Message message, ThrowableSE cause) voidMessageRecoverer.recover(Message message, ThrowableSE cause) 消費されましたが再試行がすべて失敗したメッセージのコールバック。voidRejectAndDontRequeueRecoverer.recover(Message message, @Nullable ThrowableSE cause) voidRepublishMessageRecoverer.recover(Message message, @Nullable ThrowableSE cause) 型 Message の型引数を持つ org.springframework.amqp.rabbit.retry のメソッドパラメーター修飾子と型メソッド説明voidMessageBatchRecoverer.recover(ListSE<Message> messages, ThrowableSE cause) 消費されましたが再試行にすべて失敗したメッセージバッチのコールバック。org.springframework.amqp.rabbit.support 内の Message 使用
型 Message のパラメーターを持つ org.springframework.amqp.rabbit.support のコンストラクター修飾子コンストラクター説明ListenerExecutionFailedException(StringSE msg, ThrowableSE cause, Message... failedMessage) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。ListenerExecutionFailedException のコンストラクター。org.springframework.amqp.rabbit.support.micrometer 内の Message 使用
org.springframework.amqp.rabbit.support.micrometer の Message 型の型引数を持つサブクラス型 Message のパラメーターを持つ org.springframework.amqp.rabbit.support.micrometer のコンストラクター修飾子コンストラクター説明RabbitMessageReceiverContext(Message message, StringSE listenerId) RabbitMessageSenderContext(Message message, StringSE beanName, StringSE exchange, StringSE routingKey) インスタンスRabbitMessageSenderContextを作成します。org.springframework.amqp.rabbit.test 内の Message 使用
Message を返す org.springframework.amqp.rabbit.test のメソッド修飾子と型メソッド説明protected @Nullable MessageTestRabbitTemplate.doSendAndReceiveWithFixed(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) 型 Message のパラメーターを持つ org.springframework.amqp.rabbit.test のメソッド修飾子と型メソッド説明protected @Nullable MessageTestRabbitTemplate.doSendAndReceiveWithFixed(@Nullable StringSE exchange, @Nullable StringSE routingKey, Message message, @Nullable CorrelationData correlationData) protected voidTestRabbitTemplate.sendToRabbit(com.rabbitmq.client.Channel channel, StringSE exchange, StringSE routingKey, boolean mandatory, Message message) org.springframework.amqp.rabbitmq.client 内の Message 使用
修飾子と型メソッド説明static MessageRabbitAmqpUtils.fromAmqpMessage(com.rabbitmq.client.amqp.Message amqpMessage, @Nullable com.rabbitmq.client.amqp.Consumer.Context context) MessageをMessageに変換します。型 Message の引数を持つ型を返す org.springframework.amqp.rabbitmq.client のメソッド修飾子と型メソッド説明RabbitAmqpTemplate.receive()指定されたキューからヘッドメッセージをリクエストします。RabbitAmqpTemplate.sendAndReceive(StringSE exchange, @Nullable StringSE routingKey, Message message) RabbitAmqpTemplate.sendAndReceive(StringSE queue, Message message) RabbitAmqpTemplate.sendAndReceive(Message message) 型 Message のパラメーターを持つ org.springframework.amqp.rabbitmq.client のメソッド修飾子と型メソッド説明指定されたキューにメッセージを公開します。このテンプレートで構成されているデフォルトの交換およびルーティングキー (存在する場合) (またはキュー) にメッセージを公開します。RabbitAmqpTemplate.sendAndReceive(StringSE exchange, @Nullable StringSE routingKey, Message message) RabbitAmqpTemplate.sendAndReceive(StringSE queue, Message message) RabbitAmqpTemplate.sendAndReceive(Message message) static voidRabbitAmqpUtils.toAmqpMessage(Message message, com.rabbitmq.client.amqp.Message amqpMessage) MessageをMessageに変換します。org.springframework.amqp.rabbitmq.client.listener 内の Message 使用
型 Message のパラメーターを持つ org.springframework.amqp.rabbitmq.client.listener のメソッド修飾子と型メソッド説明protected voidRabbitAmqpMessageListenerAdapter.asyncFailure(Message request, @Nullable com.rabbitmq.client.Channel channel, ThrowableSE t, @Nullable ObjectSE source) protected voidRabbitAmqpMessageListenerAdapter.basicAck(Message request, @Nullable com.rabbitmq.client.Channel channel) protected voidRabbitAmqpMessageListenerAdapter.sendResponse(@Nullable com.rabbitmq.client.Channel channel, Address replyTo, Message messageIn) 型 Message の型引数を持つ org.springframework.amqp.rabbitmq.client.listener のメソッドパラメーターorg.springframework.amqp.support.converter 内の Message 使用
修飾子と型メソッド説明protected MessageAbstractJackson2MessageConverter.createMessage(ObjectSE objectToConvert, MessageProperties messageProperties) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。protected MessageAbstractJackson2MessageConverter.createMessage(ObjectSE objectToConvert, MessageProperties messageProperties, @Nullable TypeSE genericType) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。protected MessageAbstractJacksonMessageConverter.createMessage(ObjectSE objectToConvert, MessageProperties messageProperties) protected MessageAbstractJacksonMessageConverter.createMessage(ObjectSE objectToConvert, MessageProperties messageProperties, @Nullable TypeSE genericType) protected abstract MessageAbstractMessageConverter.createMessage(ObjectSE object, MessageProperties messageProperties) 指定されたペイロードオブジェクトとメッセージプロパティからメッセージを作成します。protected MessageAbstractMessageConverter.createMessage(ObjectSE object, MessageProperties messageProperties, @Nullable TypeSE genericType) 指定されたペイロードオブジェクトとメッセージプロパティからメッセージを作成します。protected MessageMarshallingMessageConverter.createMessage(ObjectSE object, MessageProperties messageProperties) 指定されたオブジェクトをMessageにマーシャリングします。protected MessageSerializerMessageConverter.createMessage(ObjectSE object, MessageProperties messageProperties) 指定されたオブジェクトから AMQP メッセージを作成します。protected MessageSimpleMessageConverter.createMessage(ObjectSE object, MessageProperties messageProperties) 指定されたオブジェクトから AMQP メッセージを作成します。final MessageAbstractMessageConverter.toMessage(ObjectSE object, @Nullable MessageProperties messagePropertiesArg, @Nullable TypeSE genericType) final MessageAbstractMessageConverter.toMessage(ObjectSE object, MessageProperties messageProperties) ContentTypeDelegatingMessageConverter.toMessage(ObjectSE object, MessageProperties messageProperties) MessageConverter.toMessage(ObjectSE object, MessageProperties messageProperties) Java オブジェクトをメッセージに変換します。default MessageMessageConverter.toMessage(ObjectSE object, MessageProperties messageProperties, @Nullable TypeSE genericType) Java オブジェクトをメッセージに変換します。MessagingMessageConverter.toMessage(ObjectSE object, MessageProperties messageProperties) RemoteInvocationAwareMessageConverterAdapter.toMessage(ObjectSE object, MessageProperties messageProperties) 型 Message のパラメーターを持つ org.springframework.amqp.support.converter のメソッド修飾子と型メソッド説明非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。protected ObjectSEAbstractJacksonMessageConverter.convertContent(Message message, @Nullable ObjectSE conversionHint, MessageProperties properties, @Nullable StringSE encoding) protected ObjectSEJacksonJsonMessageConverter.convertContent(Message message, @Nullable ObjectSE conversionHint, MessageProperties properties, @Nullable StringSE encoding) protected ObjectSEAbstractJacksonMessageConverter.doFromMessage(Message message, @Nullable ObjectSE conversionHint, MessageProperties properties, @Nullable StringSE encoding) protected ObjectSEMessagingMessageConverter.extractPayload(Message message) 指定されたMessageのペイロードを抽出します。MessagingMessageConverterAdapter.extractPayload(Message message) AbstractJackson2MessageConverter.fromMessage(Message message) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。AbstractJackson2MessageConverter.fromMessage(Message message, @Nullable ObjectSE conversionHint) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。追加の変換コンテキストを引数として取るMessageConverter.fromMessage(Message)のバリアント。AbstractJacksonMessageConverter.fromMessage(Message message) AbstractJacksonMessageConverter.fromMessage(Message message, @Nullable ObjectSE conversionHint) 追加の変換コンテキストを引数として取るMessageConverter.fromMessage(Message)のバリアント。ContentTypeDelegatingMessageConverter.fromMessage(Message message) MarshallingMessageConverter.fromMessage(Message message) 指定されたMessageをオブジェクトに非整列化します。MessageConverter.fromMessage(Message message) Message から Java オブジェクトに変換します。MessagingMessageConverter.fromMessage(Message message) RemoteInvocationAwareMessageConverterAdapter.fromMessage(Message message) SerializerMessageConverter.fromMessage(Message message) AMQP メッセージからオブジェクトに変換します。SimpleMessageConverter.fromMessage(Message message) AMQP メッセージからオブジェクトに変換します。SmartMessageConverter.fromMessage(Message message, @Nullable ObjectSE conversionHint) 追加の変換コンテキストを引数として取るMessageConverter.fromMessage(Message)のバリアント。org.springframework.amqp.support.postprocessor 内の Message 使用
修飾子と型メソッド説明AbstractCompressingPostProcessor.postProcessMessage(Message message) AbstractDecompressingPostProcessor.postProcessMessage(Message message) DelegatingDecompressingPostProcessor.postProcessMessage(Message message) 型 Message のパラメーターを持つ org.springframework.amqp.support.postprocessor のメソッド修飾子と型メソッド説明AbstractCompressingPostProcessor.postProcessMessage(Message message) AbstractDecompressingPostProcessor.postProcessMessage(Message message) DelegatingDecompressingPostProcessor.postProcessMessage(Message message) org.springframework.rabbit.stream.producer 内の Message 使用
型 Message のパラメーターを持つ org.springframework.rabbit.stream.producer のメソッド修飾子と型メソッド説明Spring AMQP メッセージを送信してください。org.springframework.rabbit.stream.retry 内の Message 使用
型 Message のパラメーターを持つ org.springframework.rabbit.stream.retry のメソッド修飾子と型メソッド説明default voidStreamMessageRecoverer.recover(Message message, @Nullable ThrowableSE cause) org.springframework.rabbit.stream.support.converter 内の Message 使用
修飾子と型メソッド説明DefaultStreamMessageConverter.toMessage(ObjectSE object, StreamMessageProperties messageProperties) default MessageStreamMessageConverter.toMessage(ObjectSE object, MessageProperties messageProperties) StreamMessageConverter.toMessage(ObjectSE object, StreamMessageProperties messageProperties) 型 Message のパラメーターを持つ org.springframework.rabbit.stream.support.converter のメソッド修飾子と型メソッド説明com.rabbitmq.stream.MessageDefaultStreamMessageConverter.fromMessage(Message message) com.rabbitmq.stream.MessageStreamMessageConverter.fromMessage(Message message)
MessageBatch.message()。