.

src/main/java/tccn/zhub/ZHubClient.java

@@ -298,6 +298,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
 
         // send msg
         new Thread(() -> {
+            while (true) {
                 String msg = null;
                 try {
                     msg = sendMsgQueue.take();
@@ -315,7 +316,8 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
                         e.printStackTrace();
                     }
                 }
-        });
+            }
+        }).start();
 
     }