文件监听

src/main/java/com/miniframe/bisiness/mdo/MDO0039Service.java

@@ -140,13 +140,14 @@ public class MDO0039Service extends MDO0039BaseModel implements ExecProcessFlow
 			DockerExe.getDockerLogs(pid,new ResultCallback.Adapter<Frame>() {
 				@Override
 				public void onNext(Frame frame) {
-//					if(con[0] <100){
-//						line[0]+=new String(frame.getPayload());
-//					}else{
-//						LogService.addLog(pid, line[0]);
-//						line[0]="";
-//						con[0] =0;
-//					}
+					if(con[0] <100){
+						line[0]+=new String(frame.getPayload());
+						con[0]++;
+					}else{
+						LogService.addLog(pid, line[0]);
+						line[0]="";
+						con[0] =0;
+					}
 					LogService.addLog(pid, new String(frame.getPayload()));
 					System.out.print(new String(frame.getPayload()));
 					super.onNext(frame);