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.
