Use Connection.abort(…) instead of AMQConnection.close(…) in handleCh…

…annelKiller() This actually makes the code simpler.
rabbitmq · May 1, 2012 · 5a2bcc4 · 5a2bcc4
1 parent 8e02119
commit 5a2bcc4
Showing 1 changed file with 1 addition and 10 deletions.
diff --git a/src/com/rabbitmq/client/impl/DefaultExceptionHandler.java b/src/com/rabbitmq/client/impl/DefaultExceptionHandler.java
@@ -73,16 +73,7 @@ protected void handleChannelKiller(Channel channel, Throwable exception, String
             System.err.println("Failure during close of channel " + channel + " after " + exception
                     + ":");
             ioe.printStackTrace();
-            AMQConnection conn = (AMQConnection) channel.getConnection();
-            try {
-                conn.close(AMQP.INTERNAL_ERROR, "Internal error closing channel for " + what,
-                        false, ioe);
-            } catch (IOException ioeH) {
-                // TODO: log the failure
-                System.err.println("Failure during close of connection " + conn + " after " + ioe
-                        + ":");
-                ioeH.printStackTrace();
-            }
+            channel.getConnection().abort(AMQP.INTERNAL_ERROR, "Internal error closing channel for " + what);
         }
     }
 }