--- /dev/null
+/*******************************************************************************
+ * ============LICENSE_START=======================================================
+ * org.onap.dmaap
+ * ================================================================================
+ * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * 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 org.onap.dmaap.messagerouter.mirroragent.nsa.dmaapMMAgent.utils;
+
+import java.io.BufferedReader;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+
+import org.apache.log4j.Logger;
+import org.onap.dmaap.messagerouter.mirroragent.nsa.dmaapMMAgent.MirrorMakerAgent;
+
+public class MirrorMakerProcessHandler {
+ static final Logger logger = Logger.getLogger(MirrorMakerProcessHandler.class);
+
+ public static boolean checkMirrorMakerProcess(String agentname) {
+ try {
+ Runtime rt = Runtime.getRuntime();
+ Process mmprocess = null;
+
+ if (System.getProperty("os.name").contains("Windows")) {
+ String args = "";
+ args = "wmic.exe process where \"commandline like '%agentname=" + agentname
+ + "~%' and caption='java.exe'\"";
+ mmprocess = rt.exec(args);
+ } else {
+ String args[] = { "/bin/sh", "-c", "ps -ef |grep java |grep agentname=" + agentname + "~" };
+ mmprocess = rt.exec(args);
+ }
+
+ InputStream is = mmprocess.getInputStream();
+ InputStreamReader isr = new InputStreamReader(is);
+ BufferedReader br = new BufferedReader(isr);
+ String line;
+ while ((line = br.readLine()) != null) {
+ // System.out.println(line);
+ if (line.contains("agentname=" + agentname) && line.contains("/bin/sh -c") == false) {
+ return true;
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return false;
+ }
+
+ public static void stopMirrorMaker(String agentname) {
+ try {
+ Runtime rt = Runtime.getRuntime();
+ Process killprocess = null;
+
+ if (System.getProperty("os.name").contains("Windows")) {
+ String args = "wmic.exe process where \"commandline like '%agentname=" + agentname
+ + "~%' and caption='java.exe'\" call terminate";
+ killprocess = rt.exec(args);
+ } else {
+ String args[] = { "/bin/sh", "-c",
+ "kill -9 $(ps -ef |grep java |grep agentname=" + agentname + "~| awk '{print $2}')" };
+ // args = "kill $(ps -ef |grep java |grep agentname=" +
+ // agentname + "~| awk '{print $2}')";
+ killprocess = rt.exec(args);
+ }
+
+ InputStream is = killprocess.getInputStream();
+ InputStreamReader isr = new InputStreamReader(is);
+ BufferedReader br = new BufferedReader(isr);
+ String line;
+ while ((line = br.readLine()) != null) {
+ // System.out.println(line);
+ }
+
+ logger.info("Mirror Maker " + agentname + " Stopped");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+ }
+
+ public static void startMirrorMaker(String mmagenthome, String kafkaHome, String agentName, String consumerConfig,
+ String producerConfig, String whitelist) {
+ try {
+ Runtime rt = Runtime.getRuntime();
+
+ if (System.getProperty("os.name").contains("Windows")) {
+ String args = kafkaHome + "/bin/windows/kafka-run-class.bat -Dagentname=" + agentName
+ + "~ kafka.tools.MirrorMaker --consumer.config " + consumerConfig + " --producer.config "
+ + producerConfig + " --whitelist '" + whitelist + "' > " + mmagenthome + "/logs/" + agentName
+ + "_MMaker.log";
+ final Process process = rt.exec(args);
+ new Thread() {
+ public void run() {
+ try {
+ InputStream is = process.getInputStream();
+ InputStreamReader isr = new InputStreamReader(is);
+ BufferedReader br = new BufferedReader(isr);
+ String line;
+ while ((line = br.readLine()) != null) {
+ // System.out.println(line);
+ }
+ } catch (Exception anExc) {
+ anExc.printStackTrace();
+ }
+ }
+ }.start();
+ } else {
+ String args[] = { "/bin/sh", "-c",
+ kafkaHome + "/bin/kafka-run-class.sh -Dagentname=" + agentName
+ + "~ kafka.tools.MirrorMaker --consumer.config " + consumerConfig
+ + " --producer.config " + producerConfig + " --whitelist '" + whitelist + "' >"
+ + mmagenthome + "/logs/" + agentName + "_MMaker.log 2>&1" };
+ final Process process = rt.exec(args);
+ new Thread() {
+ public void run() {
+ try {
+ InputStream is = process.getInputStream();
+ InputStreamReader isr = new InputStreamReader(is);
+ BufferedReader br = new BufferedReader(isr);
+ String line;
+ while ((line = br.readLine()) != null) {
+ // System.out.println(line);
+ }
+ } catch (Exception anExc) {
+ anExc.printStackTrace();
+ }
+ }
+ }.start();
+ }
+
+ logger.info("Mirror Maker " + agentName + " Started" + " WhiteListing:" + whitelist);
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+}
Code Review / dmaap / messagerouter / mirroragent.git / blobdiff