@Service public class KafkaDriverPublisher extends java.lang.Object implements java.util.function.Consumer<InboundDriverMessage>
Constructor and Description |
---|
KafkaDriverPublisher(org.springframework.kafka.core.KafkaTemplate<java.lang.Object,java.lang.Object> kafkaTemplateForJson,
java.lang.String topic) |
Modifier and Type | Method and Description |
---|---|
void |
accept(InboundDriverMessage driver) |
@Autowired public KafkaDriverPublisher(org.springframework.kafka.core.KafkaTemplate<java.lang.Object,java.lang.Object> kafkaTemplateForJson, @Value(value="${kafka.topic.from-driver}") java.lang.String topic)
public void accept(InboundDriverMessage driver)
accept
in interface java.util.function.Consumer<InboundDriverMessage>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.