file name and location changes
[dmaap/messagerouter/mirroragent.git] / src / main / java / org / onap / dmaap / mr / dmaapMMAgent / MirrorMakerAgent.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.mr.dmaapMMAgent;
23
24 import java.io.BufferedReader;
25 import java.io.DataOutputStream;
26 import java.io.File;
27 import java.io.FileInputStream;
28 import java.io.FileOutputStream;
29 import java.io.IOException;
30 import java.io.InputStream;
31 import java.io.InputStreamReader;
32 import java.io.OutputStream;
33 import java.net.HttpURLConnection;
34 import java.net.URL;
35 import java.util.ArrayList;
36 import java.util.Properties;
37 import org.json.JSONObject;
38 import org.apache.log4j.Logger;
39 import org.jasypt.util.text.BasicTextEncryptor;
40
41 import org.onap.dmaap.mr.dmaapMMAgent.dao.CreateMirrorMaker;
42 import org.onap.dmaap.mr.dmaapMMAgent.dao.DeleteMirrorMaker;
43 import org.onap.dmaap.mr.dmaapMMAgent.dao.ListMirrorMaker;
44 import org.onap.dmaap.mr.dmaapMMAgent.dao.MirrorMaker;
45 import org.onap.dmaap.mr.dmaapMMAgent.dao.UpdateMirrorMaker;
46 import org.onap.dmaap.mr.dmaapMMAgent.dao.UpdateWhiteList;
47 import org.onap.dmaap.mr.dmaapMMAgent.utils.MirrorMakerProcessHandler;
48 import com.google.gson.Gson;
49 import com.google.gson.JsonArray;
50 import com.google.gson.internal.LinkedTreeMap;
51
52 import com.sun.org.apache.xerces.internal.impl.dtd.models.CMAny;
53 import com.sun.org.apache.xerces.internal.impl.dv.util.Base64;
54
55 public class MirrorMakerAgent {
56         static final Logger logger = Logger.getLogger(MirrorMakerAgent.class);
57         Properties mirrorMakerProperties = new Properties();
58         ListMirrorMaker mirrorMakers = null;
59         String mmagenthome = "/opt";
60         String kafkahome = "";
61         String topicURL = "";
62         String topicname = "";
63         String mechid = "";
64         String password = "";
65         String grepLog = "";
66         public boolean exitLoop = false;
67         TopicUtil topicUtil = new TopicUtil();
68         private static String secret = "utdfpWlgyDQ2ZB8SLVRtmN834I1JcT9J";
69
70         public static void main(String[] args) {
71                 if (args != null && args.length == 2) {
72                         if (args[0].equals("-encrypt")) {
73                                 BasicTextEncryptor textEncryptor = new BasicTextEncryptor();
74                                 textEncryptor.setPassword(secret);
75                                 String plainText = textEncryptor.encrypt(args[1]);
76                                 System.out.println("Encrypted Password is :" + plainText);
77                                 return;
78                         }
79                 } else if (args != null && args.length > 0) {
80                         System.out.println(
81                                         "Usage: ./mmagent to run with the configuration \n -encrypt <password> to Encrypt Password for config ");
82                         return;
83                 }
84                 MirrorMakerAgent agent = new MirrorMakerAgent();
85                 if (agent.checkStartup()) {
86                         logger.info("mmagent started, loading properties");
87                         try {
88                                 agent.checkAgentProcess();
89                         } catch (Exception e) {
90
91                                 e.printStackTrace();
92                         }
93                         agent.readAgentTopic();
94                 } else {
95                         System.out.println(
96                                         "ERROR: mmagent startup unsuccessful, please make sure the mmagenthome /etc/mmagent.config is set and mechid have the rights to the topic");
97                 }
98         }
99
100         private boolean checkStartup() {
101                 FileInputStream input = null;
102                 try {
103                         //this.mmagenthome = System.getProperty("MMAGENTHOME");
104                         input = new FileInputStream(mmagenthome + "/etc/mmagent.config");
105                         logger.info("mmagenthome is set :" + mmagenthome + " loading properties at /etc/mmagent.config");
106                 } catch (IOException ex) {
107                         logger.error(mmagenthome + "/etc/mmagent.config not found.  Set -DMMAGENTHOME and check the config file");
108                         return false;
109                 } finally {
110                         if (input != null) {
111                                 try {
112                                         input.close();
113                                 } catch (IOException e) {
114                                         e.printStackTrace();
115                                 }
116                         }
117                 }
118                 loadProperties();
119                 input = null;
120                 try {
121                         input = new FileInputStream(kafkahome + "/bin/kafka-run-class.sh");
122                         logger.info("kakahome is set :" + kafkahome);
123                 } catch (IOException ex) {
124                         logger.error(kafkahome + "/bin/kafka-run-class.sh not found.  Make sure kafka home is set correctly");
125                         return false;
126                 } finally {
127                         if (input != null) {
128                                 try {
129                                         input.close();
130                                 } catch (IOException e) {
131                                         e.printStackTrace();
132                                 }
133                         }
134                 }
135                 String response = topicUtil.publishTopic(topicURL, topicname, mechid, password, "{\"test\":\"test\"}");
136                 if (response.startsWith("ERROR:")) {
137                         logger.error("Problem publishing to topic, please verify the config " + this.topicname + " MR URL is:"
138                                         + this.topicURL + " Error is:  " + response);
139                         return false;
140                 }
141                 logger.info("Published to Topic :" + this.topicname + " Successfully");
142                 response = topicUtil.subscribeTopic(topicURL, topicname, "1", response, response);
143                 if (response != null && response.startsWith("ERROR:")) {
144                         logger.error("Problem subscribing to topic, please verify the config " + this.topicname + " MR URL is:"
145                                         + this.topicURL + " Error is:  " + response);
146                         return false;
147                 }
148                 logger.info("Subscribed to Topic :" + this.topicname + " Successfully");
149                 return true;
150         }
151
152         private void checkPropertiesFile(MirrorMaker mm, String propName, boolean refresh) {
153                 InputStream input = null;
154                 OutputStream out = null;
155                 try {
156                         if (refresh) {
157                                 throw new IOException();
158                         }
159                         input = new FileInputStream(mmagenthome + "/etc/" + mm.name + propName + ".properties");
160                 } catch (IOException ex) {
161                         try {
162                                 input = new FileInputStream(mmagenthome + "/etc/" + propName + ".properties");
163                                 Properties prop = new Properties();
164                                 prop.load(input);
165                                 if (propName.equals("consumer")) {
166                                         prop.setProperty("group.id", mm.name);
167
168                                         prop.setProperty("bootstrap.servers", mm.consumer);
169                                         prop.setProperty("client.id", mm.name + "MM_consumer");
170                                 } else {
171                                         prop.setProperty("bootstrap.servers", mm.producer);
172                                         prop.setProperty("client.id", mm.name + "MM_producer");
173
174                                 }
175                                 out = new FileOutputStream(mmagenthome + "/etc/" + mm.name + propName + ".properties");
176                                 prop.store(out, "");
177
178                         } catch (Exception e) {
179                                 e.printStackTrace();
180                         }
181                 } finally {
182                         if (input != null) {
183                                 try {
184                                         input.close();
185                                 } catch (IOException e) {
186                                         e.printStackTrace();
187                                 }
188                         }
189                         if (out != null) {
190                                 try {
191                                         out.close();
192                                 } catch (IOException e) {
193                                         e.printStackTrace();
194                                 }
195                         }
196                 }
197         }
198
199         private void checkAgentProcess() throws Exception {
200                 logger.info("Checking MirrorMaker Process");
201                 if (mirrorMakers != null) {
202                         int mirrorMakersCount = mirrorMakers.getListMirrorMaker().size();
203                         for (int i = 0; i < mirrorMakersCount; i++) {
204                                 MirrorMaker mm = mirrorMakers.getListMirrorMaker().get(i);
205                                 if (MirrorMakerProcessHandler.checkMirrorMakerProcess(mm.name, mm.enablelogCheck,
206                                                 this.grepLog) == false) {
207                                         checkPropertiesFile(mm, "consumer", false);
208                                         checkPropertiesFile(mm, "producer", false);
209
210                                         if (mm.whitelist != null && !mm.whitelist.equals("")) {
211                                                 logger.info(
212                                                                 "MirrorMaker " + mm.name + " is not running, restarting.  Check Logs for more Details");
213                                                 MirrorMakerProcessHandler.startMirrorMaker(this.mmagenthome, this.kafkahome, mm.name,
214                                                                 mmagenthome + "/etc/" + mm.name + "consumer.properties",
215                                                                 mmagenthome + "/etc/" + mm.name + "producer.properties", mm.numStreams, mm.whitelist);
216                                                 mm.setStatus("RESTARTING");
217
218                                         } else {
219                                                 logger.info("MirrorMaker " + mm.name + " is STOPPED");
220                                                 mm.setStatus("STOPPED");
221                                         }
222                                         try {
223                                                 Thread.sleep(1000);
224                                         } catch (InterruptedException e) {
225                                         }
226                                         mirrorMakers.getListMirrorMaker().set(i, mm);
227                                 } else {
228                                         logger.info("MirrorMaker " + mm.name + " is running");
229                                         mm.setStatus("RUNNING");
230                                         mirrorMakers.getListMirrorMaker().set(i, mm);
231                                 }
232                         }
233                 }
234                 // Gson g = new Gson();
235                 // System.out.println(g.toJson(mirrorMakers));
236         }
237
238         public void readAgentTopic() {
239                 try {
240                         int connectionattempt = 0;
241                         while (true) {
242                                 logger.info("--------------------------------");
243                                 logger.info("Waiting for Messages for 60 secs");
244                                 String topicMessage = topicUtil.subscribeTopic(topicURL, topicname, "60000", mechid, password);
245                                 Gson g = new Gson();
246                                 LinkedTreeMap<?, ?> object = null;
247                                 if (topicMessage != null) {
248                                         try {
249                                                 // Check and parse if String object returned by consumer
250                                                 // API
251                                                 // else use the jsonObject
252                                                 if (topicMessage.startsWith("\"")) {
253                                                         topicMessage = g.fromJson(topicMessage.toString(), String.class);
254                                                 }
255                                                 object = g.fromJson(topicMessage, LinkedTreeMap.class);
256
257                                                 // Cast the 1st item (since limit=1 and see the type of
258                                                 // object
259                                                 readAgent(object, topicMessage);
260                                         } catch (Exception ex) {
261                                                 connectionattempt++;
262                                                 if (connectionattempt > 5) {
263                                                         logger.info("Can't connect to the topic, mmagent shutting down , " + topicMessage);
264                                                         return;
265                                                 }
266                                                 logger.info("Can't connect to the topic, " + topicMessage + " Retrying " + connectionattempt
267                                                                 + " of 5 times in 1 minute" + " Error:" + ex.getLocalizedMessage());
268                                                 Thread.sleep(60000);
269                                         }
270                                 } else {
271                                         // Check all MirrorMaker every min
272                                         connectionattempt = 0;
273                                         checkAgentProcess();
274                                 }
275                                 if (exitLoop) {
276                                         break;
277                                 }
278
279                         }
280                 } catch (Exception e) {
281                         e.printStackTrace();
282                 }
283
284         }
285
286         public void createMirrorMaker(MirrorMaker newMirrorMaker) {
287                 boolean exists = false;
288                 if (mirrorMakers != null) {
289                         int mirrorMakersCount = mirrorMakers.getListMirrorMaker().size();
290                         for (int i = 0; i < mirrorMakersCount; i++) {
291                                 MirrorMaker mm = mirrorMakers.getListMirrorMaker().get(i);
292                                 if (mm.name.equals(newMirrorMaker.name)) {
293                                         exists = true;
294                                         logger.info("MirrorMaker already exist for:" + newMirrorMaker.name);
295                                         return;
296                                 }
297                         }
298                 }
299                 logger.info("Adding new MirrorMaker:" + newMirrorMaker.name);
300                 if (exists == false && mirrorMakers != null) {
301                         mirrorMakers.getListMirrorMaker().add(newMirrorMaker);
302                 } else if (exists == false && mirrorMakers == null) {
303                         mirrorMakers = new ListMirrorMaker();
304                         ArrayList<MirrorMaker> list = mirrorMakers.getListMirrorMaker();
305                         list = new ArrayList<MirrorMaker>();
306                         list.add(newMirrorMaker);
307                         mirrorMakers.setListMirrorMaker(list);
308                 }
309                 checkPropertiesFile(newMirrorMaker, "consumer", true);
310                 checkPropertiesFile(newMirrorMaker, "producer", true);
311
312                 Gson g = new Gson();
313                 mirrorMakerProperties.setProperty("mirrormakers", g.toJson(this.mirrorMakers));
314                 OutputStream out = null;
315                 try {
316                         out = new FileOutputStream(mmagenthome + "/etc/mmagent.config");
317                         mirrorMakerProperties.store(out, "");
318                 } catch (IOException ex) {
319                         ex.printStackTrace();
320                 } finally {
321                         if (out != null) {
322                                 try {
323                                         out.close();
324                                 } catch (IOException e) {
325                                         e.printStackTrace();
326                                 }
327                         }
328                 }
329         }
330
331         private void updateMirrorMaker(MirrorMaker newMirrorMaker) {
332                 boolean exists = false;
333                 if (mirrorMakers != null) {
334                         int mirrorMakersCount = mirrorMakers.getListMirrorMaker().size();
335                         for (int i = 0; i < mirrorMakersCount; i++) {
336                                 MirrorMaker mm = mirrorMakers.getListMirrorMaker().get(i);
337                                 if (mm.name.equals(newMirrorMaker.name)) {
338                                         exists = true;
339                                         if (null != newMirrorMaker.getConsumer()) {
340                                                 mm.setConsumer(newMirrorMaker.getConsumer());
341                                         }
342                                         if (null != newMirrorMaker.getProducer()) {
343                                                 mm.setProducer(newMirrorMaker.getProducer());
344                                         }
345                                         if (newMirrorMaker.getNumStreams() >= 1) {
346                                                 mm.setNumStreams(newMirrorMaker.getNumStreams());
347                                         }
348
349                                         mm.setEnablelogCheck(newMirrorMaker.enablelogCheck);
350
351                                         mirrorMakers.getListMirrorMaker().set(i, mm);
352                                         newMirrorMaker = mm;
353                                         logger.info("Updating MirrorMaker:" + newMirrorMaker.name);
354                                 }
355                         }
356                 }
357                 if (exists) {
358                         checkPropertiesFile(newMirrorMaker, "consumer", true);
359                         checkPropertiesFile(newMirrorMaker, "producer", true);
360
361                         Gson g = new Gson();
362                         mirrorMakerProperties.setProperty("mirrormakers", g.toJson(this.mirrorMakers));
363                         OutputStream out = null;
364                         try {
365                                 out = new FileOutputStream(mmagenthome + "/etc/mmagent.config");
366                                 mirrorMakerProperties.store(out, "");
367                                 MirrorMakerProcessHandler.stopMirrorMaker(newMirrorMaker.name);
368                                 try {
369                                         Thread.sleep(1000);
370                                 } catch (InterruptedException e) {
371                                 }
372                         } catch (IOException ex) {
373                                 ex.printStackTrace();
374                         } finally {
375                                 if (out != null) {
376                                         try {
377                                                 out.close();
378                                         } catch (IOException e) {
379                                                 e.printStackTrace();
380                                         }
381                                 }
382                         }
383                 } else {
384                         logger.info("MirrorMaker Not found for:" + newMirrorMaker.name);
385                 }
386         }
387
388         private void updateWhiteList(MirrorMaker newMirrorMaker) {
389                 boolean exists = false;
390                 if (mirrorMakers != null) {
391                         int mirrorMakersCount = mirrorMakers.getListMirrorMaker().size();
392                         for (int i = 0; i < mirrorMakersCount; i++) {
393                                 MirrorMaker mm = mirrorMakers.getListMirrorMaker().get(i);
394                                 if (mm.name.equals(newMirrorMaker.name)) {
395                                         exists = true;
396                                         mm.setWhitelist(newMirrorMaker.whitelist);
397                                         mirrorMakers.getListMirrorMaker().set(i, mm);
398                                         logger.info("Updating MirrorMaker WhiteList:" + newMirrorMaker.name + " WhiteList:"
399                                                         + newMirrorMaker.whitelist);
400                                 }
401                         }
402                 }
403                 if (exists) {
404                         Gson g = new Gson();
405                         mirrorMakerProperties.setProperty("mirrormakers", g.toJson(this.mirrorMakers));
406                         OutputStream out = null;
407                         try {
408                                 out = new FileOutputStream(mmagenthome + "/etc/mmagent.config");
409                                 mirrorMakerProperties.store(out, "");
410                                 MirrorMakerProcessHandler.stopMirrorMaker(newMirrorMaker.name);
411                                 try {
412                                         Thread.sleep(1000);
413                                 } catch (InterruptedException e) {
414                                 }
415                         } catch (IOException ex) {
416                                 ex.printStackTrace();
417                         } finally {
418                                 if (out != null) {
419                                         try {
420                                                 out.close();
421                                         } catch (IOException e) {
422                                                 e.printStackTrace();
423                                         }
424                                 }
425                         }
426                 } else {
427                         logger.info("MirrorMaker Not found for:" + newMirrorMaker.name);
428                 }
429         }
430
431         private void deleteMirrorMaker(MirrorMaker newMirrorMaker) {
432                 boolean exists = false;
433                 if (mirrorMakers != null) {
434                         int mirrorMakersCount = mirrorMakers.getListMirrorMaker().size();
435                         for (int i = 0; i < mirrorMakersCount; i++) {
436                                 MirrorMaker mm = mirrorMakers.getListMirrorMaker().get(i);
437                                 if (mm.name.equals(newMirrorMaker.name)) {
438                                         exists = true;
439                                         mirrorMakers.getListMirrorMaker().remove(i);
440                                         logger.info("Removing MirrorMaker:" + newMirrorMaker.name);
441                                         i = mirrorMakersCount;
442                                 }
443                         }
444                 }
445                 if (exists) {
446                         try {
447                                 String path = mmagenthome + "/etc/" + newMirrorMaker.name + "consumer" + ".properties";
448                                 File file = new File(path);
449                                 file.delete();
450                         } catch (Exception ex) {
451                         }
452                         try {
453                                 String path = mmagenthome + "/etc/" + newMirrorMaker.name + "producer" + ".properties";
454                                 File file = new File(path);
455                                 file.delete();
456                         } catch (Exception ex) {
457                         }
458                         Gson g = new Gson();
459                         mirrorMakerProperties.setProperty("mirrormakers", g.toJson(this.mirrorMakers));
460                         OutputStream out = null;
461                         try {
462                                 out = new FileOutputStream(mmagenthome + "/etc/mmagent.config");
463                                 mirrorMakerProperties.store(out, "");
464                                 MirrorMakerProcessHandler.stopMirrorMaker(newMirrorMaker.name);
465                         } catch (IOException ex) {
466                                 ex.printStackTrace();
467                         } finally {
468                                 if (out != null) {
469                                         try {
470                                                 out.close();
471                                         } catch (IOException e) {
472                                                 e.printStackTrace();
473                                         }
474                                 }
475                         }
476                 } else {
477                         logger.info("MirrorMaker Not found for:" + newMirrorMaker.name);
478                 }
479         }
480
481         private void loadProperties() {
482                 InputStream input = null;
483                 try {
484
485                         input = new FileInputStream(mmagenthome + "/etc/mmagent.config");
486                         mirrorMakerProperties.load(input);
487                         Gson g = new Gson();
488                         if (mirrorMakerProperties.getProperty("mirrormakers") == null) {
489                                 this.mirrorMakers = new ListMirrorMaker();
490                                 ArrayList<MirrorMaker> list = this.mirrorMakers.getListMirrorMaker();
491                                 list = new ArrayList<MirrorMaker>();
492                                 this.mirrorMakers.setListMirrorMaker(list);
493                         } else {
494                                 this.mirrorMakers = g.fromJson(mirrorMakerProperties.getProperty("mirrormakers"),
495                                                 ListMirrorMaker.class);
496                         }
497
498                         this.kafkahome = mirrorMakerProperties.getProperty("kafkahome");
499                         this.topicURL = mirrorMakerProperties.getProperty("topicURL");
500                         this.topicname = mirrorMakerProperties.getProperty("topicname");
501                         this.mechid = mirrorMakerProperties.getProperty("mechid");
502                         this.grepLog = mirrorMakerProperties.getProperty("grepLog");
503
504                         BasicTextEncryptor textEncryptor = new BasicTextEncryptor();
505                         textEncryptor.setPassword(secret);
506                         this.password = textEncryptor.decrypt(mirrorMakerProperties.getProperty("password"));
507                 } catch (Exception ex) {
508                         // ex.printStackTrace();
509                 } finally {
510                         if (input != null) {
511                                 try {
512                                         input.close();
513                                 } catch (IOException e) {
514                                         // e.printStackTrace();
515                                 }
516                         }
517                 }
518
519         }
520
521         public void readAgent(LinkedTreeMap<?, ?> object, String topicMessage) throws Exception{
522
523                 Gson g = new Gson();
524
525                 if (object.get("createMirrorMaker") != null) {
526                         logger.info("Received createMirrorMaker request from topic");
527                         CreateMirrorMaker m = g.fromJson(topicMessage, CreateMirrorMaker.class);
528                         createMirrorMaker(m.getCreateMirrorMaker());
529                         checkAgentProcess();
530                         mirrorMakers.setMessageID(m.getMessageID());
531                         topicUtil.publishTopic(topicURL, topicname, mechid, password, g.toJson(mirrorMakers));
532                         mirrorMakers.setMessageID("");
533                 } else if (object.get("updateMirrorMaker") != null) {
534                         logger.info("Received updateMirrorMaker request from topic");
535                         UpdateMirrorMaker m = g.fromJson(topicMessage, UpdateMirrorMaker.class);
536                         JSONObject json = new JSONObject(topicMessage);
537                         JSONObject json2 = (JSONObject) json.get("updateMirrorMaker");
538                         if (!json2.has("numStreams")) {
539                                 m.getUpdateMirrorMaker().setNumStreams(0);
540                         }
541                         updateMirrorMaker(m.getUpdateMirrorMaker());
542                         checkAgentProcess();
543                         mirrorMakers.setMessageID(m.getMessageID());
544                         topicUtil.publishTopic(topicURL, topicname, mechid, password, g.toJson(mirrorMakers));
545                         mirrorMakers.setMessageID("");
546                 } else if (object.get("deleteMirrorMaker") != null) {
547                         logger.info("Received deleteMirrorMaker request from topic");
548                         DeleteMirrorMaker m = g.fromJson(topicMessage, DeleteMirrorMaker.class);
549                         deleteMirrorMaker(m.getDeleteMirrorMaker());
550                         checkAgentProcess();
551                         mirrorMakers.setMessageID(m.getMessageID());
552                         topicUtil.publishTopic(topicURL, topicname, mechid, password, g.toJson(mirrorMakers));
553                         mirrorMakers.setMessageID("");
554                 } else if (object.get("listAllMirrorMaker") != null) {
555                         logger.info("Received listALLMirrorMaker request from topic");
556                         checkAgentProcess();
557                         mirrorMakers.setMessageID((String) object.get("messageID"));
558                         topicUtil.publishTopic(topicURL, topicname, mechid, password, g.toJson(mirrorMakers));
559                         mirrorMakers.setMessageID("");
560                 } else if (object.get("updateWhiteList") != null) {
561                         logger.info("Received updateWhiteList request from topic");
562                         UpdateWhiteList m = g.fromJson(topicMessage, UpdateWhiteList.class);
563                         updateWhiteList(m.getUpdateWhiteList());
564                         checkAgentProcess();
565                         mirrorMakers.setMessageID(m.getMessageID());
566                         topicUtil.publishTopic(topicURL, topicname, mechid, password, g.toJson(mirrorMakers));
567                         mirrorMakers.setMessageID("");
568                 } else if (object.get("listMirrorMaker") != null) {
569                         logger.info("Received listMirrorMaker from topic, skipping messages");
570                 } else {
571                         logger.info("Received unknown request from topic");
572                 }
573
574         }
575 }

© 2017 ONAP. Copyright © The Linux Foundation ®. All Rights Reserved.
The Linux Foundation has registered trademarks and uses trademarks.
For a list of trademarks of The Linux Foundation, please see our Trademark Usage page.
Linux is a registered trademark of Linus Torvalds.
Privacy Policy and Terms of Use