add test cases after the kafka 11 upgrade changes

[dmaap/messagerouter/messageservice.git] / src / main / java / com / att / nsa / dmaap / mmagent / CreateMirrorMaker.java

diff --git a/src/main/java/com/att/nsa/dmaap/mmagent/CreateMirrorMaker.java b/src/main/java/com/att/nsa/dmaap/mmagent/CreateMirrorMaker.java
index 92aca38..4007b17 100644 (file)
--- a/src/main/java/com/att/nsa/dmaap/mmagent/CreateMirrorMaker.java
+++ b/src/main/java/com/att/nsa/dmaap/mmagent/CreateMirrorMaker.java
@@ -8,19 +8,29 @@
  *  you may not use this file except in compliance with the License.
  *  You may obtain a copy of the License at
  *        http://www.apache.org/licenses/LICENSE-2.0
- *  
+*  
  *  Unless required by applicable law or agreed to in writing, software
  *  distributed under the License is distributed on an "AS IS" BASIS,
  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  *  ============LICENSE_END=========================================================
- *
+ *  
  *  ECOMP is a trademark and service mark of AT&T Intellectual Property.
  *  
  *******************************************************************************/
 package com.att.nsa.dmaap.mmagent;
 
+import java.util.Date;
+
+import org.apache.http.HttpStatus;
+import org.json.JSONObject;
+
+import com.att.dmf.mr.CambriaApiException;
+import com.att.dmf.mr.exception.DMaaPResponseCode;
+import com.att.dmf.mr.exception.ErrorResponse;
+import com.att.dmf.mr.utils.Utils;
+
 public class CreateMirrorMaker {
        String messageID;
        MirrorMaker createMirrorMaker;
@@ -29,7 +39,7 @@ public class CreateMirrorMaker {
                return createMirrorMaker;
        }
 
-       public void setCreateMirrorMaker(MirrorMaker createMirrorMaker) {
+       public void setCreateMirrorMaker(MirrorMaker createMirrorMaker) throws CambriaApiException {
                this.createMirrorMaker = createMirrorMaker;
        }
 
@@ -40,4 +50,27 @@ public class CreateMirrorMaker {
        public void setMessageID(String messageID) {
                this.messageID = messageID;
        }
+       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);
+               }
+               
+       }
 }