Class KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K, V, R>
java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>, KafkaProducerMessageHandler<K,V>>
org.springframework.integration.dsl.MessageHandlerSpec<KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>, KafkaProducerMessageHandler<K,V>>
org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec <K、V、KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec <K、V、R>>
org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec <K、V、R、KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec <K、V、R>>
org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>
- 型パラメーター:
K- 鍵の型。V- 送信値型。R- 応答値の型。
- 実装済みのインターフェース一覧:
DisposableBean, FactoryBean<KafkaProducerMessageHandler<K,V>>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration
- 含まれているクラス:
KafkaOutboundGatewaySpec<K, V, R, S extends KafkaOutboundGatewaySpec<K,V, R, S>>
public static class KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>
extends KafkaOutboundGatewaySpec<K, V, R, KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>>
implements ComponentsRegistration
KafkaTemplate ベースの KafkaProducerMessageHandlerSpec 拡張。- 導入:
- 5.4
- 作成者:
- Gary Russell
ネストされたクラスの概要
クラス KafkaOutboundGatewaySpec から継承されたネストクラス / インターフェース
KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V, R>, KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K, V, R> クラス KafkaProducerMessageHandlerSpec から継承されたネストクラス / インターフェース
KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> フィールド概要
クラス IntegrationComponentSpec から継承されたフィールド
logger, PARSER, targetインターフェース FactoryBean から継承されたフィールド
OBJECT_TYPE_ATTRIBUTEインターフェース SmartLifecycle から継承されたフィールド
DEFAULT_PHASE方法の概要
修飾子と型メソッド説明configureKafkaTemplate(ConsumerSE<KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K, V, R>> configurer) KafkaTemplateSpec引数を指定してConsumerSE コールバックを呼び出すことにより、Kafka テンプレートを構成します。クラス KafkaOutboundGatewaySpec から継承されたメソッド
assigmentDuration, replyMessageConverterクラス KafkaProducerMessageHandlerSpec から継承されたメソッド
flush, flushExpression, flushExpression, futuresChannel, futuresChannel, headerMapper, messageKey, messageKey, messageKeyExpression, messageKeyExpression, partitionId, partitionId, partitionIdExpression, partitionIdExpression, producerRecordCreator, sendFailureChannel, sendFailureChannel, sendSuccessChannel, sendSuccessChannel, sendTimeout, sync, timestamp, timestampExpression, timestampExpression, topic, topic, topicExpression, topicExpression, useTemplateConverterクラス IntegrationComponentSpec から継承されたメソッド
_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopクラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース FactoryBean から継承されたメソッド
isSingletonインターフェース SmartLifecycle から継承されたメソッド
isPauseable
方法の詳細
configureKafkaTemplate
public KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V, configureKafkaTemplateR> (ConsumerSE<KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K, V, R>> configurer) KafkaTemplateSpec引数を指定してConsumerSE コールバックを呼び出すことにより、Kafka テンプレートを構成します。- パラメーター:
configurer- コンフィギュレーター Java 8 Lambda。- 戻り値:
- スペック。
getComponentsToRegister
- 次で指定:
- インターフェース
ComponentsRegistration内のgetComponentsToRegister