@Test public void test_should_send_message() { final HashMap<String, Object> sevaRequestMap = new HashMap<>(); final SevaRequest sevaRequest = new SevaRequest(sevaRequestMap); complaintRepository.save(sevaRequest); verify(kafkaTemplate).send("topicName", sevaRequestMap); }
public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest.getRequestMap()); }
ComplaintRepository { public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest.getRequestMap()); } }
ComplaintRepository { public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest.getRequestMap()); } @Autowired  ComplaintRepository(@Value("${kafka.topics.pgr.boundary_enriched.name}") String topicName,
                               LogAwareKafkaTemplate<String, Object> kafkaTemplate); }
ComplaintRepository { public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest.getRequestMap()); } @Autowired  ComplaintRepository(@Value("${kafka.topics.pgr.boundary_enriched.name}") String topicName,
                               LogAwareKafkaTemplate<String, Object> kafkaTemplate); void save(SevaRequest sevaRequest); }
ComplaintRepository { public void save(SevaRequest sevaRequest) { kafkaTemplate.send(topicName, sevaRequest.getRequestMap()); } @Autowired  ComplaintRepository(@Value("${kafka.topics.pgr.boundary_enriched.name}") String topicName,
                               LogAwareKafkaTemplate<String, Object> kafkaTemplate); void save(SevaRequest sevaRequest);  }