Fix #13 MySQLExtractor: Reconnect after some time on connection failure

ngocdaothanh · Apr 7, 2015 · 006d66a · 006d66a
1 parent 21e422b
commit 006d66a
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,8 @@
+1.6:
+
+* [#13](https://github.com/ngocdaothanh/mydit/issues/13)
+  MySQLExtractor: Reconnect after some time on connection failure
+
 1.5:
 
 * [#12](https://github.com/ngocdaothanh/mydit/issues/12)

diff --git a/src/main/scala/mydit/MySQLExtractor.scala b/src/main/scala/mydit/MySQLExtractor.scala
@@ -142,7 +142,10 @@ class MySQLExtractor(
           if (delaySecs > 0) Thread.sleep(delaySecs * 1000)
           client.connect()
         } catch {
-          case NonFatal(e) => Log.error("Error", e)
+          case NonFatal(e) =>
+            val delay = if (delaySecs > 0) delaySecs else RECONNECT_DELAY_SECS
+            Log.error(s"Could not connect, will reconnect in $delay seconds", e)
+            connectInNewThread(delay)
         }
       }
     }.start()