commit fc16b5cd9ffb664a025fbadfae227a1abc71f3f6
author rinrinne <rinrin.ne@gmail.com> Tue Jan 07 17:29:03 2014 +0900
committer rinrinne <rinrin.ne@gmail.com> Tue Jan 07 17:29:03 2014 +0900
tree e74f60bd55835602b3cfb7575f8606f751ca626c
parent 97e0d41ba06bd6f5c90116a6fa244dabf6e6a794

Change connection close timing

src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java

diff --git a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
index d82738b..24e68b3 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
@@ -115,7 +115,6 @@
       }
     } catch (Exception ex) {
       LOGGER.warn("#disconnect: " + ex.getClass().getName());
-    } finally {
       connection = null;
       publishChannel = null;
     }
@@ -136,5 +135,7 @@
   @Override
   public void shutdownCompleted(ShutdownSignalException arg0) {
     LOGGER.info("Disconnected.");
+    connection = null;
+    publishChannel = null;
   }
 }