class 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 public  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);

}