diff --git a/src/SignalR/clients/java/signalr/src/main/java/com/microsoft/signalr/LongPollingTransport.java b/src/SignalR/clients/java/signalr/src/main/java/com/microsoft/signalr/LongPollingTransport.java
index 087867bace..939b0b2cb7 100644
--- a/src/SignalR/clients/java/signalr/src/main/java/com/microsoft/signalr/LongPollingTransport.java
+++ b/src/SignalR/clients/java/signalr/src/main/java/com/microsoft/signalr/LongPollingTransport.java
@@ -98,7 +98,7 @@ class LongPollingTransport implements Transport {
                     } else {
                         if (response.getContent() != null) {
                             logger.debug("Message received.");
-                            threadPool.execute(() -> this.onReceive(response.getContent()));
+                            this.onReceive(response.getContent());
                         } else {
                             logger.debug("Poll timed out, reissuing.");
                         }
diff --git a/src/SignalR/clients/java/signalr/src/test/java/com/microsoft/signalr/LongPollingTransportTest.java b/src/SignalR/clients/java/signalr/src/test/java/com/microsoft/signalr/LongPollingTransportTest.java
index f2a0076dd6..bd3f834325 100644
--- a/src/SignalR/clients/java/signalr/src/test/java/com/microsoft/signalr/LongPollingTransportTest.java
+++ b/src/SignalR/clients/java/signalr/src/test/java/com/microsoft/signalr/LongPollingTransportTest.java
@@ -172,6 +172,9 @@ public class LongPollingTransportTest {
                     } else if (requestCount.get() == 2) {
                         requestCount.incrementAndGet();
                         return Single.just(new HttpResponse(200, "", "SECOND"));
+                    } else if (requestCount.get() == 3) {
+                        requestCount.incrementAndGet();
+                        return Single.just(new HttpResponse(200, "", "THIRD"));
                     }
 
                     return Single.just(new HttpResponse(204, "", ""));
@@ -186,7 +189,7 @@ public class LongPollingTransportTest {
         transport.setOnReceive((msg) -> {
             onReceiveCalled.set(true);
             message.set(message.get() + msg);
-            if (messageCount.incrementAndGet() == 2) {
+            if (messageCount.incrementAndGet() == 3) {
                 blocker.onComplete();
             }
         });
@@ -196,7 +199,7 @@ public class LongPollingTransportTest {
         transport.start("http://example.com").timeout(1, TimeUnit.SECONDS).blockingAwait();
         assertTrue(blocker.blockingAwait(1, TimeUnit.SECONDS));
         assertTrue(onReceiveCalled.get());
-        assertEquals("FIRSTSECOND", message.get());
+        assertEquals("FIRSTSECONDTHIRD", message.get());
     }
 
     @Test