C#编程实现消息队列连接与消费者注册

 #region <<Topic注册消息监听>>
        /// <summary>
        /// Topic注册消息监听 
        /// </summary>
        /// <param name="mqIp">ip地址</param>
        /// <param name="mqName">名称</param>
        /// <param name="mqUsername">用户名称</param>
        /// <param name="mqPassword">密码</param>
        /// <param name="mqClientId">客户端ID</param>
        public static void reg_Listener(string mqIp, string mqName, string mqUsername, string mqPassword, string mqClientId)
        {
            try
            {
                //Create the Connection factory  
                IConnectionFactory factory = new ConnectionFactory("failover:(tcp://" + mqIp + ")");
                //Create the connection  
                using (IConnection connection = factory.CreateConnection())
                {
                    connection.ClientId = mqClientId;//客户端登录ID
                    connection.Start();
                    //将连接对象放到数组中
                    conn.Add(connection);
                    //Create the Session  
                    using (session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
                    {
                        // Destination ：消息的目的地;消息发送给谁. 
                        IDestination destination = session.GetDestination(mqName, DestinationType.Topic);
                        // 消费者，消息接收者 
                        MessageConsumer consumer = (MessageConsumer)session.CreateConsumer(destination);
                        while (true)