I was able to narrow down to a possible timeout, if the timeout happens, I never see the TimeoutException in the log, but it blows away the main thread. Any ideas ?
Thanks, Rufus On Thursday, 30 June 2016 12:46:55 UTC-7, Johny Rufus wrote: > > I have a server startup code, that starts an actor ( which is a > Netty/Camel Consumer) and waits for the actor to be started using > activationFutureFor > > val camel = CamelExtension(system) > Await.result(camel.activationFutureFor(serverRef), timeout.duration) > > > Intermittently what happens is, the startup code does not execute anything > after the call to activationFutureFor. > > And the only thing I see in the log is > > > "DeadLetterActorRef | Message > [akka.camel.internal.ActivationProtocol$EndpointActivated] from > > Actor[akka://ClusterServer/user/camel-supervisor/activationTracker#1266577768] > to Actor[akka://ClusterServer/deadLetters] was not delivered. [" > > > From what I gather, the failure seems to happen inside the call to > activationFutureFor. [Ideally I should not be even seeing the > EndpointActivated message in the log, as its part of the implementation of > activationFutureFor] > > > Any ideas ? > > > Thanks, > > Rufus > > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
