From 88657fdf63b9522614529c089d95069f442e00e0 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Wed, 10 Jun 2020 20:30:50 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/MessageClient.java | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/org/redkale/mq/MessageClient.java b/src/org/redkale/mq/MessageClient.java
index 8b7cd15aa..db2e7e5a8 100644
--- a/src/org/redkale/mq/MessageClient.java
+++ b/src/org/redkale/mq/MessageClient.java
@@ -80,12 +80,16 @@ public class MessageClient {
                 }
             }
             if (convertType != null) message.setFormat(convertType);
-            if (needresp && message.getResptopic() == null) message.setResptopic(respTopic);
-            messageAgent.getProducer().apply(message);
+            if (needresp && (message.getResptopic() == null || message.getResptopic().isEmpty())) {
+                message.setResptopic(respTopic);
+            }
             if (counter != null) counter.incrementAndGet();
+            messageAgent.getProducer().apply(message);
             if (needresp) {
                 MessageRespFutureNode node = new MessageRespFutureNode(message.getSeqid(), counter, future);
                 respNodes.put(message.getSeqid(), node);
+            } else {
+                future.complete(null);
             }
         } catch (Exception ex) {
             future.completeExceptionally(ex);