[BUG] ReactorRejectedExecutionException when stopping the EventProcessorClient #44473

kumaran-sowrirajan · 2025-03-03T18:43:56Z

Describe the bug
Bug: When stopping the EventProcessorClient with the latest version (5.20.0), it blows up with an exception ReactorRejectedExecutionException

Exception or Stack Trace
2025-02-25 09:16:31 ERROR GenericQuery:105 - LocalId:11akh4qxu3dzJUWmNNJM ERROR(128) Exception:reactor.core.Exceptions$ReactorRejectedExecutionException: Scheduler unavailable: Failed processing events
com.azure.core.exception.AzureException: reactor.core.Exceptions$ReactorRejectedExecutionException: Scheduler unavailable
at com.relx.rba.tardis.azure.eventhub.transport.EventHubPartitionProcessor.processError(EventHubPartitionProcessor.java:140) ~[classes/:?]
at com.azure.messaging.eventhubs.EventProcessorClientBuilder$1.processError(EventProcessorClientBuilder.java:909) ~[azure-messaging-eventhubs-5.20.0.jar:5.20.0]
at com.azure.messaging.eventhubs.PartitionPumpManager.handleError(PartitionPumpManager.java:380) ~[azure-messaging-eventhubs-5.20.0.jar:5.20.0]
at com.azure.messaging.eventhubs.PartitionPumpManager.lambda$startPartitionPump$5(PartitionPumpManager.java:223) ~[azure-messaging-eventhubs-5.20.0.jar:5.20.0]
at reactor.core.publisher.LambdaSubscriber.onError(LambdaSubscriber.java:149) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.trySchedule(FluxPublishOn.java:327) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.onNext(FluxPublishOn.java:237) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.innerNext(FluxConcatMapNoPrefetch.java:258) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:863) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1839) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.MonoCollectList$MonoCollectListSubscriber.onComplete(MonoCollectList.java:129) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxWindowTimeout$InnerWindow.sendComplete(FluxWindowTimeout.java:1159) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxWindowTimeout$WindowTimeoutWithBackpressureSubscriber.onComplete(FluxWindowTimeout.java:241) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:128) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144) ~[reactor-core-3.4.41.jar:3.4.41]
at com.azure.core.amqp.implementation.MessageFlux$RecoverableReactorReceiver.terminateIfErrorOrCompletionSignaled(MessageFlux.java:601) ~[azure-core-amqp-2.9.12.jar:2.9.12]
at com.azure.core.amqp.implementation.MessageFlux$RecoverableReactorReceiver.drainLoop(MessageFlux.java:437) ~[azure-core-amqp-2.9.12.jar:2.9.12]
at com.azure.core.amqp.implementation.MessageFlux$RecoverableReactorReceiver.drain(MessageFlux.java:405) ~[azure-core-amqp-2.9.12.jar:2.9.12]
at com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.onLinkComplete(MessageFlux.java:932) ~[azure-core-amqp-2.9.12.jar:2.9.12]
at com.azure.core.amqp.implementation.MessageFlux$ReactorReceiverMediator.lambda$onParentReady$3(MessageFlux.java:816) ~[azure-core-amqp-2.9.12.jar:2.9.12]
at reactor.core.publisher.LambdaSubscriber.onComplete(LambdaSubscriber.java:132) [reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.doComplete(FluxPublishOn.java:505) [reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.checkTerminated(FluxPublishOn.java:552) [reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:432) [reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:527) [reactor-core-3.4.41.jar:3.4.41]
at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84) [reactor-core-3.4.41.jar:3.4.41]
at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37) [reactor-core-3.4.41.jar:3.4.41]
at java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264) [?:?]
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java) [?:?]
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) [?:?]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
at java.base/java.lang.Thread.run(Thread.java:840) [?:?]
Caused by: reactor.core.Exceptions$ReactorRejectedExecutionException: Scheduler unavailable
at reactor.core.Exceptions.failWithRejected(Exceptions.java:271) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.Operators.onRejectedExecution(Operators.java:1024) ~[reactor-core-3.4.41.jar:3.4.41]
... 30 more
Caused by: java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@6e9afc06[Not completed, task = reactor.core.scheduler.WorkerTask@1a143d0e] rejected from BoundedScheduledExecutorService{IDLE, queued=0/10000, completed=3}
at java.base/java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2065) ~[?:?]
at java.base/java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:833) ~[?:?]
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:340) ~[?:?]
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:579) ~[?:?]
at reactor.core.scheduler.BoundedElasticScheduler$BoundedScheduledExecutorService.schedule(BoundedElasticScheduler.java:943) ~[reactor-core-3.4.41.jar:3.4.41]
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor.submit(ScheduledThreadPoolExecutor.java:731) ~[?:?]
at reactor.core.scheduler.BoundedElasticScheduler$BoundedScheduledExecutorService.submit(BoundedElasticScheduler.java:1019) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.scheduler.Schedulers.workerSchedule(Schedulers.java:1439) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.scheduler.ExecutorServiceWorker.schedule(ExecutorServiceWorker.java:50) ~[reactor-core-3.4.41.jar:3.4.41]
at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.trySchedule(FluxPublishOn.java:312) ~[reactor-core-3.4.41.jar:3.4.41]
... 29 more

