Re: [akka-user] Mock actorRef.tell inside an Actor class

> > Hi Arnout, > Thank you for your response. Actually i was trying to create child actors dynamically based on the some count and it might vary, like if Employer is the parent actor and employee is the child actor .so one employer can have different no of employee .so i wanted to created

Re: [akka-user] Question about Reactive Kafka performances

Like you said, 2000 msg / sec is really relly slow. The reactive Kafka consumer should consume at the same speed than the producer. Reading the benchmark examples in GitHub plus the benchmarks result in your link didn't help me to catch what I am doigt wrong. I respect the way to use the

Re: [akka-user] akka.http: Is it possible to use logic to select ssl certs?

Yup the SniKeyManager.java was a great example, the only "gotcha" is that if you extend X509ExtendedKeyManager and modify the keystore at run-time you actually need to request data from the keystore not the keymanager as suns default implementation caches on instantiation (and never updates it's

Re: [akka-user] Re: Supervision for persistent actors

You want to use Backoff supervision here, and that is actually an ordinary actor that takes care of the supervision for one other actor. You have to use a Backoff supervisor for the manager an one for each child. It only supports one-for-one. /Patrik tors 22 juni 2017 kl. 07:46 skrev Muthukumaran

Re: [akka-user] PubSub - Scribe with filter

That is not supported. You have to filter in the destination (or put another actor in-between). /Patrik tors 22 juni 2017 kl. 08:44 skrev Gajendra Naidu : > Just wondering if there is a way in AKKA - DistributedPubSub to subscribe > messages with some filter like take

Re: [akka-user] Stop singleton on all nodes then start the same singleton on all nodes.

Stopping the singleton actor is not a good idea because it will not be started again unless you stop the actor system that it was running on. I see two alternatives. 1) Stop the SingletonManager and later start it again. 2) Introduce another shallow parent actor to the actual singleton actor. The

Re: [akka-user] Threads Processing

Not sure I understand what you are trying to do, shutting down the ActorSystem is probably wrong. Perhaps you intended to stop the actor? If you want at most 12 jobs in parallel you could use a pool router with 12 routees (and don't stop them). Each actor will process its messages sequentially.

Re: [akka-user] Send null message to cluster receptionist

Sending a null message will not work, but we can avoid that match error. I created an issue https://github.com/akka/akka/issues/23215 /Patrik On Sat, Jun 17, 2017 at 7:25 AM, Konrad “ktoso” Malawski < konrad.malaw...@lightbend.com> wrote: > Why are you sending null messages? That’s illegal -

Re: [akka-user] akka.http: Is it possible to use logic to select ssl certs?

Wow this looks a great place to start, thanks! On Thursday, June 22, 2017 at 5:08:44 AM UTC-4, Arnout Engelen wrote: > > Hi Kevin, > > The technique used in the SSL handshake to select the right certificate to > match the hostname the client was connecting to is called Server Name > Indication

Re: [akka-user] Threads Processing

i suspect the issue is related to how you call 'context.system.shutdown()'. Make sure it is called only after all your messages have been processed to completion. As written, it appears to be called after the first message is handled. I'm no expert with actors, but I would guess the reason it

[akka-user] Akka http client dispatcher

Hi there, I'm wondering how to set the dispatcher on which to run all the akka-http-client operations. There doesn't seem to be any config voice for it as far as I can tell. I have assigned a separate dispatcher at the materializer that I'm using in the client, but I'm unsure if this is

Re: [akka-user] Dependency injection in Akka Http

Hi there Amer, DI is one thing, but “DI frameworks” is quite another. I for one am not a big fan of frameworks taking much control over this, however any tool/framework you want to use will “just work”, it’s just creating objects after all - Akka is very simple in that sense, no magical registries

[akka-user] Dependency injection in Akka Http

Hi guys, I'm looking for a way to inject config in various classes/traits in Akka HTTP application. Config is loaded from various files (there is custom logic for it) and it should be used in all classes. Is there any other way to do this beside guice? And BTW, do you recommend using Guice in

Re: [akka-user] Mock actorRef.tell inside an Actor class

Hi Sharanya, Thanks for your question. First of all I noticed you're creating a new ActorSystem inside this actor. That's probably not what you want: you typically create just 1 ActorSystem per application, and use "context.actorOf" to create new (child) actors from this actor. More information

Re: [akka-user] akka.http: Is it possible to use logic to select ssl certs?

Hi Kevin, The technique used in the SSL handshake to select the right certificate to match the hostname the client was connecting to is called Server Name Indication (SNI). I've never done it myself, but it seems you could add custom logic to this by writing your own KeyManager.

[akka-user] Threads Processing

Hi Akka Team, I have 100 threads, need to process only 12 threads at a time not more than that. After completion of these threads other 12 have to be processed and so on but it's processing only first 12 set threads then it terminates after that. Here is my Logic: class AkkaProcessing extends

[akka-user] PubSub - Scribe with filter

Just wondering if there is a way in AKKA - DistributedPubSub to subscribe messages with some filter like take the function as a parameter. The function should be like f(x) => boolean and send the message if the function returns true. mediator ? DistributedPubSubMediator.Subscribe(subscription,