@Test public void testAddToSearchQueue() { Mockito.doNothing().when(bankBranchQueueRepository).add(Mockito.any()); BankBranchRequest request = new BankBranchRequest(); request.setRequestInfo(getRequestInfo()); request.setBankBranches(new ArrayList<BankBranchContract>()); request.getBankBranches().add(getBankBranchContract()); bankBranchRepository.addToSearchQueue(request); Map<String, Object> message = new HashMap<>(); message.put("bankbranch_persisted", request); Mockito.verify(bankBranchQueueRepository).addToSearch(message); }
public void addToSearchQueue(BankBranchRequest request) { Map<String, Object> message = new HashMap<>(); message.put("bankbranch_persisted", request); bankBranchQueueRepository.addToSearch(message); }
BankBranchRepository { public void addToSearchQueue(BankBranchRequest request) { Map<String, Object> message = new HashMap<>(); message.put("bankbranch_persisted", request); bankBranchQueueRepository.addToSearch(message); } }
BankBranchRepository { public void addToSearchQueue(BankBranchRequest request) { Map<String, Object> message = new HashMap<>(); message.put("bankbranch_persisted", request); bankBranchQueueRepository.addToSearch(message); } @Autowired  BankBranchRepository(BankBranchJdbcRepository bankBranchJdbcRepository,
			MastersQueueRepository bankBranchQueueRepository,
			FinancialConfigurationService financialConfigurationService, BankBranchESRepository bankBranchESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka); }
BankBranchRepository { public void addToSearchQueue(BankBranchRequest request) { Map<String, Object> message = new HashMap<>(); message.put("bankbranch_persisted", request); bankBranchQueueRepository.addToSearch(message); } @Autowired  BankBranchRepository(BankBranchJdbcRepository bankBranchJdbcRepository,
			MastersQueueRepository bankBranchQueueRepository,
			FinancialConfigurationService financialConfigurationService, BankBranchESRepository bankBranchESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka); BankBranch findById(BankBranch bankBranch); String getNextSequence(); @Transactional List<BankBranch> save(List<BankBranch> bankBranches, RequestInfo requestInfo); @Transactional List<BankBranch> update(List<BankBranch> bankBranches, RequestInfo requestInfo); @Transactional BankBranch save(BankBranch bankBranch); @Transactional BankBranch update(BankBranch bankBranch); void add(BankBranchRequest request); Pagination<BankBranch> search(BankBranchSearch domain); void addToQue(BankBranchRequest request); void addToSearchQueue(BankBranchRequest request); boolean uniqueCheck(String fieldName, BankBranch bankBranch); }
BankBranchRepository { public void addToSearchQueue(BankBranchRequest request) { Map<String, Object> message = new HashMap<>(); message.put("bankbranch_persisted", request); bankBranchQueueRepository.addToSearch(message); } @Autowired  BankBranchRepository(BankBranchJdbcRepository bankBranchJdbcRepository,
			MastersQueueRepository bankBranchQueueRepository,
			FinancialConfigurationService financialConfigurationService, BankBranchESRepository bankBranchESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka); BankBranch findById(BankBranch bankBranch); String getNextSequence(); @Transactional List<BankBranch> save(List<BankBranch> bankBranches, RequestInfo requestInfo); @Transactional List<BankBranch> update(List<BankBranch> bankBranches, RequestInfo requestInfo); @Transactional BankBranch save(BankBranch bankBranch); @Transactional BankBranch update(BankBranch bankBranch); void add(BankBranchRequest request); Pagination<BankBranch> search(BankBranchSearch domain); void addToQue(BankBranchRequest request); void addToSearchQueue(BankBranchRequest request); boolean uniqueCheck(String fieldName, BankBranch bankBranch);  }