@Test public void test_should_send_message_on_save() { final HashMap<String, Object> expectedMap = new HashMap<>(); final SevaRequest sevaRequest = new SevaRequest(); complaintMessageQueueRepository.save(sevaRequest); verify(kafkaTemplate).send(TOPIC_NAME, sevaRequest); }
public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest); }
ComplaintMessageQueueRepository { public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest); } }
ComplaintMessageQueueRepository { public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest); } ComplaintMessageQueueRepository(@Value("${kafka.topics.escalation.update.name}")
                                               String topicName,
                                           LogAwareKafkaTemplate<String, Object> kafkaTemplate); }
ComplaintMessageQueueRepository { public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest); } ComplaintMessageQueueRepository(@Value("${kafka.topics.escalation.update.name}")
                                               String topicName,
                                           LogAwareKafkaTemplate<String, Object> kafkaTemplate); void save(SevaRequest sevaRequest); }
ComplaintMessageQueueRepository { public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest); } ComplaintMessageQueueRepository(@Value("${kafka.topics.escalation.update.name}")
                                               String topicName,
                                           LogAwareKafkaTemplate<String, Object> kafkaTemplate); void save(SevaRequest sevaRequest);  }