+ @Test
+ public void testcheckStartupWtOneParam() {
+ String parameters[] = { "test" };
+ mirrorMakerAgent.main(parameters);
+
+ }
+
+
+ @Test
+ public void testReadAgentTopics() {
+
+ agent.exitLoop = true;
+ agent.readAgentTopic();
+ }
+
+ @Test
+ public void testReadCreateMirrorMaker() throws Exception {
+
+ String topicMessage = "{ messageID:\"test\", createMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\"}}";
+ LinkedTreeMap<?, ?> object = g.fromJson(topicMessage, LinkedTreeMap.class);
+ agent.exitLoop = true;
+ agent.readAgent(object, topicMessage);
+
+ }
+
+ @Test
+ public void testReadUpdateMirrorMaker() throws Exception {
+
+ String topicMessage = "{ messageID:\"test\", updateMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\"}}";
+ LinkedTreeMap<?, ?> object = g.fromJson(topicMessage, LinkedTreeMap.class);
+ testReadCreateMirrorMaker();
+ agent.readAgent(object, topicMessage);
+
+ }
+
+ @Test
+ public void testReadDeleteMirrorMaker() throws Exception {
+
+ String topicMessage = "{ messageID:\"test\", deleteMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\", whitelist:\"test\",status:\"test\" }}";
+ LinkedTreeMap<?, ?> object = g.fromJson(topicMessage, LinkedTreeMap.class);
+ testReadCreateMirrorMaker();
+ agent.readAgent(object, topicMessage);
+
+ }
+
+ @Test
+ public void testReadListMirrorMaker() throws Exception {
+
+ String topicMessage = "{ messageID:\"test\", listAllMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\", whitelist:\"test\",status:\"test\" }}";
+ LinkedTreeMap<?, ?> object = g.fromJson(topicMessage, LinkedTreeMap.class);
+ testReadCreateMirrorMaker();
+ agent.readAgent(object, topicMessage);
+
+ }
+
+ @Test
+ public void testReadWhitelistMirrorMaker() throws Exception {
+
+ String topicMessage = "{ messageID:\"test\", updateWhiteList: { name:\"test\", consumer:\"test\", producer:\"test\", whitelist:\"test\",status:\"test\" }}";
+ LinkedTreeMap<?, ?> object = g.fromJson(topicMessage, LinkedTreeMap.class);
+ testReadCreateMirrorMaker();
+ agent.readAgent(object, topicMessage);
+
+ }
+