From a862b1511c7df151a7c09cec59761501a4c274c2 Mon Sep 17 00:00:00 2001
From: eyalkoren <eyal.koren@elastic.co>
Date: Wed, 12 Jun 2019 07:48:44 +0300
Subject: [PATCH] Increase timeouts to 3 seconds

---
 .../co/elastic/apm/agent/jms/JmsInstrumentationIT.java | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/apm-agent-plugins/apm-jms-plugin/src/test/java/co/elastic/apm/agent/jms/JmsInstrumentationIT.java b/apm-agent-plugins/apm-jms-plugin/src/test/java/co/elastic/apm/agent/jms/JmsInstrumentationIT.java
index 6e5aa0e633..4865ffac58 100644
--- a/apm-agent-plugins/apm-jms-plugin/src/test/java/co/elastic/apm/agent/jms/JmsInstrumentationIT.java
+++ b/apm-agent-plugins/apm-jms-plugin/src/test/java/co/elastic/apm/agent/jms/JmsInstrumentationIT.java
@@ -141,7 +141,7 @@ private void testQueueSendReceiveOnTracedThread(Callable<Message> receiveMethod,
         String message = UUID.randomUUID().toString();
         Message outgoingMessage = brokerFacade.createTextMessage(message);
         brokerFacade.send(queue, outgoingMessage);
-        Message incomingMessage = receiveOnTracedThread(receiveMethod).get(1, TimeUnit.SECONDS);
+        Message incomingMessage = receiveOnTracedThread(receiveMethod).get(3, TimeUnit.SECONDS);
         verifyMessage(message, incomingMessage);
 
         List<Span> spans = reporter.getSpans();
@@ -168,7 +168,7 @@ private void testQueueSendReceiveOnNonTracedThread(Callable<Message> receiveMeth
         String message = UUID.randomUUID().toString();
         Message outgoingMessage = brokerFacade.createTextMessage(message);
         brokerFacade.send(queue, outgoingMessage);
-        Message incomingMessage = receiveOnNonTracedThread(receiveMethod).get(1, TimeUnit.SECONDS);
+        Message incomingMessage = receiveOnNonTracedThread(receiveMethod).get(3, TimeUnit.SECONDS);
         verifyMessage(message, incomingMessage);
         verifySendReceiveOnNonTracedThread(queue.getQueueName(), 1);
     }
@@ -228,7 +228,7 @@ private void testQueueSendListen(Function<Destination, CompletableFuture<Message
         String message = UUID.randomUUID().toString();
         Message outgoingMessage = brokerFacade.createTextMessage(message);
         brokerFacade.send(queue, outgoingMessage);
-        Message incomingMessage = incomingMessageFuture.get(1, TimeUnit.SECONDS);
+        Message incomingMessage = incomingMessageFuture.get(3, TimeUnit.SECONDS);
         verifyMessage(message, incomingMessage);
         Thread.sleep(500);
         verifySendReceiveOnNonTracedThread(queue.getQueueName(), 1);
@@ -245,10 +245,10 @@ public void testTopicWithTwoSubscribers() throws Exception {
         Message outgoingMessage = brokerFacade.createTextMessage(message);
         brokerFacade.send(topic, outgoingMessage);
 
-        Message incomingMessage1 = incomingMessageFuture1.get(1, TimeUnit.SECONDS);
+        Message incomingMessage1 = incomingMessageFuture1.get(3, TimeUnit.SECONDS);
         verifyMessage(message, incomingMessage1);
 
-        Message incomingMessage2 = incomingMessageFuture2.get(1, TimeUnit.SECONDS);
+        Message incomingMessage2 = incomingMessageFuture2.get(3, TimeUnit.SECONDS);
         verifyMessage(message, incomingMessage2);
 
         Thread.sleep(500);