Hi Hamid,
Your configuration looks correct. I think you are fooled by the SLF4J
logging. The thread you see in the log is not the thread of the actor that
emitted the log event. You must use the %X{akkaSource} variable in the
logging pattern to see that. See:
http://doc.akka.io/docs/akka/2.3.6/scala/logging.html#Logging_Thread_and_Akka_Source_in_MDC
You can also verify by using the default logging, i.e. remove loggers =
["akka.event.slf4j.Slf4jLogger"]
Cheers,
Patrik
On Mon, Oct 20, 2014 at 12:45 PM, Hamid Fajic <[email protected]> wrote:
> HI Endre,
>
>
>
> sorry for my late feedback, I was ill last week..
>
>
>
> I followed your suggestions (and many others also, see my email from
> 10.Okt), but neither of them works, sorry.. heartbeat messages are not
> processed with "my-cluster-dispatcher".. At the end I tried with this
> application.conf, but without success:
>
>
>
> akka {
>
>
>
> # Loggers to register at boot time
> (akka.event.Logging$DefaultLogger logs to STDOUT)
>
> loggers = ["akka.event.slf4j.Slf4jLogger"]
>
>
>
> # Options: OFF, ERROR, WARNING, INFO, DEBUG
>
> loglevel = "DEBUG"
>
>
>
> # Options: OFF, ERROR, WARNING, INFO, DEBUG
>
> stdout-loglevel = "WARNING"
>
>
>
> log-config-on-start = on
>
>
>
> actor {
>
> provider =
> "akka.cluster.ClusterActorRefProvider"
>
> }
>
>
>
> remote {
>
> netty.tcp {
>
>
> hostname = "127.0.0.1"
>
> port = 2552
>
> }
>
> }
>
>
>
> # settings definition of mycluster-dispatcher
>
> mycluster-dispatcher {
>
> type = "Dispatcher"
>
> executor = "fork-join-executor"
>
> fork-join-executor {
>
> parallelism-min = 2
>
> parallelism-max = 8
>
> }
>
> }
>
>
>
> cluster {
>
> seed-nodes = ["akka.tcp://
> [email protected]:2552"]
>
> use-dispatcher =
> "akka.mycluster-dispatcher"
>
> }
>
> }
>
>
>
> What is wrong here? Can you verified your suggestions are working with
> akka version 2.3.6?
>
>
>
> Thanks and regards,
>
> Hamid
>
>
> --
> >>>>>>>>>> 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.
>
--
Patrik Nordwall
Typesafe <http://typesafe.com/> - Reactive apps on the JVM
Twitter: @patriknw
--
>>>>>>>>>> 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.