@Test public void testAddToSearchQueue() { Mockito.doNothing().when(accountDetailKeyQueueRepository).add(Mockito.any()); AccountDetailKeyRequest request = new AccountDetailKeyRequest(); request.setRequestInfo(getRequestInfo()); request.setAccountDetailKeys(new ArrayList<AccountDetailKeyContract>()); request.getAccountDetailKeys().add(getAccountDetailKeyContract()); accountDetailKeyRepository.addToSearchQueue(request); Map<String, Object> message = new HashMap<>(); message.put("accountdetailkey_persisted", request); Mockito.verify(accountDetailKeyQueueRepository).addToSearch(message); }
public void addToSearchQueue(AccountDetailKeyRequest request) { Map<String, Object> message = new HashMap<>(); message.put("accountdetailkey_persisted", request); accountDetailKeyQueueRepository.addToSearch(message); }
AccountDetailKeyRepository { public void addToSearchQueue(AccountDetailKeyRequest request) { Map<String, Object> message = new HashMap<>(); message.put("accountdetailkey_persisted", request); accountDetailKeyQueueRepository.addToSearch(message); } }
AccountDetailKeyRepository { public void addToSearchQueue(AccountDetailKeyRequest request) { Map<String, Object> message = new HashMap<>(); message.put("accountdetailkey_persisted", request); accountDetailKeyQueueRepository.addToSearch(message); } @Autowired  AccountDetailKeyRepository(AccountDetailKeyJdbcRepository accountDetailKeyJdbcRepository,
			MastersQueueRepository accountDetailKeyQueueRepository,
			FinancialConfigurationService financialConfigurationService,
			AccountDetailKeyESRepository accountDetailKeyESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka); }
AccountDetailKeyRepository { public void addToSearchQueue(AccountDetailKeyRequest request) { Map<String, Object> message = new HashMap<>(); message.put("accountdetailkey_persisted", request); accountDetailKeyQueueRepository.addToSearch(message); } @Autowired  AccountDetailKeyRepository(AccountDetailKeyJdbcRepository accountDetailKeyJdbcRepository,
			MastersQueueRepository accountDetailKeyQueueRepository,
			FinancialConfigurationService financialConfigurationService,
			AccountDetailKeyESRepository accountDetailKeyESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka); @Transactional List<AccountDetailKey> save(List<AccountDetailKey> accountDetailKies, RequestInfo requestInfo); @Transactional List<AccountDetailKey> update(List<AccountDetailKey> accountDetailKies, RequestInfo requestInfo); void addToQue(AccountDetailKeyRequest request); void addToSearchQueue(AccountDetailKeyRequest request); AccountDetailKey findById(AccountDetailKey accountDetailKey); String getNextSequence(); @Transactional AccountDetailKey save(AccountDetailKey accountDetailKey); @Transactional AccountDetailKey update(AccountDetailKey accountDetailKey); void add(AccountDetailKeyRequest request); Pagination<AccountDetailKey> search(final AccountDetailKeySearch domain); boolean uniqueCheck(String fieldName, AccountDetailKey accountDetailKey); }
AccountDetailKeyRepository { public void addToSearchQueue(AccountDetailKeyRequest request) { Map<String, Object> message = new HashMap<>(); message.put("accountdetailkey_persisted", request); accountDetailKeyQueueRepository.addToSearch(message); } @Autowired  AccountDetailKeyRepository(AccountDetailKeyJdbcRepository accountDetailKeyJdbcRepository,
			MastersQueueRepository accountDetailKeyQueueRepository,
			FinancialConfigurationService financialConfigurationService,
			AccountDetailKeyESRepository accountDetailKeyESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka); @Transactional List<AccountDetailKey> save(List<AccountDetailKey> accountDetailKies, RequestInfo requestInfo); @Transactional List<AccountDetailKey> update(List<AccountDetailKey> accountDetailKies, RequestInfo requestInfo); void addToQue(AccountDetailKeyRequest request); void addToSearchQueue(AccountDetailKeyRequest request); AccountDetailKey findById(AccountDetailKey accountDetailKey); String getNextSequence(); @Transactional AccountDetailKey save(AccountDetailKey accountDetailKey); @Transactional AccountDetailKey update(AccountDetailKey accountDetailKey); void add(AccountDetailKeyRequest request); Pagination<AccountDetailKey> search(final AccountDetailKeySearch domain); boolean uniqueCheck(String fieldName, AccountDetailKey accountDetailKey);  }