To Reproduce
Stop the EventProcessorClient. I have 2 partitions in the event hub.

Code Snippet
Below is the java code to reproduce this issue.

import com.azure.messaging.eventhubs.EventData;
import com.azure.messaging.eventhubs.EventHubBufferedProducerClient;
import com.azure.messaging.eventhubs.EventHubBufferedProducerClientBuilder;
import com.azure.messaging.eventhubs.EventHubClientBuilder;
import com.azure.messaging.eventhubs.EventProcessorClient;
import com.azure.messaging.eventhubs.EventProcessorClientBuilder;
import com.azure.messaging.eventhubs.checkpointstore.blob.BlobCheckpointStore;
import com.azure.messaging.eventhubs.models.EventPosition;
import com.azure.storage.blob.BlobContainerAsyncClient;
import com.azure.storage.blob.BlobServiceAsyncClient;
import com.azure.storage.blob.BlobServiceClientBuilder;
import com.azure.storage.common.StorageSharedKeyCredential;
import java.time.Duration;
import java.time.Instant;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CountDownLatch;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;

public class EventHubConsumerSDKTest {

    /**
     * This test is to demonstrate the exception upon stopping the EventProcessorClient
     */
    @Test
    public void testConsumeEventsInBatchByEventHubConsumerClient() {
        //Event Hub details
        String connectionString = "<<REPLACE_THIS_WITH_YOUR_EVENT_HUB_CONNECTION_STRING>>";
        String eventHubName = "<<REPLACE_THIS_WITH_YOUR_EVENT_HUB_NAME>>";

        //Blob Storage Account details (for checkpointing)
        String accountName = "<<REPLACE_THIS_WITH_YOUR_STORAGE_ACCOUNT_NAME>>";
        String accountKey = "<<REPLACE_THIS_WITH_YOUR_STORAGE_ACCOUNT_KEY>>";
        String containerName = "<<REPLACE_THIS_WITH_YOUR_STORAGE_ACCOUNT_CONTAINER_NAME>>";
        String endpointUrl = "<<REPLACE_THIS_WITH_YOUR_STORAGE_ACCOUNT_ENDPOINT>>";
 
        List<String> events = List.of("one", "two", "three");
        int numberOfEvents = events.size();
        BlobServiceClientBuilder blobServiceClientBuilder = new BlobServiceClientBuilder();
        BlobServiceAsyncClient blobServiceClient = blobServiceClientBuilder.credential(new StorageSharedKeyCredential(accountName, accountKey)).endpoint(endpointUrl).buildAsyncClient();
        BlobContainerAsyncClient blobContainerClient = blobServiceClient.getBlobContainerAsyncClient(containerName);
        CountDownLatch latch = new CountDownLatch(numberOfEvents);
        Map<String, String> eventsByPartition = new HashMap<>();
        EventPosition startingPosition = EventPosition.fromEnqueuedTime(Instant.now());
        EventProcessorClientBuilder eventProcessorClientBuilder = new EventProcessorClientBuilder();
        EventProcessorClient eventProcessorClient = eventProcessorClientBuilder.eventHubName(eventHubName)
                .connectionString(connectionString)
                .consumerGroup(EventHubClientBuilder.DEFAULT_CONSUMER_GROUP_NAME)
                .processEventBatch(eventBatchContext -> {
                    for (EventData eventData : eventBatchContext.getEvents()) {
                        String partitionId = eventBatchContext.getPartitionContext().getPartitionId();
                        eventsByPartition.putIfAbsent(partitionId + "-" + eventData.getOffset(), eventData.getBodyAsString());
                        latch.countDown();
                    }
                }, 10, Duration.ofSeconds(10))
                .processError(errorContext -> System.out.println(errorContext.getThrowable().getMessage()))//This will show the //exception message. Inspect the stacktrace to find more detail about the exception.
                .initialPartitionEventPosition(partitionId -> startingPosition)
                .checkpointStore(new BlobCheckpointStore(blobContainerClient))
                .buildEventProcessorClient();
        EventHubBufferedProducerClient producerClient = new EventHubBufferedProducerClientBuilder()
                .connectionString(connectionString)
                .eventHubName(eventHubName)
                .onSendBatchSucceeded(context -> System.out.println("partition-id => " + context.getPartitionId()))
                .onSendBatchFailed(context -> System.out.println("context.getThrowable().getMessage() => " + context.getThrowable().getMessage()))
                .buildClient();
        eventProcessorClient.start();
        try (producerClient) {
            List<EventData> eventData = events.stream().map(EventData::new).toList();
            producerClient.enqueueEvents(eventData);
            producerClient.flush();
            latch.await();
            Assertions.assertEquals(0, latch.getCount(), "Latch count should be 0");
        } catch (Exception e) {
            Assertions.fail("Unable to publish an event", e);
        } finally {
            if (eventProcessorClient.isRunning()) {
                eventProcessorClient.stop();
            }
        }
    }
}
`

**Expected behavior**
No exception

**Setup (please complete the following information):**
 - OS: Windows 11 Enterprise
 - IDE: IntelliJ
 - Library/Libraries

        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-storage-blob</artifactId>
            <version>12.29.0</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-storage-common</artifactId>
            <version>12.28.0</version>
        </dependency>
        <dependency>
            <groupId>com.microsoft.azure</groupId>
            <artifactId>azure-storage</artifactId>
            <version>8.6.6</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-messaging-eventhubs</artifactId>
            <version>5.20.0</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-messaging-eventhubs-checkpointstore-blob</artifactId>
            <version>1.20.3</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-core</artifactId>
            <version>1.55.2</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-identity</artifactId>
            <version>1.15.3</version>
        </dependency>
        <dependency>
            <groupId>com.microsoft.azure</groupId>
            <artifactId>msal4j</artifactId>
            <version>1.19.0</version>
        </dependency>

 - Java version: Amazon Corretto (jdk17.0.14_7)

github-actions · 2025-03-03T18:44:43Z

@anuchandy @conniey @lmolkova

github-actions · 2025-03-03T18:44:44Z

Thank you for your feedback. Tagging and routing to the team member best able to assist.

conniey · 2025-03-03T22:36:10Z

Hi,

I copy, pasted, and executed your code. It did not throw any exceptions. Do you have a DEBUG log from the beginning of your run to the end of it?

Output I got:

partition-id => 2
partition-id => 0
partition-id => 1

Process finished with exit code 0

kumaran-sowrirajan · 2025-03-04T03:14:22Z

Hi,

I copy, pasted, and executed your code. It did not throw any exceptions. Do you have a DEBUG log from the beginning of your run to the end of it?

Output I got:
partition-id => 2
partition-id => 0
partition-id => 1

Process finished with exit code 0

Did you get a chance to run the same with the artifacts version what I provided (Added below for your reference)? I do not have the debug log but I can get one and share it here.

    <dependency>
        <groupId>com.azure</groupId>
        <artifactId>azure-storage-blob</artifactId>
        <version>12.29.0</version>
    </dependency>
    <dependency>
        <groupId>com.azure</groupId>
        <artifactId>azure-storage-common</artifactId>
        <version>12.28.0</version>
    </dependency>
    <dependency>
        <groupId>com.microsoft.azure</groupId>
        <artifactId>azure-storage</artifactId>
        <version>8.6.6</version>
    </dependency>
    <dependency>
        <groupId>com.azure</groupId>
        <artifactId>azure-messaging-eventhubs</artifactId>
        <version>5.20.0</version>
    </dependency>
    <dependency>
        <groupId>com.azure</groupId>
        <artifactId>azure-messaging-eventhubs-checkpointstore-blob</artifactId>
        <version>1.20.3</version>
    </dependency>
    <dependency>
        <groupId>com.azure</groupId>
        <artifactId>azure-core</artifactId>
        <version>1.55.2</version>
    </dependency>
    <dependency>
        <groupId>com.azure</groupId>
        <artifactId>azure-identity</artifactId>
        <version>1.15.3</version>
    </dependency>
    <dependency>
        <groupId>com.microsoft.azure</groupId>
        <artifactId>msal4j</artifactId>
        <version>1.19.0</version>
    </dependency>**

conniey · 2025-03-04T19:51:23Z

I created a new project and added the dependencies you listed. It does not run. Can you include a full project sample.

What is the reason you're referencing azure-core, azure-messaging-eventhubs, azure-storage-blob explicitly? azure-messaging-eventhubs-checkpointstore-blob will pull them in transitively.

java.lang.LinkageError: Package versions: jackson-core=2.9.4, jackson-databind=2.17.2, jackson-dataformat-xml=unknown,
 jackson-datatype-jsr310=2.17.2, azure-core=1.55.2, Troubleshooting version conflicts: 
https://aka.ms/azsdk/java/dependency/troubleshoot

	at com.azure.core.implementation.jackson.ObjectMapperShim.createPrettyPrintMapper(ObjectMapperShim.java:132)
	at com.azure.core.http.policy.HttpLoggingPolicy.<clinit>(HttpLoggingPolicy.java:85)
	at com.azure.storage.blob.implementation.util.BuilderHelper.buildPipeline(BuilderHelper.java:145)
	at com.azure.storage.blob.BlobServiceClientBuilder.constructPipeline(BlobServiceClientBuilder.java:149)
	at com.azure.storage.blob.BlobServiceClientBuilder.buildAsyncClient(BlobServiceClientBuilder.java:172)
	at org.example.EventHubConsumerSDKTest.testConsumeEventsInBatchByEventHubConsumerClient(EventHubConsumerSDKTest.java:45)
	at java.base/java.lang.reflect.Method.invoke(Method.java:569)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
Caused by: java.lang.NoClassDefFoundError: com/fasterxml/jackson/core/util/JacksonFeature
	at java.base/java.lang.ClassLoader.defineClass1(Native Method)
	at java.base/java.lang.ClassLoader.defineClass(ClassLoader.java:1017)
	at java.base/java.security.SecureClassLoader.defineClass(SecureClassLoader.java:150)
...

kumaran-sowrirajan · 2025-03-04T20:08:44Z

We expose API to our users who can access the azure storage blob storage account, azure datalake. Similarly we expose API to interact with azure event hub. Not all users are interested in event hub interaction.

kumaran-sowrirajan · 2025-03-04T22:39:35Z

Please find the full project sample below.

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.example</groupId>
    <artifactId>Evenhub_Error</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <maven.compiler.source>17</maven.compiler.source>
        <maven.compiler.target>17</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <jakarta-jms.version>3.1.0</jakarta-jms.version>
        <nimbus.version>9.48</nimbus.version>
        <netty.version>4.1.118.Final</netty.version>
        <netty-tcnative.version>2.0.70.Final</netty-tcnative.version>
        <apache-httpclient5.version>5.4.2</apache-httpclient5.version>
        <mssql-jdbc.version>12.8.1.jre11</mssql-jdbc.version>
        <junit.version>5.12.0</junit.version>
        <jackson.version>2.18.2</jackson.version>
        <jackson.databind.version>2.18.2</jackson.databind.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-storage-blob</artifactId>
            <version>12.29.0</version>
            <exclusions>
                <exclusion>
                    <groupId>io.netty</groupId>
                    <artifactId>*</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-storage-blob-batch</artifactId>
            <version>12.25.0</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-storage-common</artifactId>
            <version>12.28.0</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-storage-file-datalake</artifactId>
            <version>12.22.0</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-messaging-servicebus</artifactId>
            <version>7.17.8</version>
        </dependency>
        <dependency>
            <groupId>com.microsoft.azure</groupId>
            <artifactId>azure-storage</artifactId>
            <version>8.6.6</version>
            <exclusions>
                <exclusion>
                    <groupId>com.google.guava</groupId>
                    <artifactId>guava</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-storage-file-share</artifactId>
            <version>12.25.1</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-storage-queue</artifactId>
            <version>12.24.0</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-messaging-eventhubs</artifactId>
            <version>5.20.0</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-messaging-eventhubs-checkpointstore-blob</artifactId>
            <version>1.20.3</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-core</artifactId>
            <version>1.55.2</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-identity</artifactId>
            <version>1.15.3</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-core-test</artifactId>
            <version>1.26.2</version>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>io.netty</groupId>
                    <artifactId>*</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>jakarta.jms</groupId>
            <artifactId>jakarta.jms-api</artifactId>
            <version>${jakarta-jms.version}</version>
        </dependency>
        <dependency>
            <groupId>com.microsoft.azure</groupId>
            <artifactId>azure-servicebus</artifactId>
            <version>3.6.7</version>
            <exclusions>
                <exclusion>
                    <groupId>net.minidev</groupId>
                    <artifactId>json-smart</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>com.nimbusds</groupId>
                    <artifactId>nimbus-jose-jwt</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>com.google.guava</groupId>
                    <artifactId>guava</artifactId>
                </exclusion>
                <exclusion>
                    <artifactId>okhttp</artifactId>
                    <groupId>com.squareup.okhttp3</groupId>
                </exclusion>
                <exclusion>
                    <groupId>io.netty</groupId>
                    <artifactId>*</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.nimbusds</groupId>
            <artifactId>nimbus-jose-jwt</artifactId>
            <version>${nimbus.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.qpid</groupId>
            <artifactId>qpid-jms-client</artifactId>
            <version>2.7.0</version>
            <exclusions>
                <exclusion>
                    <groupId>io.netty</groupId>
                    <artifactId>*</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-all</artifactId>
            <version>${netty.version}</version>
        </dependency>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-tcnative-boringssl-static</artifactId>
            <version>${netty-tcnative.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents.client5</groupId>
            <artifactId>httpclient5</artifactId>
            <version>${apache-httpclient5.version}</version>
        </dependency>
        <dependency>
            <groupId>com.microsoft.azure</groupId>
            <artifactId>msal4j</artifactId>
            <version>1.19.0</version>
        </dependency>
        <dependency>
            <groupId>com.microsoft.sqlserver</groupId>
            <artifactId>mssql-jdbc</artifactId>
            <version>${mssql-jdbc.version}</version>
        </dependency>
        <dependency>
            <groupId>org.junit.jupiter</groupId>
            <artifactId>junit-jupiter-api</artifactId>
            <version>${junit.version}</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>org.junit.jupiter</groupId>
            <artifactId>junit-jupiter-engine</artifactId>
            <version>${junit.version}</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-core</artifactId>
            <version>${jackson.version}</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>${jackson.databind.version}</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.dataformat</groupId>
            <artifactId>jackson-dataformat-csv</artifactId>
            <version>${jackson.version}</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.dataformat</groupId>
            <artifactId>jackson-dataformat-xml</artifactId>
            <version>${jackson.version}</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-annotations</artifactId>
            <version>${jackson.version}</version>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.codehaus.mojo</groupId>
                <artifactId>flatten-maven-plugin</artifactId>
            </plugin>
            <plugin>
                <artifactId>maven-compiler-plugin</artifactId>
            </plugin>
            <plugin>
                <artifactId>maven-source-plugin</artifactId>
            </plugin>
            <plugin>
                <artifactId>maven-jar-plugin</artifactId>
            </plugin>
            <plugin>
                <artifactId>maven-surefire-plugin</artifactId>
                <configuration>
                    <forkCount>1</forkCount>
                </configuration>
            </plugin>
            <plugin>
                <artifactId>maven-javadoc-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>
`

