diff --git a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/ConnectionMonitorTask.java b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/ConnectionMonitorTask.java
new file mode 100644
index 0000000..c44cf18
--- /dev/null
+++ b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/ConnectionMonitorTask.java
@@ -0,0 +1,24 @@
+package com.googlesource.gerrit.plugins.rabbitmq;
+
+import com.google.inject.Inject;
+
+import java.util.TimerTask;
+
+public class ConnectionMonitorTask extends TimerTask {
+
+  private final AMQPSession.Factory sessionFactory;
+
+  @Inject
+  public ConnectionMonitorTask(AMQPSession.Factory sessionFactory) {
+    this.sessionFactory = sessionFactory;
+  }
+
+  @Override
+  public void run() {
+    AMQPSession session = sessionFactory.create();
+    if (!session.isOpen()) {
+      session.connect();
+    }
+  }
+
+}
diff --git a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/Module.java b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/Module.java
index 4067d5c..e9ec6a6 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/Module.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/Module.java
@@ -24,6 +24,7 @@
   @Override
   protected void configure() {
     bind(AMQPSession.class);
+    bind(ConnectionMonitorTask.class);
     DynamicSet.bind(binder(), ChangeListener.class).to(PluginChangeListener.class);
     DynamicSet.bind(binder(), LifecycleListener.class).to(PluginChangeListener.class);
     install(new FactoryModuleBuilder().build(AMQPSession.Factory.class));