何知谦 4 роки тому
батько
коміт
ac80b5931b

BIN
seecoder-logTracking-client/target/app.jar


BIN
seecoder-logTracking-common/target/app.jar


BIN
seecoder-logTracking-common/target/classes/com/nju/edu/logTracking/kafka/Config.class


BIN
seecoder-logTracking-consumer/target/app.jar


BIN
seecoder-logTracking-server/target/app.jar


BIN
seecoder-logTracking-server/target/app.jar.original


+ 2 - 7
testConnect/src/main/java/Test.java

@@ -1,9 +1,8 @@
 import com.nju.edu.logTracking.LogConsumer;
 
-import java.io.IOException;
-
 public class Test {
-    public static void main(String[] args) throws IOException, InterruptedException {
+    public static void main(String[] args) {
+        System.out.println("start running");
         LogConsumer myConsumer = new LogConsumer() {
             @Override
             public void run(String value) {
@@ -11,9 +10,5 @@ public class Test {
             }
         };
         myConsumer.processLog();
-        while(true){
-            System.out.println("running");
-            Thread.sleep(2000);
-        }
     }
 }

BIN
testConnect/target/app.jar


BIN
testConnect/target/app.jar.original


BIN
testConnect/target/classes/Test$1.class


BIN
testConnect/target/classes/Test.class