@@ -141,7 +141,7 @@ private void testQueueSendReceiveOnTracedThread(Callable<Message> receiveMethod,
141141 String message = UUID .randomUUID ().toString ();
142142 Message outgoingMessage = brokerFacade .createTextMessage (message );
143143 brokerFacade .send (queue , outgoingMessage );
144- Message incomingMessage = receiveOnTracedThread (receiveMethod ).get (1 , TimeUnit .SECONDS );
144+ Message incomingMessage = receiveOnTracedThread (receiveMethod ).get (3 , TimeUnit .SECONDS );
145145 verifyMessage (message , incomingMessage );
146146
147147 List <Span > spans = reporter .getSpans ();
@@ -168,7 +168,7 @@ private void testQueueSendReceiveOnNonTracedThread(Callable<Message> receiveMeth
168168 String message = UUID .randomUUID ().toString ();
169169 Message outgoingMessage = brokerFacade .createTextMessage (message );
170170 brokerFacade .send (queue , outgoingMessage );
171- Message incomingMessage = receiveOnNonTracedThread (receiveMethod ).get (1 , TimeUnit .SECONDS );
171+ Message incomingMessage = receiveOnNonTracedThread (receiveMethod ).get (3 , TimeUnit .SECONDS );
172172 verifyMessage (message , incomingMessage );
173173 verifySendReceiveOnNonTracedThread (queue .getQueueName (), 1 );
174174 }
@@ -228,7 +228,7 @@ private void testQueueSendListen(Function<Destination, CompletableFuture<Message
228228 String message = UUID .randomUUID ().toString ();
229229 Message outgoingMessage = brokerFacade .createTextMessage (message );
230230 brokerFacade .send (queue , outgoingMessage );
231- Message incomingMessage = incomingMessageFuture .get (1 , TimeUnit .SECONDS );
231+ Message incomingMessage = incomingMessageFuture .get (3 , TimeUnit .SECONDS );
232232 verifyMessage (message , incomingMessage );
233233 Thread .sleep (500 );
234234 verifySendReceiveOnNonTracedThread (queue .getQueueName (), 1 );
@@ -245,10 +245,10 @@ public void testTopicWithTwoSubscribers() throws Exception {
245245 Message outgoingMessage = brokerFacade .createTextMessage (message );
246246 brokerFacade .send (topic , outgoingMessage );
247247
248- Message incomingMessage1 = incomingMessageFuture1 .get (1 , TimeUnit .SECONDS );
248+ Message incomingMessage1 = incomingMessageFuture1 .get (3 , TimeUnit .SECONDS );
249249 verifyMessage (message , incomingMessage1 );
250250
251- Message incomingMessage2 = incomingMessageFuture2 .get (1 , TimeUnit .SECONDS );
251+ Message incomingMessage2 = incomingMessageFuture2 .get (3 , TimeUnit .SECONDS );
252252 verifyMessage (message , incomingMessage2 );
253253
254254 Thread .sleep (500 );
0 commit comments