commit 96bb01e47065c4a6ac8d37f88f6292ba025996ae
author rinrinne <rinrin.ne@gmail.com> Thu Jul 31 19:37:57 2014 +0900
committer rinrinne <rinrin.ne@gmail.com> Thu Jul 31 19:37:57 2014 +0900
tree 011c4120c3977bdb25161feae794e694f25dcd73
parent 566cacaa5dc510fad87aee18c2971652799efb6b

Do connect if connection is none on getChannel()

This can reconnect session even if connection suddenly disconnected.

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 c0215f5..ce0f729 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
@@ -55,6 +55,9 @@
 
   private Channel getChannel() {
     Channel ch = null;
+    if (connection == null) {
+      connect();
+    }
     if (connection != null) {
       try {
         ch = connection.createChannel();