diff --git a/server/src/main/scala/com/stratio/crossdata/server/CrossdataServer.scala b/server/src/main/scala/com/stratio/crossdata/server/CrossdataServer.scala
index bb262d44c..52804bb2b 100644
--- 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"))