Use :executor during connection recovery

michaelklishin · Aug 6, 2013 · 6ae5050 · 6ae5050
1 parent d05002b
commit 6ae5050
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/java/com/novemberain/langohr/Connection.java b/src/java/com/novemberain/langohr/Connection.java
@@ -106,7 +106,8 @@ private void recoverShutdownHooks() {
   }
 
   private void recoverConnection() throws IOException {
-    this.delegate = this.cf.newConnection();
+    ExecutorService es = (ExecutorService)this.options.valAt(EXECUTOR_KEYWORD);
+    this.delegate = this.cf.newConnection(es);
   }
 
   public boolean automaticRecoveryEnabled() {