@@ -0,0 +1,84 @@
+package demo;
+
+import com.github.dockerjava.api.async.ResultCallback;
+import java.io.Closeable;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.concurrent.CountDownLatch;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * @GitHub : https://github.com/zacscoding
+ */
+public class NoStreamCallback<A_RES_T> implements ResultCallback<A_RES_T> {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(NoStreamCallback.class);
+
+    private Closeable stream;
+    private boolean closed = false;
+    private A_RES_T object;
+    private Throwable firstError = null;
+    private final CountDownLatch next = new CountDownLatch(1);
+
+
+    @Override
+    public void onStart(Closeable stream) {
+        this.stream = stream;
+        this.closed = false;
+    }
+
+    @Override
+    public void onNext(A_RES_T object) {
+        this.object = object;
+        next.countDown();
+        onComplete();
+    }
+
+    @Override
+    public void onError(Throwable throwable) {
+        if (closed) {
+            return;
+        }
+
+        if (firstError == null) {
+            firstError = throwable;
+        }
+
+        try {
+            LOGGER.error("Error during callback", throwable);
+        } finally {
+            try {
+                close();
+            } catch (IOException e) {
+                throw new RuntimeException(e);
+            }
+        }
+    }
+
+    @Override
+    public void onComplete() {
+        try {
+            LOGGER.info("onComplete is called..");
+            close();
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    @Override
+    public void close() throws IOException {
+        if (!closed) {
+            closed = true;
+            if (stream != null) {
+                LOGGER.info("Try to close stream");
+                stream.close();
+            }
+        }
+    }
+
+    public A_RES_T awaitNext() throws InterruptedException {
+        next.await();
+        return object;
+    }
+}
@@ -3,6 +3,7 @@
 import com.github.dockerjava.api.DockerClient;
 import com.github.dockerjava.api.model.Container;
 import demo.DockerClientHelper;
+import java.util.Arrays;
 import java.util.List;
 import org.junit.Test;
 
@@ -18,8 +19,8 @@ public void connect() throws Exception {
             .withStatusFilter("exited").exec();
 
         for (Container container : containers) {
-            System.out.println(container);
-            System.out.println(container.getNames());
+            System.out.println(container.getId());
+            System.out.println(Arrays.toString(container.getNames()));
         }
 
         dockerClient.close();
 
@@ -1,35 +1,35 @@
 package docker;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.github.dockerjava.api.DockerClient;
 import com.github.dockerjava.api.model.Container;
-import com.google.common.base.Strings;
+import com.github.dockerjava.api.model.Statistics;
 import demo.DockerClientHelper;
+import demo.NoStreamCallback;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 
+
 /**
  * @GitHub : https://github.com/zacscoding
  */
 public class DockerMetricsTest {
 
-    Map<String, String> idNameMap = new HashMap<>();
+    List<String> containerIds;
     DockerClient docker;
 
     @Before
     public void setUp() {
         this.docker = DockerClientHelper.INSTANCE.getDockerClient();
-        this.idNameMap = new HashMap<>();
-
         List<Container> containers = docker.listContainersCmd().withShowAll(true).exec();
-        for (Container container : containers) {
-            idNameMap.put(container.getId(), Arrays.toString(container.getNames()));
-        }
+        this.containerIds = containers.stream().map(container -> container.getId()).collect(Collectors.toList());
     }
 
     @After
@@ -38,7 +38,18 @@ public void tearDown() throws Exception {
     }
 
     @Test
-    public void temp() throws Exception {
+    public void collectMetricsJob() throws Exception {
+        ObjectMapper objectMapper = new ObjectMapper();
+        for (int i = 0; i < 5; i++) {
+            for (String containerId : containerIds) {
+
+                NoStreamCallback<Statistics> statsCallback = new NoStreamCallback<>();
+
+                docker.statsCmd(containerId).exec(statsCallback);
+                Statistics stats = statsCallback.awaitNext();
+                System.out.println(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(stats));
+            }
+            TimeUnit.SECONDS.sleep(10L);
+        }
     }
-
 }