@Test public void test_should_send_message_to_kafka() { final SevaRequest sevaRequest = new SevaRequest(new RequestInfo(), null); serviceRequestMessageQueueRepository.save(sevaRequest); verify(kafkaTemplate).send(TOPIC_NAME, sevaRequest); }
public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest); }
ServiceRequestMessageQueueRepository { public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest); } }
ServiceRequestMessageQueueRepository { public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest); } @Autowired  ServiceRequestMessageQueueRepository(LogAwareKafkaTemplate<String, Object> kafkaTemplate,
                                                @Value("${outgoing.queue.name}") String topicName); }
ServiceRequestMessageQueueRepository { public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest); } @Autowired  ServiceRequestMessageQueueRepository(LogAwareKafkaTemplate<String, Object> kafkaTemplate,
                                                @Value("${outgoing.queue.name}") String topicName); void save(SevaRequest sevaRequest); }
ServiceRequestMessageQueueRepository { public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest); } @Autowired  ServiceRequestMessageQueueRepository(LogAwareKafkaTemplate<String, Object> kafkaTemplate,
                                                @Value("${outgoing.queue.name}") String topicName); void save(SevaRequest sevaRequest);  }