class FunctionRepository {

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

		message.put("function_persisted", request);

		functionQueueRepository.addToSearch(message);
	}

	@Autowired public  FunctionRepository(FunctionJdbcRepository functionJdbcRepository,
			MastersQueueRepository functionQueueRepository, FinancialConfigurationService financialConfigurationService,
			FunctionESRepository functionESRepository, @Value("${persist.through.kafka}") String persistThroughKafka);

}