@Test public void test_should_send_notifications() { final HashMap<String, Object> sevaRequestMap = new HashMap<>(); notificationListener.process(sevaRequestMap); verify(notificationService).notify(any(SevaRequest.class)); }
@KafkaListener(topics = "${consumer.topic}") public void process(HashMap<String, Object> sevaRequestMap) { final SevaRequest sevaRequest = new SevaRequest(sevaRequestMap); notificationService.notify(sevaRequest); }
NotificationListener { @KafkaListener(topics = "${consumer.topic}") public void process(HashMap<String, Object> sevaRequestMap) { final SevaRequest sevaRequest = new SevaRequest(sevaRequestMap); notificationService.notify(sevaRequest); } }
NotificationListener { @KafkaListener(topics = "${consumer.topic}") public void process(HashMap<String, Object> sevaRequestMap) { final SevaRequest sevaRequest = new SevaRequest(sevaRequestMap); notificationService.notify(sevaRequest); } NotificationListener(NotificationService notificationService); }
NotificationListener { @KafkaListener(topics = "${consumer.topic}") public void process(HashMap<String, Object> sevaRequestMap) { final SevaRequest sevaRequest = new SevaRequest(sevaRequestMap); notificationService.notify(sevaRequest); } NotificationListener(NotificationService notificationService); @KafkaListener(topics = "${consumer.topic}") void process(HashMap<String, Object> sevaRequestMap); }
NotificationListener { @KafkaListener(topics = "${consumer.topic}") public void process(HashMap<String, Object> sevaRequestMap) { final SevaRequest sevaRequest = new SevaRequest(sevaRequestMap); notificationService.notify(sevaRequest); } NotificationListener(NotificationService notificationService); @KafkaListener(topics = "${consumer.topic}") void process(HashMap<String, Object> sevaRequestMap);  }