@Test public void testAddToSearchQueue() { Mockito.doNothing().when(bankQueueRepository).add(Mockito.any()); BankRequest request = new BankRequest(); request.setRequestInfo(getRequestInfo()); request.setBanks(new ArrayList<BankContract>()); request.getBanks().add(getBankContract()); bankRepository.addToSearchQueue(request); Map<String, Object> message = new HashMap<>(); message.put("bank_persisted", request); Mockito.verify(bankQueueRepository).addToSearch(message); }
public void addToSearchQueue(BankRequest request) { Map<String, Object> message = new HashMap<>(); message.put("bank_persisted", request); bankQueueRepository.addToSearch(message); }
BankRepository { public void addToSearchQueue(BankRequest request) { Map<String, Object> message = new HashMap<>(); message.put("bank_persisted", request); bankQueueRepository.addToSearch(message); } }
BankRepository { public void addToSearchQueue(BankRequest request) { Map<String, Object> message = new HashMap<>(); message.put("bank_persisted", request); bankQueueRepository.addToSearch(message); } @Autowired  BankRepository(BankJdbcRepository bankJdbcRepository, MastersQueueRepository bankQueueRepository,
			FinancialConfigurationService financialConfigurationService, BankESRepository bankESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka); }
BankRepository { public void addToSearchQueue(BankRequest request) { Map<String, Object> message = new HashMap<>(); message.put("bank_persisted", request); bankQueueRepository.addToSearch(message); } @Autowired  BankRepository(BankJdbcRepository bankJdbcRepository, MastersQueueRepository bankQueueRepository,
			FinancialConfigurationService financialConfigurationService, BankESRepository bankESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka); Bank findById(Bank bank); String getNextSequence(); @Transactional Bank save(Bank bank); @Transactional Bank update(Bank bank); void add(BankRequest request); Pagination<Bank> search(BankSearch domain); @Transactional List<Bank> save(List<Bank> banks, RequestInfo requestInfo); @Transactional List<Bank> update(List<Bank> banks, RequestInfo requestInfo); void addToQue(BankRequest request); void addToSearchQueue(BankRequest request); boolean uniqueCheck(String fieldName, Bank bank); }
BankRepository { public void addToSearchQueue(BankRequest request) { Map<String, Object> message = new HashMap<>(); message.put("bank_persisted", request); bankQueueRepository.addToSearch(message); } @Autowired  BankRepository(BankJdbcRepository bankJdbcRepository, MastersQueueRepository bankQueueRepository,
			FinancialConfigurationService financialConfigurationService, BankESRepository bankESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka); Bank findById(Bank bank); String getNextSequence(); @Transactional Bank save(Bank bank); @Transactional Bank update(Bank bank); void add(BankRequest request); Pagination<Bank> search(BankSearch domain); @Transactional List<Bank> save(List<Bank> banks, RequestInfo requestInfo); @Transactional List<Bank> update(List<Bank> banks, RequestInfo requestInfo); void addToQue(BankRequest request); void addToSearchQueue(BankRequest request); boolean uniqueCheck(String fieldName, Bank bank);  }