Moved timeout config to start method

zalando-nakadi · Oct 4, 2016 · 594247e · 594247e
1 parent da13da6
commit 594247e
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/main/scala/org/zalando/react/nakadi/NakadiActorPublisher.scala b/src/main/scala/org/zalando/react/nakadi/NakadiActorPublisher.scala
@@ -40,8 +40,6 @@ class NakadiActorPublisher(consumerAndProps: ReactiveNakadiConsumer, leaseManage
   private val client: ActorRef = consumerAndProps.nakadiClient
   private var streamSupervisor: Option[ActorRef] = None
   private val reconnectTimeout: Duration = consumerAndProps.properties.batchFlushTimeoutInSeconds * 1.5
-  context.setReceiveTimeout(reconnectTimeout)
-
   private val MaxBufferSize = 100
   private var buf = Vector.empty[StringConsumerMessage]
 
@@ -129,6 +127,7 @@ class NakadiActorPublisher(consumerAndProps: ReactiveNakadiConsumer, leaseManage
 
   def start() = {
     if (!isRunning) {
+      context.setReceiveTimeout(reconnectTimeout)
       isRunning = true
       client ! ConsumeCommand.Start
     }