class BankBranchQueueRepository {

	public void push(BankBranchContractRequest bankBranchContractRequest) {
		HashMap<String, Object> bankBranchContractRequestMap = new HashMap<String, Object>();

		if ("create".equalsIgnoreCase(bankBranchContractRequest.getRequestInfo().getAction()))
			bankBranchContractRequestMap.put("BankBranchCreate", bankBranchContractRequest);
		else if ("updateAll".equalsIgnoreCase(bankBranchContractRequest.getRequestInfo().getAction())
				|| "update".equalsIgnoreCase(bankBranchContractRequest.getRequestInfo().getAction()))
			bankBranchContractRequestMap.put("BankBranchUpdate", bankBranchContractRequest);

		financialProducer.sendMessage(bankBranchValidatedTopic, bankBranchValidatedKey, bankBranchContractRequestMap);
	}

	@Autowired public  BankBranchQueueRepository(FinancialProducer financialProducer,
			@Value("${kafka.topics.egf.masters.validated.topic}") String bankBranchValidatedTopic,
			@Value("${kafka.topics.egf.masters.bankbranch.validated.key}") String bankBranchValidatedKey);

}