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

© 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