+ public void validateJSON() throws CambriaApiException
+ {
+ ErrorResponse errRes = new ErrorResponse(HttpStatus.SC_BAD_REQUEST,
+ DMaaPResponseCode.INCORRECT_JSON.getResponseCode(), "", null, Utils.getFormattedDate(new Date()), null, null, null,
+ null,
+ "");
+ if(null==this.createMirrorMaker.getConsumer())
+ {
+ errRes.setErrorMessage("Please provide Consumer host:port details");
+ throw new CambriaApiException(errRes);
+ }
+ if(null==this.createMirrorMaker.getProducer())
+ {
+ errRes.setErrorMessage("Please provide Producer host:port details");
+ throw new CambriaApiException(errRes);
+ }
+ if(this.createMirrorMaker.getNumStreams()<=0)
+ {
+ errRes.setErrorMessage("Please provide numStreams value");
+ throw new CambriaApiException(errRes);
+ }
+
+ }