[CROSSDATA-577] Service discovery: Bug fixing

Stratio · Sep 12, 2016 · 67533d9 · 67533d9
1 parent a3246d1
commit 67533d9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server/src/main/scala/com/stratio/crossdata/server/CrossdataServer.scala b/server/src/main/scala/com/stratio/crossdata/server/CrossdataServer.scala
@@ -84,10 +84,10 @@ class CrossdataServer(progrConfig: Option[Config] = None) extends ServerConfig {
     Try {
       if(sLeader.await(sdc.getOrElse(
         SDCH.SubscriptionTimeoutPath, SDCH.DefaultSubscriptionTimeout.toString).toLong, TimeUnit.SECONDS)){
-        throw new RuntimeException()
-      } else {
         logger.info("Subscription leadership acquired")
         sLeader
+      } else {
+        throw new RuntimeException()
       }
     } recoverWith {
       case _ => Failure(new RuntimeException("Subscription leadership couldn't be acquired"))