クラス StreamMessageListenerAdapter
java.lang.ObjectSE
org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
org.springframework.rabbit.stream.listener.adapter.StreamMessageListenerAdapter
- 実装されたすべてのインターフェース:
MessageListener、ChannelAwareMessageListener、StreamMessageListener
public class StreamMessageListenerAdapter
extends MessagingMessageListenerAdapter
implements StreamMessageListener
ネイティブストリームメッセージを受信するリスナーアダプター。
- 導入:
- 2.4
- 作成者:
- Gary Russell
ネストされたクラスのサマリー
クラス org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter から継承されたネストクラス / インターフェース
MessagingMessageListenerAdapter.MessagingMessageConverterAdapterクラス org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener から継承されたネストクラス / インターフェース
AbstractAdaptableMessageListener.ReplyExpressionRootフィールドサマリー
クラス org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener から継承されたフィールド
loggerコンストラクターのサマリー
コンストラクターコンストラクター説明StreamMessageListenerAdapter(ObjectSE bean, MethodSE method, boolean returnExceptions, RabbitListenerErrorHandler errorHandler) 提供された引数を使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明voidonStreamMessage(com.rabbitmq.stream.Message message, com.rabbitmq.stream.MessageHandler.Context context) メッセージを処理します。クラス org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter から継承されたメソッド
asyncFailure, buildMessage, getHandlerAdapter, getMessagingMessageConverter, invokeHandlerAndProcessResult, isAsyncReplies, onMessage, setHandlerAdapter, setHeaderMapper, setMessageConverter, toMessagingMessageクラス org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener から継承されたメソッド
containerAckMode, convert, doHandleResult, doPublish, extractMessage, getEncoding, getMessageConverter, getReceivedExchange, getReplyContentType, getReplyToAddress, handleListenerException, handleResult, handleResult, isConverterWinsContentType, postProcessChannel, postProcessResponse, sendResponse, setBeanResolver, setBeforeSendReplyPostProcessors, setConverterWinsContentType, setDefaultRequeueRejected, setEncoding, setMandatoryPublish, setRecoveryCallback, setReplyContentType, setReplyPostProcessor, setResponseAddress, setResponseExchange, setResponseRoutingKey, setRetryTemplateクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener から継承されたメソッド
onMessage, onMessageBatchインターフェース org.springframework.amqp.core.MessageListener から継承されたメソッド
containerAckMode, isAsyncReplies, onMessageBatch
コンストラクターの詳細
StreamMessageListenerAdapter
public StreamMessageListenerAdapter(ObjectSE bean, MethodSE method, boolean returnExceptions, RabbitListenerErrorHandler errorHandler) 提供された引数を使用してインスタンスを構築します。- パラメーター:
bean- Bean。method- メソッド。returnExceptions- 例外を返す場合は true。errorHandler- エラーハンドラー。
メソッドの詳細
onStreamMessage
public void onStreamMessage(com.rabbitmq.stream.Message message, com.rabbitmq.stream.MessageHandler.Context context) インターフェースからコピーされた説明:StreamMessageListenerメッセージを処理します。- 次で指定:
- インターフェース
StreamMessageListenerのonStreamMessage - パラメーター:
message- メッセージ。context- ストリームコンテキスト。