Class KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>>
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,H>
org.springframework.integration.dsl.MessageHandlerSpec<S,KafkaProducerMessageHandler<K,V>>
org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec<K,V,S>
org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec<K,V,R,S>
- Type Parameters:
K
- the key type.V
- the outbound value type.R
- the reply value type.S
- theKafkaProducerMessageHandlerSpec
extension type.
- All Implemented Interfaces:
Aware
,BeanClassLoaderAware
,BeanFactoryAware
,DisposableBean
,FactoryBean<KafkaProducerMessageHandler<K,V>>
,InitializingBean
,Lifecycle
,Phased
,SmartLifecycle
- Direct Known Subclasses:
KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec
public class KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>> extends KafkaProducerMessageHandlerSpec<K,V,S>
A
MessageHandlerSpec
implementation for the KafkaProducerMessageHandler
as a gateway.- Since:
- 5.4
- Author:
- Gary Russell
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R>
AKafkaTemplate
-basedKafkaProducerMessageHandlerSpec
extension.static class
KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R>
AnIntegrationComponentSpec
implementation for theKafkaTemplate
.Nested classes/interfaces inherited from class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec
KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>
-
Field Summary
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
PARSER, target
-
Method Summary
Modifier and Type Method Description S
replyMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
Set a message converter for replies (when a gateway).Methods inherited from class org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec
flush, flushExpression, flushExpression, futuresChannel, futuresChannel, headerMapper, messageKey, messageKey, messageKeyExpression, messageKeyExpression, partitionId, partitionId, partitionIdExpression, partitionIdExpression, sendFailureChannel, sendFailureChannel, sendSuccessChannel, sendSuccessChannel, sendTimeout, sync, timestamp, timestampExpression, timestampExpression, topic, topic, topicExpression, topicExpression
Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
-
Method Details
-
replyMessageConverter
public S replyMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)Set a message converter for replies (when a gateway).- Parameters:
messageConverter
- the converter.- Returns:
- the spec.
-