@Test public void test_add_to_search_queue() { final BudgetReAppropriationRequest request = new BudgetReAppropriationRequest(); request.setBudgetReAppropriations(getBudgetReAppropriations()); budgetReAppropriationQueueRepository.addToSearchQue(request); final ArgumentCaptor<HashMap> argumentCaptor = ArgumentCaptor.forClass(HashMap.class); verify(financialProducer).sendMessage(any(String.class), any(String.class), argumentCaptor.capture()); final HashMap<String, Object> actualRequest = argumentCaptor.getValue(); assertEquals(request, actualRequest.get("budgetreappropriation_persisted")); }
public void addToSearchQue(final BudgetReAppropriationRequest request) { final HashMap<String, Object> topicMap = new HashMap<String, Object>(); if (!request.getBudgetReAppropriations().isEmpty()) { topicMap.put("budgetreappropriation_persisted", request); System.out.println("push search topic" + request); } financialProducer.sendMessage(completedTopic, budgetReAppCompletedKey, topicMap); }
BudgetReAppropriationQueueRepository { public void addToSearchQue(final BudgetReAppropriationRequest request) { final HashMap<String, Object> topicMap = new HashMap<String, Object>(); if (!request.getBudgetReAppropriations().isEmpty()) { topicMap.put("budgetreappropriation_persisted", request); System.out.println("push search topic" + request); } financialProducer.sendMessage(completedTopic, budgetReAppCompletedKey, topicMap); } }
BudgetReAppropriationQueueRepository { public void addToSearchQue(final BudgetReAppropriationRequest request) { final HashMap<String, Object> topicMap = new HashMap<String, Object>(); if (!request.getBudgetReAppropriations().isEmpty()) { topicMap.put("budgetreappropriation_persisted", request); System.out.println("push search topic" + request); } financialProducer.sendMessage(completedTopic, budgetReAppCompletedKey, topicMap); } @Autowired  BudgetReAppropriationQueueRepository(final FinancialProducer financialProducer,
            @Value("${kafka.topics.egf.budget.service.validated.topic}") final String validatedTopic,
            @Value("${kafka.topics.egf.budget.budgetreapp.validated.key}") final String budgetReAppValidatedKey,
            @Value("${kafka.topics.egf.budget.service.completed.topic}") final String completedTopic,
            @Value("${kafka.topics.egf.budget.budgetreapp.completed.key}") final String budgetReAppCompletedKey); }
BudgetReAppropriationQueueRepository { public void addToSearchQue(final BudgetReAppropriationRequest request) { final HashMap<String, Object> topicMap = new HashMap<String, Object>(); if (!request.getBudgetReAppropriations().isEmpty()) { topicMap.put("budgetreappropriation_persisted", request); System.out.println("push search topic" + request); } financialProducer.sendMessage(completedTopic, budgetReAppCompletedKey, topicMap); } @Autowired  BudgetReAppropriationQueueRepository(final FinancialProducer financialProducer,
            @Value("${kafka.topics.egf.budget.service.validated.topic}") final String validatedTopic,
            @Value("${kafka.topics.egf.budget.budgetreapp.validated.key}") final String budgetReAppValidatedKey,
            @Value("${kafka.topics.egf.budget.service.completed.topic}") final String completedTopic,
            @Value("${kafka.topics.egf.budget.budgetreapp.completed.key}") final String budgetReAppCompletedKey); void addToQue(final BudgetReAppropriationRequest request); void addToSearchQue(final BudgetReAppropriationRequest request); }
BudgetReAppropriationQueueRepository { public void addToSearchQue(final BudgetReAppropriationRequest request) { final HashMap<String, Object> topicMap = new HashMap<String, Object>(); if (!request.getBudgetReAppropriations().isEmpty()) { topicMap.put("budgetreappropriation_persisted", request); System.out.println("push search topic" + request); } financialProducer.sendMessage(completedTopic, budgetReAppCompletedKey, topicMap); } @Autowired  BudgetReAppropriationQueueRepository(final FinancialProducer financialProducer,
            @Value("${kafka.topics.egf.budget.service.validated.topic}") final String validatedTopic,
            @Value("${kafka.topics.egf.budget.budgetreapp.validated.key}") final String budgetReAppValidatedKey,
            @Value("${kafka.topics.egf.budget.service.completed.topic}") final String completedTopic,
            @Value("${kafka.topics.egf.budget.budgetreapp.completed.key}") final String budgetReAppCompletedKey); void addToQue(final BudgetReAppropriationRequest request); void addToSearchQue(final BudgetReAppropriationRequest request);  }