关于断开 Rabbit MQ 连接的问题

while (falg)            {                debuglogger.info("find msg of: " + acid);                QueueingConsumer.Delivery delivery = consumer.nextDelivery();                String text = new String(delivery.getBody());                                // 解析消息                String from = "";                String to = "";              。。。。。。。。              }

当我试着去关闭 channel 通道的时候。。报以下错误：

     com.rabbitmq.client.ShutdownSignalException: clean channel shutdown; reason: #method<channel.close>(reply-code=200, reply-text=OK, class-id=0, method-id=0)at com.rabbitmq.client.QueueingConsumer.handle(QueueingConsumer.java:198)at com.rabbitmq.client.QueueingConsumer.nextDelivery(QueueingConsumer.java:214)at com.handbb.dating.mq.MQMsgMrg.recmsg(MQMsgMrg.java:251)at com.handbb.dating.action.UserAction$1.run(UserAction.java:156)Caused by: com.rabbitmq.client.ShutdownSignalException: clean channel shutdown; reason: #method<channel.close>(reply-code=200, reply-text=OK, class-id=0, method-id=0)at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:521)at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:480)at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:473)at com.handbb.dating.mq.MQMsgMrg.closeMq(MQMsgMrg.java:519)at com.handbb.dating.action.UserAction.userlogout(UserAction.java:194)at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)at java.lang.reflect.Method.invoke(Method.java:585)at com.opensymphony.xwork2.DefaultActionInvocation.invokeAction(DefaultActionInvocation.java:452)at com.opensymphony.xwork2.DefaultActionInvocation.invokeActionOnly(DefaultActionInvocation.java:291)at com.opensymphony.xwork2.DefaultActionInvocation.invoke(DefaultActionInvocation.java:254)

原因可能能为我还在不停的从队列中去接受消息，现在去关闭channel的时候。发生异常。。


现在问题是。我要怎么去合理的关闭channel，不会发生异常，或者理解为。怎么样去更好的接受消息？？

求好心人指点。。谢谢。。。