private void init() {
        if(connectionNum < 1){
            log.error("connection param error：connectionNum："+ connectionNum);
            return;
        }
        urls = this.brokerUrl.split(",");
        if (urls.length < 1) {
            urls = this.brokerUrl.split(" ");
        }
        if (urls.length >= 1) {
            for (String url : urls) {
                JmsInfo jmsInfo = new JmsInfo(url, userName, password, connectionNum, JmsConfig.isCheakPool(), JmsConfig.getLazyCheck(), JmsConfig.getPeriodCheck());
                JmsConnectionPool jmsConnectionPool = new JmsConnectionPool(jmsInfo);
                jmsConnectionPool.setActiveTrue();
                pools.add(jmsConnectionPool);
            }
        }
        //消费异常消息
        processMessageQueue();
        log.info("connection initialization is complete");
    }