class WorkflowRepository {

	public void saveMarriageRegn(MarriageRegnRequest marriageRegnRequest, String stateId) {
		log.info("WorkflowRepository saveMarriageRegn marriageRegnRequest"+marriageRegnRequest);
		marriageRegnRequest.getMarriageRegn().setStateId(stateId);
		try {
			kafkaTemplate.send(propertiesManager.getCreateMarriageRegnTopicName(), marriageRegnRequest);
		} catch (Exception exception) {
			log.info("AgreementService : " + exception.getMessage(), exception);
			throw exception;
		}
	}

}