class WorkflowRepository {

	public void updateMarriagRegn(MarriageRegnRequest marriageRegnRequest) {
		try {
			kafkaTemplate.send(propertiesManager.getUpdateMarriageRegnTopicName(), marriageRegnRequest);
		} catch (Exception exception) {
			log.info("MarriageRegnService : " + exception.getMessage(), exception);
			throw exception;
		}
	}

}