Hello!
I have 2 actors. deployed to different nodes on cluster:
On consumer:
val mediator = DistributedPubSubExtension(context.system).mediator
override def preStart(): Unit = {
log.debug("Subscribing to urls ⇒ {}", self)
mediator ! Subscribe("urls", self)
}
and on producer:
val mediator = DistributedPubSubExtension(context.system).mediator
...
mediator ! Publish("urls", GiveMeWork)
I have the test, that verifies the flow between those actors - it starts
the cluster locally and sets up the environment. It works 100% correctly
locally, but when running on TeamCity - 1 times of 5 it gets stuck. In logs
I can see that the message was sent to "urls" topic, but it seems never
delivered to the consumer. With debug logs enabled and tracing the dead
letters I see nothing suspicious - there are no dead letters.
Is it possible that the message may get lost, or consumer "unsubscribes"
from the topic somehow? I double checked the logs, and the message is sent
to the topic after the consumers are subscribed to it - but it would be
nice to be able to trace down the delivery of the message in the topic.
Thanks!
Akka 2.3.9, Scala 2.11
P/S I'd like to create some simple test case out of my code, but it's
rather complicated and involves FSM actors, so I'd like to try other
advices before diving into this ice-hole.
--
>>>>>>>>>> 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 http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
