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 98eb583..ab45387 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/AMQPSession.java
@@ -37,6 +37,13 @@
     this.pluginName = pluginName;
   }
 
+  public boolean isOpen() {
+    if (connection != null) {
+      return true;
+    }
+    return false;
+  }
+
   public void connect() {
     ConnectionFactory factory = new ConnectionFactory();
     exchangeName = UUID.randomUUID().toString();