クラス ConvertingMessageListener<V>
java.lang.ObjectSE
org.springframework.kafka.listener.adapter.ConvertingMessageListener<V>
- 型パラメーター:
V
- 変換後の目的の値の型。
- 実装されたすべてのインターフェース:
AcknowledgingConsumerAwareMessageListener<ObjectSE,
、ObjectSE> DelegatingMessageListener<MessageListener>
、GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<ObjectSE,
、ObjectSE>> MessageListener<ObjectSE,
ObjectSE>
public class ConvertingMessageListener<V>
extends ObjectSE
implements DelegatingMessageListener<MessageListener>, AcknowledgingConsumerAwareMessageListener<ObjectSE,ObjectSE>
指定された
MessageConverter
を使用して受信した ConsumerRecord
の変換を実装し、結果を指定された MessageListener
に渡す AcknowledgingConsumerAwareMessageListener
アダプター。直接設定する場合、ヘッダーも KafkaHeaderMapper
の実装でマップし、実際に処理されるメッセージの一部としてコンバーターに渡すことができます。それ以外の場合、ヘッダーマッパーが指定されていない場合、コンバーターの観点からはヘッダーにアクセスできません。- 導入:
- 3.0
- 作成者:
- Adrian Chlebosz
- 関連事項:
コンストラクターのサマリー
コンストラクターコンストラクター説明ConvertingMessageListener
(MessageListener<?, V> delegateMessageListener, ClassSE<V> desiredValueType) メソッドのサマリー
修飾子と型メソッド説明代理人を返します。void
onMessage
(org.apache.kafka.clients.consumer.ConsumerRecord receivedRecord, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer consumer) kafka からのデータで呼び出され、Consumer
へのアクセスを提供します。void
setKafkaHeaderMapper
(KafkaHeaderMapper headerMapper) KafkaHeaderMapper
を設定します。void
setMessageConverter
(MessageConverter messageConverter) MessageConverter
を設定します。クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener から継承されたメソッド
onMessage
インターフェース org.springframework.kafka.listener.GenericMessageListener から継承されたメソッド
onMessage, onMessage
コンストラクターの詳細
ConvertingMessageListener
public ConvertingMessageListener(MessageListener<?, V> delegateMessageListener, ClassSE<V> desiredValueType) 提供されたMessageListener
およびClass
SE を、変換後のConsumerRecord
の値の目的の型として使用してインスタンスを構築します。MessageConverter
のデフォルト値であるGenericMessageConverter
が使用されます。- パラメーター:
delegateMessageListener
- 変換されたConsumerRecord
をさらに渡すときに使用するMessageListener
。desiredValueType
-Class
SE 設定ConsumerRecord
の値の必要な型。
メソッドの詳細
setMessageConverter
MessageConverter
を設定します。- パラメーター:
messageConverter
- 受信ConsumerRecord
の変換に使用するメッセージコンバーター。- 導入:
- 3.0
setKafkaHeaderMapper
KafkaHeaderMapper
を設定します。- パラメーター:
headerMapper
- 受信ConsumerRecord
のヘッダーのマッピングに使用するヘッダーマッパー。- 導入:
- 3.0
getDelegate
インターフェースからコピーされた説明:DelegatingMessageListener
代理人を返します。- 次で指定:
- インターフェース
DelegatingMessageListener<V>
のgetDelegate
- 戻り値:
- 代表者。
onMessage
public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord receivedRecord, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer consumer) インターフェースからコピーされた説明:GenericMessageListener
kafka からのデータで呼び出され、Consumer
へのアクセスを提供します。デフォルトの実装はUnsupportedOperationException
SE をスローします。- 次で指定:
- インターフェース
AcknowledgingConsumerAwareMessageListener<ObjectSE,
のObjectSE> onMessage
- 次で指定:
- インターフェース
GenericMessageListener<V>
のonMessage
- パラメーター:
receivedRecord
- 処理されるデータ。acknowledgment
- 承認。consumer
- コンシューマー。