class RecoveryRepository {

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

        message.put("recovery_persisted", request);

        recoveryQueueRepository.addToSearch(message);
    }

    @Autowired public  RecoveryRepository(MastersQueueRepository recoveryQueueRepository, FinancialConfigurationService financialConfigurationService,
                              @Value("${persist.through.kafka}") String persistThroughKafka,
                              RecoveryJdbcRepository recoveryJdbcRepository,
                              RecoveryESRepository recoveryESRepository);

}