class AccountEntityRepository {

    public void addToQue(AccountEntityRequest request) {
        Map<String, Object> message = new HashMap<>();

        if (request.getRequestInfo().getAction().equalsIgnoreCase(Constants.ACTION_CREATE)) {
            message.put("accountentity_create", request);
        } else {
            message.put("accountentity_update", request);
        }
        accountEntityQueueRepository.add(message);
    }

    @Autowired public  AccountEntityRepository(AccountEntityJdbcRepository accountEntityJdbcRepository,
                                   MastersQueueRepository accountEntityQueueRepository, FinancialConfigurationService financialConfigurationService,
                                   AccountEntityESRepository accountEntityESRepository, @Value("${persist.through.kafka}") String persistThroughKafka);

}