class AccountEntityRepository {

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

        message.put("accountentity_persisted", request);

        accountEntityQueueRepository.addToSearch(message);
    }

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

}