class AccountDetailKeyRepository {

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

		if (request.getRequestInfo().getAction().equalsIgnoreCase(Constants.ACTION_CREATE)) {
			message.put("accountdetailkey_create", request);
		} else {
			message.put("accountdetailkey_update", request);
		}
		accountDetailKeyQueueRepository.add(message);
	}

	@Autowired public  AccountDetailKeyRepository(AccountDetailKeyJdbcRepository accountDetailKeyJdbcRepository,
			MastersQueueRepository accountDetailKeyQueueRepository,
			FinancialConfigurationService financialConfigurationService,
			AccountDetailKeyESRepository accountDetailKeyESRepository,
			@Value("${persist.through.kafka}") String persistThroughKafka);

}