bug fix

Author: [email protected]

src/main/java/com/dtstack/logstash/Main.java

@@ -90,7 +90,7 @@ public static void main(String[] args) {
             //assembly pipeline
             inputQueueList =assemblyPipeline.assemblyPipeline(cmdLine);
     		//add shutdownhook
-    		ShutDownHook shutDownHook = new ShutDownHook(inputQueueList, assemblyPipeline.getBaseInputs(),assemblyPipeline.getBaseOutPuts());
+    		ShutDownHook shutDownHook = new ShutDownHook(inputQueueList, assemblyPipeline.getBaseInputs(),assemblyPipeline.getAllBaseOutputs());
     		shutDownHook.addShutDownHook();
 		} catch (Exception e) {
 			logger.error("jlogstash_start error:{}",e.getCause());

src/main/java/com/dtstack/logstash/assembly/AssemblyPipeline.java

@@ -41,7 +41,7 @@ public class AssemblyPipeline {
 
 	private List<BaseInput> baseInputs =null;
 
-	private List<BaseOutput> baseOutputs = Lists.newCopyOnWriteArrayList();
+	private List<BaseOutput> allBaseOutputs = Lists.newCopyOnWriteArrayList();
 
 	/**
 	 * 组装管道
@@ -112,7 +112,7 @@ protected void initFilterAndOutputThread(List<Map> outputs, List<Map> filters, L
 			List<BaseOutput> baseOutputs = OutputFactory.getBatchInstance(outputs);
 			List<BaseFilter> baseFilters = FilterFactory.getBatchInstance(filters);	
 			filterOutputExecutor.submit(new FilterAndOutputThread(queue,baseFilters,baseOutputs,batchSize));
-			baseOutputs.addAll(baseOutputs);
+			allBaseOutputs.addAll(baseOutputs);
 		}
 	}
 
@@ -162,8 +162,10 @@ protected static boolean isInputQueueSizeLog(CommandLine line){
 	public List<BaseInput> getBaseInputs() {
 		return this.baseInputs;
 	}
-	
-	public List<BaseOutput> getBaseOutPuts() {
-		return this.baseOutputs;
+
+
+	public List<BaseOutput> getAllBaseOutputs() {
+		return allBaseOutputs;
 	}
+
 }

src/main/java/com/dtstack/logstash/assembly/ShutDownHook.java

@@ -1,10 +1,8 @@
 package com.dtstack.logstash.assembly;
 
 import java.util.List;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-
 import com.dtstack.logstash.inputs.BaseInput;
 import com.dtstack.logstash.outputs.BaseOutput;