@Test public void test_should_push_create_serviceCharge_to_queue() { when(applicationProperties.getCreateServiceChargeTopicName()).thenReturn("egov.wcms.servicecharge-create"); serviceChargeRepository.pushCreateToQueue(getServiceChargeRequest()); verify(kafkaTemplate).send("egov.wcms.servicecharge-create", getServiceChargeRequest()); }
public List<ServiceCharge> pushCreateToQueue(final ServiceChargeReq serviceChargeRequest) { logger.info("Pushing ServiceChargeCreateRequest to queue"); try { kafkaTemplate.send(applicationProperties.getCreateServiceChargeTopicName(), serviceChargeRequest); } catch (final Exception e) { logger.error("Exception Encountered :" + e); } return serviceChargeRequest.getServiceCharge(); }
ServiceChargeRepository { public List<ServiceCharge> pushCreateToQueue(final ServiceChargeReq serviceChargeRequest) { logger.info("Pushing ServiceChargeCreateRequest to queue"); try { kafkaTemplate.send(applicationProperties.getCreateServiceChargeTopicName(), serviceChargeRequest); } catch (final Exception e) { logger.error("Exception Encountered :" + e); } return serviceChargeRequest.getServiceCharge(); } }
ServiceChargeRepository { public List<ServiceCharge> pushCreateToQueue(final ServiceChargeReq serviceChargeRequest) { logger.info("Pushing ServiceChargeCreateRequest to queue"); try { kafkaTemplate.send(applicationProperties.getCreateServiceChargeTopicName(), serviceChargeRequest); } catch (final Exception e) { logger.error("Exception Encountered :" + e); } return serviceChargeRequest.getServiceCharge(); }  }
ServiceChargeRepository { public List<ServiceCharge> pushCreateToQueue(final ServiceChargeReq serviceChargeRequest) { logger.info("Pushing ServiceChargeCreateRequest to queue"); try { kafkaTemplate.send(applicationProperties.getCreateServiceChargeTopicName(), serviceChargeRequest); } catch (final Exception e) { logger.error("Exception Encountered :" + e); } return serviceChargeRequest.getServiceCharge(); }  @SuppressWarnings("unchecked") ServiceChargeReq create(final ServiceChargeReq serviceChargeRequest); @SuppressWarnings("unchecked") ServiceChargeReq update(final ServiceChargeReq serviceChargeRequest); List<ServiceCharge> pushCreateToQueue(final ServiceChargeReq serviceChargeRequest); List<ServiceCharge> pushUpdateToQueue(final ServiceChargeReq serviceChargeRequest); List<ServiceCharge> searchServiceChargesByCriteria(final ServiceChargeGetRequest serviceChargeGetRequest); List<ServiceCharge> convertToModel(final List<ServiceCharge> listOfServiceChargesFromDB,
            final List<ServiceChargeDetails> serviceChargeDetails); }
ServiceChargeRepository { public List<ServiceCharge> pushCreateToQueue(final ServiceChargeReq serviceChargeRequest) { logger.info("Pushing ServiceChargeCreateRequest to queue"); try { kafkaTemplate.send(applicationProperties.getCreateServiceChargeTopicName(), serviceChargeRequest); } catch (final Exception e) { logger.error("Exception Encountered :" + e); } return serviceChargeRequest.getServiceCharge(); }  @SuppressWarnings("unchecked") ServiceChargeReq create(final ServiceChargeReq serviceChargeRequest); @SuppressWarnings("unchecked") ServiceChargeReq update(final ServiceChargeReq serviceChargeRequest); List<ServiceCharge> pushCreateToQueue(final ServiceChargeReq serviceChargeRequest); List<ServiceCharge> pushUpdateToQueue(final ServiceChargeReq serviceChargeRequest); List<ServiceCharge> searchServiceChargesByCriteria(final ServiceChargeGetRequest serviceChargeGetRequest); List<ServiceCharge> convertToModel(final List<ServiceCharge> listOfServiceChargesFromDB,
            final List<ServiceChargeDetails> serviceChargeDetails); static final String TENANT; static final String SERVICECHARGE; static final Logger logger; }