From 674066d9f0995db42e986c3863ea58177de0f802 Mon Sep 17 00:00:00 2001
From: noear <noear@live.cn>
Date: Wed, 10 Jan 2024 18:16:16 +0800
Subject: [PATCH] =?UTF-8?q?js:=20=E8=B0=83=E6=95=B4=20sendAndRequest(timeo?=
 =?UTF-8?q?ut=3D-1)=E6=97=B6=EF=BC=8C=E8=A1=A8=E7=A4=BA=E4=B8=BA=E6=B5=81?=
 =?UTF-8?q?=E8=B6=85=E6=97=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/org/noear/socketd/broker/BrokerListener.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/java/socketd/src/main/java/org/noear/socketd/broker/BrokerListener.java b/java/socketd/src/main/java/org/noear/socketd/broker/BrokerListener.java
index ab306ecf..9d36ca29 100644
--- a/java/socketd/src/main/java/org/noear/socketd/broker/BrokerListener.java
+++ b/java/socketd/src/main/java/org/noear/socketd/broker/BrokerListener.java
@@ -104,7 +104,7 @@ protected boolean forwardToName(Session requester, Message message, String name)
      */
     protected void forwardToSession(Session requester, Message message, Session responder) throws IOException {
         if (message.isRequest()) {
-            responder.sendAndRequest(message.event(), message).thenReply(reply -> {
+            responder.sendAndRequest(message.event(), message, -1).thenReply(reply -> {
                 if (requester.isValid()) {
                     requester.reply(message, reply);
                 }