Merge pull request #78 from hengboy/master

🚀 创建消息管道达到上限数量时抛出异常

Author: hengboy

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

@@ -1,6 +1,7 @@
 package org.minbox.framework.message.pipe.server.manager;
 
 import lombok.extern.slf4j.Slf4j;
+import org.minbox.framework.message.pipe.core.exception.MessagePipeException;
 import org.minbox.framework.message.pipe.server.MessagePipe;
 import org.minbox.framework.message.pipe.server.config.MessagePipeConfiguration;
 import org.minbox.framework.message.pipe.server.config.ServerConfiguration;
@@ -66,6 +67,10 @@ public AbstractMessagePipeManager(Map<String, MessagePipeConfiguration> initConf
     public void createMessagePipe(String name) {
         synchronized (MESSAGE_PIPE_MAP) {
             if (!MESSAGE_PIPE_MAP.containsKey(name)) {
+                if (MESSAGE_PIPE_MAP.size() >= serverConfiguration.getMaxMessagePipeCount()) {
+                    throw new MessagePipeException("The number of message pipes reaches the upper limit, " +
+                            "and the message pipe cannot be created.");
+                }
                 MessagePipeConfiguration configuration = this.getConfiguration();
                 MessagePipe messagePipe = this.messagePipeFactoryBean.createMessagePipe(name, configuration);
                 MESSAGE_PIPE_MAP.put(name, messagePipe);