github-actions bot assigned anuchandy Mar 3, 2025

conniey self-assigned this Mar 4, 2025

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[BUG] ReactorRejectedExecutionException when stopping the EventProcessorClient #44473

[BUG] ReactorRejectedExecutionException when stopping the EventProcessorClient #44473

kumaran-sowrirajan commented Mar 3, 2025

github-actions bot commented Mar 3, 2025

github-actions bot commented Mar 3, 2025

conniey commented Mar 3, 2025 •

edited

Loading

kumaran-sowrirajan commented Mar 4, 2025 •

edited

Loading

conniey commented Mar 4, 2025 •

edited

Loading

kumaran-sowrirajan commented Mar 4, 2025

kumaran-sowrirajan commented Mar 4, 2025

[BUG] ReactorRejectedExecutionException when stopping the EventProcessorClient #44473

[BUG] ReactorRejectedExecutionException when stopping the EventProcessorClient #44473

Comments

kumaran-sowrirajan commented Mar 3, 2025

github-actions bot commented Mar 3, 2025

github-actions bot commented Mar 3, 2025

conniey commented Mar 3, 2025 • edited Loading

kumaran-sowrirajan commented Mar 4, 2025 • edited Loading

conniey commented Mar 4, 2025 • edited Loading

kumaran-sowrirajan commented Mar 4, 2025

kumaran-sowrirajan commented Mar 4, 2025

conniey commented Mar 3, 2025 •

edited

Loading

kumaran-sowrirajan commented Mar 4, 2025 •

edited

Loading

conniey commented Mar 4, 2025 •

edited

Loading