src/main/java/org/onap/dmaap/mmagent/CreateMirrorMaker.java

   1 /*******************************************************************************
   2  *  ============LICENSE_START=======================================================
   3  *  org.onap.dmaap
   4  *  ================================================================================
   5  *  Copyright © 2017 AT&T Intellectual Property. All rights reserved.
   6  *  ================================================================================
   7  *  Licensed under the Apache License, Version 2.0 (the "License");
   8  *  you may not use this file except in compliance with the License.
   9  *  You may obtain a copy of the License at
  10  *        http://www.apache.org/licenses/LICENSE-2.0
  11 *
  12  *  Unless required by applicable law or agreed to in writing, software
  13  *  distributed under the License is distributed on an "AS IS" BASIS,
  14  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  *  See the License for the specific language governing permissions and
  16  *  limitations under the License.
  17  *  ============LICENSE_END=========================================================
  18  *
  19  *  ECOMP is a trademark and service mark of AT&T Intellectual Property.
  20  *
  21  *******************************************************************************/
  22  package org.onap.dmaap.mmagent;
  23
  24 import java.util.Date;
  25
  26 import org.apache.http.HttpStatus;
  27 import org.json.JSONObject;
  28
  29 import org.onap.dmaap.dmf.mr.CambriaApiException;
  30 import  org.onap.dmaap.dmf.mr.exception.DMaaPResponseCode;
  31 import  org.onap.dmaap.dmf.mr.exception.ErrorResponse;
  32 import  org.onap.dmaap.dmf.mr.utils.Utils;
  33
  34 public class CreateMirrorMaker {
  35         String messageID;
  36         MirrorMaker createMirrorMaker;
  37
  38         public MirrorMaker getCreateMirrorMaker() {
  39                 return createMirrorMaker;
  40         }
  41
  42         public void setCreateMirrorMaker(MirrorMaker createMirrorMaker) throws CambriaApiException {
  43                 this.createMirrorMaker = createMirrorMaker;
  44         }
  45
  46         public String getMessageID() {
  47                 return messageID;
  48         }
  49
  50         public void setMessageID(String messageID) {
  51                 this.messageID = messageID;
  52         }
  53         public void validateJSON() throws CambriaApiException
  54         {
  55                 ErrorResponse errRes = new ErrorResponse(HttpStatus.SC_BAD_REQUEST,
  56                                 DMaaPResponseCode.INCORRECT_JSON.getResponseCode(), "", null, Utils.getFormattedDate(new Date()), null, null, null,
  57                                                 null,
  58                                 "");
  59                 if(null==this.createMirrorMaker.getConsumer())
  60                 {
  61                         errRes.setErrorMessage("Please provide Consumer host:port details");
  62                         throw new CambriaApiException(errRes);
  63                 }
  64                 if(null==this.createMirrorMaker.getProducer())
  65                 {
  66                         errRes.setErrorMessage("Please provide Producer host:port details");
  67                         throw new CambriaApiException(errRes);
  68                 }
  69                 if(this.createMirrorMaker.getNumStreams()<=0)
  70                 {
  71                         errRes.setErrorMessage("Please provide numStreams value");
  72                         throw new CambriaApiException(errRes);
  73                 }
  74
  75         }
  76 }