From dfeddb01cfa0db5489f677bb0f6b489241185be0 Mon Sep 17 00:00:00 2001 From: Michiel Boekhoff Date: Mon, 19 Jun 2017 11:12:06 +0100 Subject: [PATCH 1/2] Throwing exceptions after maxRetries connection attempts. --- src/main/scala/eventstore/tcp/ConnectionActor.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/scala/eventstore/tcp/ConnectionActor.scala b/src/main/scala/eventstore/tcp/ConnectionActor.scala index e274b56f..4ee135ed 100644 --- a/src/main/scala/eventstore/tcp/ConnectionActor.scala +++ b/src/main/scala/eventstore/tcp/ConnectionActor.scala @@ -142,7 +142,7 @@ private[eventstore] class ConnectionActor(settings: Settings) extends Actor with case PackIn(Failure(NotHandled(NotMaster(x))), _) => reconnect(x.tcpAddress, "NotMaster failure received") case ClusterFailure(x) => log.error("Cluster failed with error: {}", x) - context stop self + throw new RetriesLimitReachedException(x.toString) } } From d228e8eae85718413b22dc7eede4a33a4c2997ef Mon Sep 17 00:00:00 2001 From: Michiel Alexander Boekhoff Date: Mon, 26 Jun 2017 13:53:24 +0100 Subject: [PATCH 2/2] Changed timefactor for Travis. --- .travis.yml | 3 +++ src/test/resources/reference.conf | 2 ++ 2 files changed, 5 insertions(+) create mode 100644 src/test/resources/reference.conf diff --git a/.travis.yml b/.travis.yml index 1323b929..d718f072 100644 --- a/.travis.yml +++ b/.travis.yml @@ -1,5 +1,8 @@ language: scala +env: + - AKKA_TEST_TIMEFACTOR=2.0 + scala: - 2.12.2 - 2.11.11 diff --git a/src/test/resources/reference.conf b/src/test/resources/reference.conf new file mode 100644 index 00000000..61194e32 --- /dev/null +++ b/src/test/resources/reference.conf @@ -0,0 +1,2 @@ +akka.test.timefactor = 1.0 +akka.test.timefactor = ${?AKKA_TEST_TIMEFACTOR} \ No newline at end of file