クラスの使用
org.springframework.amqp.core.Message
Message を使用するパッケージ
パッケージ
説明
Spring の AMQP 抽象化のためのコアクラスを提供します。
Spring Rabbit のトップレベルクラスを提供します。
メッセージバッチ処理用のクラスを提供します。
Spring Rabbit のコアクラスを提供します。
メッセージリスナーコンテナーのクラスを提供します。
リスナーを適応させるためのクラスを提供します。
リスナーに追加の API を提供します。
Log4j2 アペンダーをサポートするクラスを提供します。
Logback アペンダーをサポートするクラスを提供します。
再試行をサポートするクラスを提供します。
Spring Rabbit のサポートクラスを提供します。
Micrometer サポート用のクラスを提供します。
Spring AMQP アプリケーションをテストするためのクラス。
Spring AMQP サポートクラスのパッケージ。
メッセージ変換をサポートするためのクラスを提供します。
Spring AMQP メッセージポストプロセッサー用のパッケージ。
ストリームプロデューサーにクラスを提供します。
再試行をサポートするクラスを提供します。
メッセージ変換用のクラスを提供します。
org.springframework.amqp.core 内の Message 使用
Message を返す org.springframework.amqp.core のメソッド修飾子と型メソッド説明MessageBuilder.build()ReturnedMessage.getMessage()メッセージを取得します。AmqpReplyTimeoutException.getRequestMessage()AmqpMessageReturnedException.getReturnedMessage()MessagePostProcessor.postProcessMessage(Message message) メッセージを変更 (または置換) します。default MessageMessagePostProcessor.postProcessMessage(Message message, Correlation correlation) メッセージを変更 (または置換) し、その相関データを変更します。default MessageMessagePostProcessor.postProcessMessage(Message message, Correlation correlation, StringSE exchange, StringSE routingKey) メッセージを変更 (または置換) し、その相関データを変更します。AmqpTemplate.receive()デフォルトキューからのメッセージがある場合は、メッセージを受信します。AmqpTemplate.receive(long timeoutMillis) デフォルトのキューからメッセージを受信し、メッセージが利用可能になるまで必要に応じて指定された待機時間まで待機します。特定のキューからのメッセージがある場合、メッセージを受信します。特定のキューからメッセージを受信し、メッセージが使用可能になるまで必要に応じて指定された待機時間まで待機します。AmqpTemplate.sendAndReceive(StringSE exchange, StringSE routingKey, Message message) 基本的な RPC パターン。AmqpTemplate.sendAndReceive(StringSE routingKey, Message message) 基本的な RPC パターン。AmqpTemplate.sendAndReceive(Message message) 基本的な RPC パターン。型 Message の引数を持つ型を返す org.springframework.amqp.core のメソッド修飾子と型メソッド説明AsyncAmqpTemplate.sendAndReceive(StringSE exchange, 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, Correlation correlation) メッセージを変更 (または置換) し、その相関データを変更します。default MessageMessagePostProcessor.postProcessMessage(Message message, Correlation correlation, StringSE exchange, StringSE routingKey) メッセージを変更 (または置換) し、その相関データを変更します。void特定のルーティングキーを使用して、特定の交換にメッセージを送信します。void特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。voidデフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。AmqpTemplate.sendAndReceive(StringSE exchange, StringSE routingKey, Message message) 基本的な RPC パターン。AmqpTemplate.sendAndReceive(StringSE routingKey, Message message) 基本的な RPC パターン。AmqpTemplate.sendAndReceive(Message message) 基本的な RPC パターン。AsyncAmqpTemplate.sendAndReceive(StringSE exchange, 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.rabbit 内の Message 使用
型 Message のパラメーターを持つ org.springframework.amqp.rabbit のメソッド修飾子と型メソッド説明voidAsyncRabbitTemplate.sendAndReceive(StringSE exchange, StringSE routingKey, Message message) AsyncRabbitTemplate.sendAndReceive(StringSE routingKey, Message message) AsyncRabbitTemplate.sendAndReceive(Message message) 型 Message のパラメーターを持つ org.springframework.amqp.rabbit のコンストラクター修飾子コンストラクター説明protectedRabbitFuture(StringSE correlationId, Message requestMessage, BiConsumerSE<StringSE, DirectReplyToMessageListenerContainer.ChannelHolder> canceler, FunctionSE<RabbitFuture<?>, ScheduledFutureSE<?>> timeoutTaskFunction) org.springframework.amqp.rabbit.batch 内の Message 使用
Message を返す org.springframework.amqp.rabbit.batch のメソッド型 Message のパラメーターを持つ org.springframework.amqp.rabbit.batch のメソッド修飾子と型メソッド説明BatchingStrategy.addToBatch(StringSE exchange, StringSE routingKey, Message message) バッチにメッセージを追加し、必要に応じてバッチを解放します。SimpleBatchingStrategy.addToBatch(StringSE exch, 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 のコンストラクターorg.springframework.amqp.rabbit.core 内の Message 使用
Message を返す org.springframework.amqp.rabbit.core のメソッド修飾子と型メソッド説明protected MessageRabbitTemplate.convertMessageIfNecessary(ObjectSE object) protected MessageRabbitTemplate.convertSendAndReceiveRaw(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) メッセージを変換して送信し、生の返信メッセージまたは null を返します。protected MessageRabbitTemplate.doReceiveNoWait(StringSE queueName) ノンブロッキング受信。protected MessageRabbitTemplate.doSendAndReceive(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) メッセージを送信し、返信を待ちます。protected MessageRabbitTemplate.doSendAndReceiveWithFixed(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) protected MessageRabbitTemplate.doSendAndReceiveWithTemporary(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) AmqpNackReceivedException.getFailedMessage()失敗したメッセージを返します。RabbitTemplate.receive()RabbitTemplate.receive(long timeoutMillis) RabbitTemplate.sendAndReceive(StringSE exchange, StringSE routingKey, Message message) RabbitTemplate.sendAndReceive(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive(StringSE routingKey, Message message) RabbitTemplate.sendAndReceive(StringSE routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive(Message message) RabbitTemplate.sendAndReceive(Message message, CorrelationData correlationData) 型 Message のパラメーターを持つ org.springframework.amqp.rabbit.core のメソッド修飾子と型メソッド説明protected Message<?>RabbitMessagingTemplate.convertAmqpMessage(Message message) voidRabbitTemplate.doSend(com.rabbitmq.client.Channel channel, StringSE exchangeArg, StringSE routingKeyArg, Message message, boolean mandatory, CorrelationData correlationData) 指定されたメッセージを指定された交換に送信します。protected MessageRabbitTemplate.doSendAndReceive(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) メッセージを送信し、返信を待ちます。protected MessageRabbitTemplate.doSendAndReceiveWithFixed(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) protected MessageRabbitTemplate.doSendAndReceiveWithTemporary(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) RabbitTemplate.isMandatoryFor(Message message) 指定されたメッセージを必須フラグを設定して送信する必要があるかどうかを返します。protected voidRabbitTemplate.logReceived(StringSE prefix, Message message) 受信したメッセージをログに記録します。protected voidRabbitTemplate.observeTheSend(com.rabbitmq.client.Channel channel, Message message, boolean mandatory, StringSE exch, StringSE rKey) voidvoidCorrelationDataPostProcessor.postProcess(Message message, CorrelationData correlationData) send メソッドで提供される相関データを更新または置換します。voidBatchingRabbitTemplate.send(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) voidRabbitOperations.send(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) 特定のルーティングキーを使用して、特定の交換にメッセージを送信します。default voidRabbitOperations.send(StringSE routingKey, Message message, CorrelationData correlationData) 特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。voidvoidRabbitTemplate.send(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) voidvoidRabbitTemplate.send(StringSE routingKey, Message message, CorrelationData correlationData) voidRabbitTemplate.sendAndReceive(StringSE exchange, StringSE routingKey, Message message) RabbitTemplate.sendAndReceive(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive(StringSE routingKey, Message message) RabbitTemplate.sendAndReceive(StringSE routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive(Message message) RabbitTemplate.sendAndReceive(Message message, 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 使用
修飾子と型メソッド説明BlockingQueueConsumer.nextMessage()主なアプリケーション側 API: 次のメッセージ配信を待って、それを返します。BlockingQueueConsumer.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(com.rabbitmq.client.Channel channel, ObjectSE result, TypeSE genericType) 指定された結果オブジェクトに基づいて、レスポンスとして送信される Rabbit メッセージを作成します。protected MessageMessagingMessageListenerAdapter.buildMessage(com.rabbitmq.client.Channel channel, ObjectSE result, TypeSE genericType) 指定された結果オブジェクトに基づいて、レスポンスとして送信される Rabbit メッセージを作成します。protected MessageAbstractAdaptableMessageListener.convert(ObjectSE result, TypeSE genericType, MessageConverter converter) 設定に基づいた返信コンテンツ型で、メッセージに変換します。AbstractAdaptableMessageListener.ReplyExpressionRoot.getRequest()型 Message のパラメーターを持つ org.springframework.amqp.rabbit.listener.adapter のメソッド修飾子と型メソッド説明protected voidAbstractAdaptableMessageListener.asyncFailure(Message request, com.rabbitmq.client.Channel channel, ThrowableSE t, ObjectSE source) protected voidMessagingMessageListenerAdapter.asyncFailure(Message request, com.rabbitmq.client.Channel channel, ThrowableSE t, ObjectSE source) protected ObjectSE[]MessageListenerAdapter.buildListenerArguments(ObjectSE extractedMessage, com.rabbitmq.client.Channel channel, Message message) ターゲットリスナーメソッドに渡される引数の配列を作成します。protected voidAbstractAdaptableMessageListener.doHandleResult(InvocationResult resultArg, Message request, com.rabbitmq.client.Channel channel, ObjectSE source) protected voidAbstractAdaptableMessageListener.doPublish(com.rabbitmq.client.Channel channel, Address replyTo, Message message) protected ObjectSEAbstractAdaptableMessageListener.extractMessage(Message message) 指定された Rabbit メッセージからメッセージ本文を抽出します。protected ObjectSEMessagingMessageListenerAdapter.MessagingMessageConverterAdapter.extractPayload(Message message) protected StringSEMessageListenerAdapter.getListenerMethodName(Message originalMessage, ObjectSE extractedMessage) 指定されたメッセージを処理するリスナーメソッドの名前を決定します。protected StringSEAbstractAdaptableMessageListener.getReceivedExchange(Message request) protected AddressAbstractAdaptableMessageListener.getReplyToAddress(Message request, ObjectSE source, InvocationResult result) 指定されたメッセージの返信先アドレスを決定します。protected voidAbstractAdaptableMessageListener.handleResult(InvocationResult resultArg, Message request, com.rabbitmq.client.Channel channel) リスナメソッドから返された結果オブジェクトを処理し、レスポンスメッセージを送り返します。protected voidAbstractAdaptableMessageListener.handleResult(InvocationResult resultArg, Message request, com.rabbitmq.client.Channel channel, ObjectSE source) リスナメソッドから返された結果オブジェクトを処理し、レスポンスメッセージを送り返します。protected voidMessagingMessageListenerAdapter.invokeHandlerAndProcessResult(Message amqpMessage, com.rabbitmq.client.Channel channel, Message<?> message) protected ObjectSEMessageListenerAdapter.invokeListenerMethod(StringSE methodName, ObjectSE[] arguments, Message originalMessage) 指定されたリスナーメソッドを呼び出します。voidSpringChannelAwareMessageListenerエントリポイント。voidprotected voidAbstractAdaptableMessageListener.postProcessChannel(com.rabbitmq.client.Channel channel, Message response) レスポンスを送信する前に、指定されたメッセージを後処理します。protected voidAbstractAdaptableMessageListener.postProcessResponse(Message request, Message response) 指定されたレスポンスメッセージを送信する前に後処理します。protected voidAbstractAdaptableMessageListener.sendResponse(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, com.rabbitmq.client.Channel channel) 型 Message のパラメーターを持つ org.springframework.amqp.rabbit.listener.adapter のコンストラクターorg.springframework.amqp.rabbit.listener.api 内の Message 使用
型 Message のパラメーターを持つ org.springframework.amqp.rabbit.listener.api のメソッド修飾子と型メソッド説明default ObjectSERabbitListenerErrorHandler.handleError(Message amqpMessage, com.rabbitmq.client.Channel channel, Message<?> message, ListenerExecutionFailedException exception) エラーを処理します。RabbitListenerErrorHandler.handleError(Message amqpMessage, Message<?> message, ListenerExecutionFailedException exception) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。default voiddefault voidvoid受信した Rabbit メッセージを処理するためのコールバック。型 Message の型引数を持つ org.springframework.amqp.rabbit.listener.api のメソッドパラメーター修飾子と型メソッド説明voidChannelAwareBatchMessageListener.onMessageBatch(ListSE<Message> messages, com.rabbitmq.client.Channel channel) default voidChannelAwareMessageListener.onMessageBatch(ListSE<Message> messages, 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, ThrowableSE cause) サブクラスは、このメソッドをオーバーライドして、再発行されたメッセージにヘッダーを追加できます。protected voidメッセージを送信します。protected voidRepublishMessageRecovererWithConfirms.doSend(StringSE exchange, StringSE routingKey, Message message) 再配信時に繰り返し可能なメッセージの一意のキーを生成します。booleanメッセージをクエリして、それが以前に表示されたかどうかを確認します。protected StringSERepublishMessageRecoverer.prefixedOriginalRoutingKey(Message message) このメソッドのデフォルトの動作は、受信したルーティングキーをroutingKeyPrefixに追加することです。voidImmediateRequeueMessageRecoverer.recover(Message message, ThrowableSE cause) default voidMessageBatchRecoverer.recover(Message message, ThrowableSE cause) voidMessageRecoverer.recover(Message message, ThrowableSE cause) 消費されましたがすべての再試行に失敗したメッセージのコールバック。voidRejectAndDontRequeueRecoverer.recover(Message message, ThrowableSE cause) voidRepublishMessageRecoverer.recover(Message message, 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 のメソッド型 Message のパラメーターを持つ org.springframework.amqp.rabbit.support のコンストラクター修飾子コンストラクター説明ListenerExecutionFailedException(StringSE msg, ThrowableSE cause, Message... failedMessage) ListenerExecutionFailedException のコンストラクター。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 destination) org.springframework.amqp.rabbit.test 内の Message 使用
Message を返す org.springframework.amqp.rabbit.test のメソッド修飾子と型メソッド説明protected MessageTestRabbitTemplate.doSendAndReceiveWithFixed(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) 型 Message のパラメーターを持つ org.springframework.amqp.rabbit.test のメソッド修飾子と型メソッド説明protected MessageTestRabbitTemplate.doSendAndReceiveWithFixed(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) protected voidTestRabbitTemplate.sendToRabbit(com.rabbitmq.client.Channel channel, StringSE exchange, StringSE routingKey, boolean mandatory, Message message) org.springframework.amqp.support 内の Message 使用
Message を返す org.springframework.amqp.support のメソッド修飾子と型メソッド説明static MessageSendRetryContextAccessor.getMessage(org.springframework.retry.RetryContext context) コンテキストからMessageを取得します。org.springframework.amqp.support.converter 内の Message 使用
修飾子と型メソッド説明protected MessageAbstractJackson2MessageConverter.createMessage(ObjectSE objectToConvert, MessageProperties messageProperties) protected MessageAbstractJackson2MessageConverter.createMessage(ObjectSE objectToConvert, MessageProperties messageProperties, TypeSE genericType) protected abstract MessageAbstractMessageConverter.createMessage(ObjectSE object, MessageProperties messageProperties) 指定されたペイロードオブジェクトとメッセージプロパティからメッセージを作成します。protected MessageAbstractMessageConverter.createMessage(ObjectSE object, MessageProperties messageProperties, 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, MessageProperties messageProperties) final MessageAbstractMessageConverter.toMessage(ObjectSE object, MessageProperties messagePropertiesArg, TypeSE genericType) ContentTypeDelegatingMessageConverter.toMessage(ObjectSE object, MessageProperties messageProperties) MessageConverter.toMessage(ObjectSE object, MessageProperties messageProperties) Java オブジェクトをメッセージに変換します。default MessageMessageConverter.toMessage(ObjectSE object, MessageProperties messageProperties, TypeSE genericType) Java オブジェクトをメッセージに変換します。MessagingMessageConverter.toMessage(ObjectSE object, MessageProperties messageProperties) RemoteInvocationAwareMessageConverterAdapter.toMessage(ObjectSE object, MessageProperties messageProperties) 型 Message のパラメーターを持つ org.springframework.amqp.support.converter のメソッド修飾子と型メソッド説明protected ObjectSEMessagingMessageConverter.extractPayload(Message message) 指定されたMessageのペイロードを抽出します。AbstractJackson2MessageConverter.fromMessage(Message message) AbstractJackson2MessageConverter.fromMessage(Message message, 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, 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 のメソッド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)
RabbitListenerErrorHandler.handleError(Message, Channel, org.springframework.messaging.Message, ListenerExecutionFailedException)を推奨