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);
                 }