@@ -34,7 +34,7 @@ void testPublishQuery() throws QueryNotFoundException, SiteNotFoundException {
34
34
client .addQueryStatusListener (statusListener );
35
35
client .publishQuery (brokerQueryId );
36
36
37
- verify (statusListener , timeout (ASYNC_TIMEOUT_WAIT_MS )).onClientUpdate (
37
+ verify (statusListener , timeout (ASYNC_TIMEOUT_WAIT_MS ). atLeastOnce () ).onClientUpdate (
38
38
TEST_BACKEND_QUERY_ID ,
39
39
QueryStatusUpdate .builder ()
40
40
.source (client )
@@ -43,7 +43,7 @@ void testPublishQuery() throws QueryNotFoundException, SiteNotFoundException {
43
43
.status (COMPLETED )
44
44
.build ()
45
45
);
46
- verify (statusListener , timeout (ASYNC_TIMEOUT_WAIT_MS )).onClientUpdate (
46
+ verify (statusListener , timeout (ASYNC_TIMEOUT_WAIT_MS ). atLeastOnce () ).onClientUpdate (
47
47
TEST_BACKEND_QUERY_ID ,
48
48
QueryStatusUpdate .builder ()
49
49
.source (client )
@@ -52,7 +52,7 @@ void testPublishQuery() throws QueryNotFoundException, SiteNotFoundException {
52
52
.status (COMPLETED )
53
53
.build ()
54
54
);
55
- verify (statusListener , timeout (ASYNC_TIMEOUT_WAIT_MS )).onClientUpdate (
55
+ verify (statusListener , timeout (ASYNC_TIMEOUT_WAIT_MS ). atLeastOnce () ).onClientUpdate (
56
56
TEST_BACKEND_QUERY_ID ,
57
57
QueryStatusUpdate .builder ()
58
58
.source (client )
@@ -61,7 +61,7 @@ void testPublishQuery() throws QueryNotFoundException, SiteNotFoundException {
61
61
.status (COMPLETED )
62
62
.build ()
63
63
);
64
- verify (statusListener , timeout (ASYNC_TIMEOUT_WAIT_MS )).onClientUpdate (
64
+ verify (statusListener , timeout (ASYNC_TIMEOUT_WAIT_MS ). atLeastOnce () ).onClientUpdate (
65
65
TEST_BACKEND_QUERY_ID ,
66
66
QueryStatusUpdate .builder ()
67
67
.source (client )
0 commit comments