Merge pull request #88 from hengboy/master

🔥 创建消息管道时返回MessagePipe实例

Author: hengboy

message-pipe-server/src/main/java/org/minbox/framework/message/pipe/server/manager/AbstractMessagePipeManager.java

@@ -64,7 +64,7 @@ public AbstractMessagePipeManager(Map<String, MessagePipeConfiguration> initConf
     }
 
     @Override
-    public void createMessagePipe(String name) {
+    public MessagePipe createMessagePipe(String name) {
         synchronized (MESSAGE_PIPE_MAP) {
             if (!MESSAGE_PIPE_MAP.containsKey(name)) {
                 if (MESSAGE_PIPE_MAP.size() >= serverConfiguration.getMaxMessagePipeCount()) {
@@ -89,6 +89,9 @@ public void createMessagePipe(String name) {
                 MessagePipeScheduler scheduler = new MessagePipeScheduler(messagePipe, distributor);
                 SCHEDULER_SERVICE.submit(() -> scheduler.startup());
                 log.info("MessagePipe：{}，scheduler create successfully.", name);
+                return messagePipe;
+            } else {
+                return MESSAGE_PIPE_MAP.get(name);
             }
         }
     }

message-pipe-server/src/main/java/org/minbox/framework/message/pipe/server/manager/MessagePipeManager.java

@@ -13,7 +13,7 @@ public interface MessagePipeManager {
      *
      * @param name The {@link MessagePipe} name
      */
-    void createMessagePipe(String name);
+    MessagePipe createMessagePipe(String name);
 
     /**
      * Get message pipe by name