js: 调整 sendAndRequest(timeout=-1)时，表示为流超时

noear · Jan 10, 2024 · 674066d · 674066d
1 parent 4f47b4a
commit 674066d
Showing 1 changed file with 1 addition and 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
@@ -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);
                 }