[akka-user] Re: Behavior of Akka when you sleep in an actor

> > Hi every body! I have a relative question; I want to create some heavy and thread occupier actors by akka; by using thread.sleep(5000) are the threads associated to that actors really occupied?I mean when I use thread.sleep(5000) inside an actor, does the actor occupy the thread for 5

[akka-user] is akka.actor.ActorNotFound possible after context.actorOf(...)?

I've been debugging this issue for a couple of days now. I am getting an akka.actor.ActorNotFound after doing actor selection and resolveOne. By now I am pretty confident that the actor is created via actorOf. Then I do actorDetails.actorSelection(path).resolveOne(timeout) timeout is long

Re: [akka-user] Re: Behavior of Akka when you sleep in an actor

Thread.sleep's behavior is documented here: https://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html#sleep(long) On Wed, Oct 14, 2015 at 4:14 PM, Fahimeh Rahemi wrote: > Hi every body! > > I have a relative question; > I want to create some heavy and thread

Re: [akka-user] State of ZeroMQ support (Oct, 2015)

Btw, for messaging between langs I'd rather go down the route of integrating services (be it micro or not :-)), since it's easier to maintain dependencies and messages in this style when the boundary is very explicit like this. Or you can use services like Kafka to share messages pub-sub style

Re: [akka-user] [akka-cluster] Large cluster or many clusters?

I absolutely agree. Basically it would be a cluster per microservice, even if the microservice is a domain service one, and let roles play a more fine-grained responsibility. It makes sense. Thanks! Juanjo. El mié., 14 oct. 2015 a las 10:08, Konrad Malawski () escribió: >

Re: [akka-user] State of ZeroMQ support (Oct, 2015)

ZeroMQ support has been deprecated and phased out a while ago. More info about it's deprecation is mentioned in the RoadMap update in 2014: https://www.typesafe.com/blog/akka-roadmap-update-2014 While doing the deprecation we practically didn't see any feedback (we went around asking for it) that

[akka-user] Re: Access to variable in a UntypedActor causes a permanent stall on the 55th onReceive

I expected DeadLetters to be rare, they happen all of the time. I log them but there is no visibility of why they occur and thus no hint about how we prevent them. I changed the design in the example I have given to overcome most but not all issues. The LiveIds and UnuserIds classes are no

Re: [akka-user] [akka-cluster] Large cluster or many clusters?

Hi Juan, In general it's best to think of a Cluster as something coherent - of if you want adding Roles to separate things a bit between nodes, but the cluster still serves one purpose – for example "a service" is backed by a cluster, which is multiple nodes but "one service" :) On Sat, Oct 3,

[akka-user] Re: Sharding Coordinator updates its state incorrectly after rebalancing

Thanks for your reply Patrik. I've opened an issue #18722 . Also, tried to perform exactly same actions with default state-store-mode mode, which is persistence, and that worked as expected. Mike On Monday, 12 October 2015 13:56:42 UTC+2, Mike

[akka-user] Akka remote communication roadmap?

Hi, I created a similar post some time ago but the circumstances were a bit different, the project I'm working at the moment has the requirement of processing messages within 5ms, and I chose Akka remote to do this job, the project also requires to be distributed so again, Akka remote with

Re: [akka-user] How many actors can be launched in an ActorSystem ?

Thanks a lot Heiko !! This is really helpful . On Wednesday, October 14, 2015 at 2:19:26 PM UTC-7, Heiko Seeberger wrote: > > Yes, of course. > See http://doc.akka.io/docs/akka/2.4.0/scala/dispatchers.html and > http://doc.akka.io/docs/akka/2.4.0/general/configuration.html. > > Heiko > > -- > >

[akka-user] Re: Akka remote communication roadmap?

Very nice, I wasn't aware of it, IMHO it needs something like that as proper remote communication is the foundation for distributed micro-services, our application is a FOREX trading application and we might eventually move to high-frequency trading, it is in production and for what we do at

[akka-user] Re: Akka remote communication roadmap?

Did you see this? https://github.com/typesafehub/netty-reactive-streams/blob/master/pom.xml I think it's a first step of migration to streams. It already depends on Netty 4. On Wednesday, October 14, 2015 at 12:22:33 PM UTC+3, Guido Medina wrote: > > Hi, > > I created a similar post some time

[akka-user] SharedLeveldbJournal questions

Hi, Now that Akka 2.4 is released with the new persistence-query APIs, we upgraded Akka in our application. After doing some searching, I couldn't find any persistence-query plugins yet, so in the meantime I switched to the shared LevelDB plugin. So functionally, everything works now, and I

[akka-user] How to synchronize/notify multiple parallel Actors on completion?

I've written a simple actor system, based on the "calculate Pi" example[1]. In my case, I am processing two types of (large) csv files. I load and parse the first one into a list of lines, and then split the lines into equal chunks, for multiple worker actors to process in parallel:

[akka-user] Re: [whoops] Accessing response entity as String in Akka Http

On Thursday, 24 September 2015 15:09:07 UTC+1, Konrad Malawski wrote: > I mis-clicked when accepting this email to be pushed to the mailing list, > sorry Jose! > Posting on Jose's behalf, will answer soon: > > > > > > I need to sign the response, and the signature depends on the response

Re: [akka-user] Marshalling FormData to multi-part mime with one field per part

Eric, you can create a multipart/formdata request like this, for example: val formData = { def utf8TextEntity(content: String) = { val bytes = ByteString(content) HttpEntity.Default(ContentTypes.`text/plain(UTF-8)`, bytes.length, Source.single(bytes)) }

Re: [akka-user] Re: Akka remote communication roadmap?

For extremely low latency we'd want to use a transport like Aeron. On Wed, Oct 14, 2015 at 1:34 PM, Guido Medina wrote: > Very nice, I wasn't aware of it, IMHO it needs something like that as > proper remote communication is the foundation for distributed > micro-services,

Re: [akka-user] Marshalling FormData to multi-part mime with one field per part

Hi Mathias, I think you are suggesting pretty much exactly what I did, but I did it in such a way that I didn’t have to make each body part (corresponding to a form parameter) manually (I used mapping). However, AWS/S3 will not accept the Content-Type: text/plain in the body parts. It

Re: [akka-user] How many actors can be launched in an ActorSystem ?

Thanks Heiko !! Can we change the number of threads on which ActorSystem runs?. I guess by default it is 64 threads. On Tuesday, October 13, 2015 at 10:13:08 PM UTC-7, Heiko Seeberger wrote: > > An actor without any state and with an empty mailbox weighs some 400 bytes > only, hence you could

Re: [akka-user] How is Initial Demand Generated in this Example?

Hi Konrad, I'm not looking at these configurations in order to use them in my program. I'm looking at them to understand what they're used for. I assume they serve some purpose otherwise they wouldn't exist. Specifically, what is the significance of