From 5cad836ddb2b023960178e7eb394155d8309518b Mon Sep 17 00:00:00 2001
From: Alix <alix.baggio@outlook.fr>
Date: Sun, 8 Jun 2025 21:26:30 +0200
Subject: [PATCH] Reuse public createDispatcher

Allows custom wrapper to overload requestInternal MessageHandler
---
 src/main/java/io/nats/client/impl/NatsConnection.java | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/src/main/java/io/nats/client/impl/NatsConnection.java b/src/main/java/io/nats/client/impl/NatsConnection.java
index 0034a2ba4..ac59868a4 100644
--- a/src/main/java/io/nats/client/impl/NatsConnection.java
+++ b/src/main/java/io/nats/client/impl/NatsConnection.java
@@ -1301,12 +1301,7 @@ CompletableFuture<Message> requestFutureInternal(String subject, Headers headers
             inboxDispatcherLock.lock();
             try {
                 if (inboxDispatcher.get() == null) {
-                    NatsDispatcher d = dispatcherFactory.createDispatcher(this, this::deliverReply);
-
-                    // Ensure the dispatcher is started before publishing messages
-                    String id = this.nuid.next();
-                    this.dispatchers.put(id, d);
-                    d.start(id);
+                    NatsDispatcher d = (NatsDispatcher) createDispatcher(this::deliverReply);
                     d.subscribe(this.mainInbox);
                     inboxDispatcher.set(d);
                 }