Azure / azure-service-bus-java

☁️ Java client library for Azure Service Bus
https://azure.microsoft.com/services/service-bus
MIT License
60 stars 59 forks source link

Stopping the reactor because thread was interrupted or the reactor has no more events to process. #411

Open ingvildodegard opened 3 years ago

ingvildodegard commented 3 years ago

Actual Behavior

  1. We are using ServiceBusReceiverAsyncClient to receive messages from an Azure service bus. The problem is that after a while, it suddenly stops receiving messages from the queue, and we need to restart the application in order to make it read the messages again. We have not yet found any logic related to when it stops. It can stop after 30 minutes, and it can stop after several hours. The message shown when stopping says: c.a.c.a.i.ReactorExecutor - [reactor-executor-1] INFO - connectionId[MF_edbe29_1615620074027], message[Stopping the reactor because thread was interrupted or the reactor has no more events to process.]
  2. Our java test application is shown here: ServiceBusQueueReceiverTest.java

Expected Behavior

The receiver should run without issues, and read messages from the service bus as they are put on the queue

Versions

Apache Maven 3.6.3 (cecedd343002696d0abb50b32b541b8a6ba2883f) Maven home: C:\Appl\apache-maven-3.6.3\bin.. Java version: 10.0.2, vendor: Oracle Corporation, runtime: C:\Appl\jdk-10.0.2 Default locale: en_US, platform encoding: Cp1252 OS name: "windows 10", version: "10.0", arch: "amd64", family: "windows"