@Test public void testAddToSearchQueue() { Mockito.doNothing().when(accountCodePurposeQueueRepository).add(Mockito.any()); AccountCodePurposeRequest request = new AccountCodePurposeRequest(); request.setRequestInfo(getRequestInfo()); request.setAccountCodePurposes(new ArrayList<AccountCodePurposeContract>()); request.getAccountCodePurposes().add(getAccountCodePurposeContract()); accountCodePurposeRepository.addToSearchQueue(request); Map<String, Object> message = new HashMap<>(); message.put("accountcodepurpose_persisted", request); Mockito.verify(accountCodePurposeQueueRepository).addToSearch(message); }
public void addToSearchQueue(AccountCodePurposeRequest request) { Map<String, Object> message = new HashMap<>(); message.put("accountcodepurpose_persisted", request); accountCodePurposeQueueRepository.addToSearch(message); }
AccountCodePurposeRepository { public void addToSearchQueue(AccountCodePurposeRequest request) { Map<String, Object> message = new HashMap<>(); message.put("accountcodepurpose_persisted", request); accountCodePurposeQueueRepository.addToSearch(message); } }
AccountCodePurposeRepository { public void addToSearchQueue(AccountCodePurposeRequest request) { Map<String, Object> message = new HashMap<>(); message.put("accountcodepurpose_persisted", request); accountCodePurposeQueueRepository.addToSearch(message); } @Autowired  AccountCodePurposeRepository(AccountCodePurposeJdbcRepository accountCodePurposeJdbcRepository,
			MastersQueueRepository accountCodePurposeQueueRepository,
			FinancialConfigurationService financialConfigurationService,
			AccountCodePurposeESRepository accountCodePurposeESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka); }
AccountCodePurposeRepository { public void addToSearchQueue(AccountCodePurposeRequest request) { Map<String, Object> message = new HashMap<>(); message.put("accountcodepurpose_persisted", request); accountCodePurposeQueueRepository.addToSearch(message); } @Autowired  AccountCodePurposeRepository(AccountCodePurposeJdbcRepository accountCodePurposeJdbcRepository,
			MastersQueueRepository accountCodePurposeQueueRepository,
			FinancialConfigurationService financialConfigurationService,
			AccountCodePurposeESRepository accountCodePurposeESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka); AccountCodePurpose findById(AccountCodePurpose accountCodePurpose); String getNextSequence(); @Transactional AccountCodePurpose save(AccountCodePurpose accountCodePurpose); @Transactional AccountCodePurpose update(AccountCodePurpose accountCodePurpose); @Transactional List<AccountCodePurpose> save(List<AccountCodePurpose> accountCodePurposes, RequestInfo requestInfo); @Transactional List<AccountCodePurpose> update(List<AccountCodePurpose> accountCodePurposes, RequestInfo requestInfo); void add(AccountCodePurposeRequest request); Pagination<AccountCodePurpose> search(AccountCodePurposeSearch domain); void uniqueCheck(AccountCodePurpose accountCodePurpose); Boolean uniqueCheck(String fieldName, AccountCodePurpose accountCodePurpose); void addToQue(AccountCodePurposeRequest request); void addToSearchQueue(AccountCodePurposeRequest request); }
AccountCodePurposeRepository { public void addToSearchQueue(AccountCodePurposeRequest request) { Map<String, Object> message = new HashMap<>(); message.put("accountcodepurpose_persisted", request); accountCodePurposeQueueRepository.addToSearch(message); } @Autowired  AccountCodePurposeRepository(AccountCodePurposeJdbcRepository accountCodePurposeJdbcRepository,
			MastersQueueRepository accountCodePurposeQueueRepository,
			FinancialConfigurationService financialConfigurationService,
			AccountCodePurposeESRepository accountCodePurposeESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka); AccountCodePurpose findById(AccountCodePurpose accountCodePurpose); String getNextSequence(); @Transactional AccountCodePurpose save(AccountCodePurpose accountCodePurpose); @Transactional AccountCodePurpose update(AccountCodePurpose accountCodePurpose); @Transactional List<AccountCodePurpose> save(List<AccountCodePurpose> accountCodePurposes, RequestInfo requestInfo); @Transactional List<AccountCodePurpose> update(List<AccountCodePurpose> accountCodePurposes, RequestInfo requestInfo); void add(AccountCodePurposeRequest request); Pagination<AccountCodePurpose> search(AccountCodePurposeSearch domain); void uniqueCheck(AccountCodePurpose accountCodePurpose); Boolean uniqueCheck(String fieldName, AccountCodePurpose accountCodePurpose); void addToQue(AccountCodePurposeRequest request); void addToSearchQueue(AccountCodePurposeRequest request);  }