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