Hi,
I'm using akka 2.3.6 on a single node on Amazon m1.large instance.
I'm using akka system as a cluster (see my configuration file below).
My akka system include several parallel identical topologies.
Each topology start with an actor that act as a MQTT client at front which
send arrived massages after processing them to some other actors (some of
them written in scala and some in java).
When starting up the system everything seem to work well.
But after a couple of hours (usually ~8-10 hours) it seem that the MQTT
actor (the first in front) is still getting it's messages and work as
expected, but when sending them to its followers nothing happened. I do not
see dead letters, or any logging (applicative \ akka) that indicate
something regarding the actors (all heartbeats are stopped).
When looking in all my logs at debug level it seem that there was no error
at all, and that this scenario happen to all my topologies at the exact
same moment.
Trying to debug it, we added an internal scheduler into the second actor in
line (the one that get messages from the MQTT actor) which send a "Tick"
message to himself every minute and print it.
As long as the system work well we see these "tick" messages, but when the
system is "down" we do not see anymore "tick" messages.
Please advice
--
>>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
# In this file you can override any option defined in the reference files.
# Copy in parts of the reference files and modify as you please.
akka {
#loggers =
["akka.event.Logging$DefaultLogger","akka.event.slf4j.Slf4jLogger"]
loggers = ["akka.event.slf4j.Slf4jLogger"]
#event-handlers = ["akka.event.slf4j.Slf4jEventHandler"]
loglevel = "DEBUG"
log-config-on-start = on
actor {
provider = "akka.cluster.ClusterActorRefProvider"
extensions = [
"akka.contrib.pattern.DistributedPubSubExtension",
"akka.contrib.pattern.ClusterReceptionistExtension"]
}
remote {
log-remote-lifecycle-events = on
enabled-transports = ["akka.remote.netty.tcp"]
netty.tcp {
hostname = "127.0.0.1"
port = 2551
}
log-sent-messages = on
log-received-messages = on
}
cluster {
seed-nodes = [
"akka.tcp://MessagingService@127.0.0.1:2551"]
#,"akka.tcp://MessagingService@127.0.0.1:2552"]
auto-down = on
}
}
