Catch AlreadyClosedException separatly so that if it is another kind …

…of ShutdownSignalException, we can log more details
stampy88 · Jan 7, 2011 · b5ea6c7 · b5ea6c7
1 parent 9901cc2
commit b5ea6c7
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/main/java/amqp/AmqpClient.java b/src/main/java/amqp/AmqpClient.java
@@ -17,6 +17,7 @@
  */
 package amqp;
 
+import com.rabbitmq.client.AlreadyClosedException;
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.ConnectionFactory;
@@ -194,6 +195,8 @@ protected void closeChannelSilently(Channel channel) {
         channel.close();
       } catch (IOException e) {
         LOG.warn("Problem closing down channel", e);
+      } catch (AlreadyClosedException e) {
+        LOG.debug("Channel was already closed");
       } catch (ShutdownSignalException e) {
         // we can ignore this since we are shutting down
         LOG.debug("Got a shutdown signal while closing channel", e);
@@ -208,6 +211,8 @@ private void closeConnectionSilently(Connection connection) {
         connection.close();
       } catch (IOException e) {
         LOG.warn("Problem closing down connection", e);
+      } catch (AlreadyClosedException e) {
+        LOG.debug("Connection was already closed");
       } catch (ShutdownSignalException e) {
         // we can ignore this since we are shutting down
         LOG.debug("Got a shutdown signal while closing connection", e);