@@ -68,13 +68,13 @@ public void testEventStreamTimeBound() throws InterruptedException,
6868 EventsCmd eventsCmd = dockerClient .eventsCmd (eventCallback )
6969 .withSince (startTime ).withUntil (endTime );
7070 ExecutorService executorService = eventsCmd .exec ();
71-
72- boolean zeroCount = countDownLatch .await (5 , TimeUnit .SECONDS );
73-
71+
72+ boolean zeroCount = countDownLatch .await (10 , TimeUnit .SECONDS );
73+
7474 executorService .shutdown ();
7575 eventCallback .close ();
7676
77- assertTrue (zeroCount , "" + eventCallback .getEvents ());
77+ assertTrue (zeroCount , "Received only: " + eventCallback .getEvents ());
7878 }
7979
8080 @ Test
@@ -91,10 +91,10 @@ public void testEventStreaming1() throws InterruptedException, IOException {
9191
9292 generateEvents ();
9393
94- boolean zeroCount = countDownLatch .await (5 , TimeUnit .SECONDS );
94+ boolean zeroCount = countDownLatch .await (10 , TimeUnit .SECONDS );
9595 executorService .shutdown ();
9696 eventCallback .close ();
97- assertTrue (zeroCount , "Expected 4 events, [create, start, die, stop]" );
97+ assertTrue (zeroCount , "Received only: " + eventCallback . getEvents () );
9898 }
9999
100100 @ Test
@@ -111,10 +111,10 @@ public void testEventStreaming2() throws InterruptedException, IOException {
111111
112112 generateEvents ();
113113
114- boolean zeroCount = countDownLatch .await (5 , TimeUnit .SECONDS );
114+ boolean zeroCount = countDownLatch .await (10 , TimeUnit .SECONDS );
115115 executorService .shutdown ();
116116 eventCallback .close ();
117- assertTrue (zeroCount , "Expected 4 events, [create, start, die, stop]" );
117+ assertTrue (zeroCount , "Received only: " + eventCallback . getEvents () );
118118 }
119119
120120 /**
0 commit comments