Re: [akka-user] handling 2 receive functions for an actor

An Actor can only have one Receive method active at any given time; by default, it's the value of receive. You can't just add another method and have it work -- it'll never be used unless you become(handler). (Or compose the two PartialFunctions together and set receive to that.) Is there a

Re: [akka-user] Patterns.Ask replacement

Hi, Yeah I was looking for something like that. But now I realized that I was trying to solve task partially. I can fully replace set of actors in my app with the complex graph in order to obtain desirable result. Thanks! понедельник, 11 июля 2016 г., 22:39:20 UTC+3 пользователь Justin du

[akka-user] handling 2 receive functions for an actor

Hi I have a class MyActorClass(out,post) where out and post are 2 actors passed as an argument to it. It has a receive function like this: def receive = { case msg:String => myfunction } and another receive function as: def handler:Receive = { case handlingMsg => //some logic case

Re: [akka-user] Patterns.Ask replacement

Ah -- yeah, if you're looking for a more Actor-compatible way to do single request/response interactions, check out Requester , which was designed for exactly this. It's intended specifically as a replacement for ask(), in a way that is relatively safe and

[akka-user] Akka create two Tcp Connections with the same port

Hi, as the title says i'm trying to create 2 tcp connections from the same port Here is the stackoverflow question: https://stackoverflow.com/questions/38314437/akka-create-two-tcp-connections-with-the-same-port I'm trying to create two tcp connections that are bound to the same port. I'm

Re: [akka-user] Akka-Stream: deploying graphs from a plain config file

Seems tractable to define a conventional format using the condig lib and interpret the config to generate the graph. Report back if you decide to do that! -- Cheers, √ On Jul 11, 2016 17:35, "Héctor Veiga" wrote: > Hi, > > I am trying to figure out if there is any way of

[akka-user] Akka-Stream: deploying graphs from a plain config file

Hi, I am trying to figure out if there is any way of deploying graphs from a plain config file. I would like to be able to define a graph using the powerful GraphDSL but instead of in Scala code, in some kind of config file. Then if you deploy that file into some folder, the stream will be

Re: [akka-user] General Question on AKKA

Like we explained many times, Akka Streams is NOT competing with Spark nor Flink–it's complementing them. Those are distributed stream processing engines. Akka Streams is a building block, that could be used to build such. So the question asked here can be translated as "Hadoop or Iterator?",

[akka-user] General Question on AKKA

Hi, I like Akka, Akka Stream and its programing model. I like it better than, Apache Sparks or Flink, I find it way more flexible. However i wonder if there is a future plan, to have a framework on top of Akka Stream, that would allow to manage jobs, submit job and so on, including coming

Re: [akka-user] Pre-fusing and materialization

Thanks for the update. On a side note, I wanted to share my appreciation to you all working on Akka and Streams. I'm very impressed with the Streams implementation. Once you wrap your head around the paradigm, it is surprisingly easy to do things that would otherwise be difficult. It is a

Re: [akka-user] Re: akka-http web socket issue

I have created a ticket for updating the docs about the client example mentioned: https://github.com/akka/akka/issues/20938 As always, contributions are welcome! -- Johan On Thu, Jul 7, 2016 at 7:42 PM, Eric Swenson wrote: > Thanks, Giovanni. That was precisely the problem

Re: [akka-user] Patterns.Ask replacement

Hi Sergey, What are you trying to achieve? In general Streams are geared more for processing pipelines than "get one element"-request-response type of interaction. -- Johan On Tue, Jul 5, 2016 at 9:22 PM, Sergey Sopin wrote: > Hi, > > Is there any possibility to replace

Re: [akka-user] Re: How to perform dataset queries with cluster sharding in cqrs?

Take a look at this section of the docs and see if that helps: http://doc.akka.io/docs/akka/2.4/scala/persistence-query.html#Performance_and_denormalization -- Johan On Tue, Jul 5, 2016 at 8:42 AM, Lap Ming Lee wrote: > Another solution I can think of is to forward the

Re: [akka-user] Using WithoutSizeLimit of akka-http on specific route entity than using max-content-length setting at config level

All directives have proper documentation, please read it: http://doc.akka.io/docs/akka/2.4.8/scala/http/routing-dsl/directives/misc-directives/withoutSizeLimit.html#example Happy hakking -- Konrad `ktoso` Malawski Akka @ Lightbend On 11 July 2016 at

Re: [akka-user] Exception during Actor construction

Please read the cluster docs: http://doc.akka.io/docs/akka/2.4/java/cluster-usage.html#A_Simple_Cluster_Example as the error hints at. -- Konrad `ktoso` Malawski Akka @ Lightbend On 11 July 2016 at 09:23:56, Drisha Roy (drish...@gmail.com) wrote: hi, I

Re: [akka-user] Exception during Actor construction

Caused by: akka.ConfigurationException: ActorSystem [akka://MQReceiver] needs to have a 'ClusterActorRefProvider' enabled in the configuration, currently uses [akka.actor.LocalActorRefProvider] -- Cheers, √ On Jul 11, 2016 09:23, "Drisha Roy" wrote: > hi, > I am getting

[akka-user] Exception during Actor construction

hi, I am getting exception like this. Cant understand why i am getting this please help. my akkaVersion = "2.4.4",play 2.5.0 [MQReceiver-akka.actor.default-dispatcher-7] [akka://MQReceiver/user/TOPIC;actionExchange] null akka.actor.ActorInitializationException: