-
- }
-
- @Test
- public void testReadAgentTopics() {
- when(agent.subscribeTopic("60000")).thenReturn(null);
- agent.exitLoop = true;
- agent.readAgentTopic();
- }
-
- @Test
- public void testReadCreateMirrorMaker() {
- when(agent.publishTopic(
- "{\"messageID\":\"test\",\"listMirrorMaker\":[{\"name\":\"test\",\"consumer\":\"test\",\"producer\":\"test\",\"status\":\"STOPPED\"}]}"))
- .thenReturn(null);
- String topicMessage = "{ messageID:\"test\", createMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\"}}";
- LinkedTreeMap<?, ?> object = g.fromJson(topicMessage, LinkedTreeMap.class);
- agent.readAgent(object, topicMessage);
-
- }
-
- @Test
- public void testReadUpdateMirrorMaker() {
- when(agent.publishTopic(
- "{\"messageID\":\"test\",\"listMirrorMaker\":[{\"name\":\"test\",\"consumer\":\"test\",\"producer\":\"test\",\"status\":\"STOPPED\"}]}"))
- .thenReturn(null);
- 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() {
- when(agent.publishTopic(
- "{\"messageID\":\"test\",\"listMirrorMaker\":[{\"name\":\"test\",\"consumer\":\"test\",\"producer\":\"test\",\"status\":\"STOPPED\"}]}"))
- .thenReturn(null);
- 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);
-