[akka-user] creating akka actors by using context.actorOf

Hi, On stackoverflow I read that creating akka actors using context.actorOf instead of actorSystem.actorOf incures less cost, but I don't know how to obtain this context in java. thanks Krishna Kadam -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >

[akka-user] SSL Support of akka-http(0.9)

I tried to get contents of SSL encrypted page by using akka.http.HTTP.Connect, but i couldn't.(version is 0.9) According to the code, coming api will support ssl connection by SetupHostConnector's flag, but i could not find how to do it by using current API. How do i get contents of SSL encrypte

[akka-user] Akka with Java 8 lambda support - MDC

I'm testing the experimental Java 8 lambda support with akka and AbstractActor, but I cannot seem to find a way to use the MDC feature this way. With an untyped actor, I can do Logging.getLogger(this) and get a DiagnosticLoggingAdapter with MDC support. However, since AbstractActor does not ext

[akka-user] Akka cluster and scheduled tasks

So let's say I have an akka cluster of 5 nodes. 4 are "worker nodes" and 1 is the "master" node, the master implemented via an akka singleton ( http://doc.akka.io/docs/akka/snapshot/contrib/cluster-singleton.html ). Then I use a worker registration type pattern to have the workers tell the mast

[akka-user] Passing large files as akka streams in actor messages?

Hi, An actor needs to receive messages containing the binary contents of files that can be around 35mb in size. Rather than sending an actor message containing an Array[Byte] would it make sense to send a message containing an Akka Stream (for example, a Source[Byte])? Would this also work with

[akka-user] Setting custom jms message header with Akka Camel

I'm working with Akka camel 2.3.6 and Active MQ in a small scala app and would like to set some customer headers in a producer. According to the docs for 1.3.1 this sort of thing can be done by overriding the receiveBeforeProduce method. Although this method is still referred to in the scala do

Re: [akka-user] Cluster-Shard Rebalancing of persistent actors

Hi Wolfgang, The idea behind event sourcing and persistent actors is that you should at all times be able to reconstruct the internal state of the actor by replaying the events that it has stored. The snapshot mechanism is an optimization whereby you can save the state at a certain event so tha

Re: [akka-user] Actor State and State Changes

On 06/11/14 06:26, Richard Rodseth wrote: I had in mind that I would strive to have a single var in my actors, which was a reference to an immutable object. One issue I've run into that since the actors go through various states of initialization (using become), I find myself with bits of state

Re: [akka-user] About akka dispatcher

Hi, Have you read the documentation on dispatchers? http://doc.akka.io/docs/akka/2.3.6/scala/dispatchers.html It describes both configuration of dispatchers and the different types of dispatchers available. B/ On 6 November 2014 at 07:44:16, Krishna Kadam (shrikrishna.kad...@gmail.com) wrote

Re: [akka-user] Unrecoverable "gated" state in remote system

Hi Robert, On Wed, Nov 5, 2014 at 9:55 PM, Robert Preissl wrote: > hello! > > I am having a problem in my remote Akka production system, which consists > of 3 nodes running with the latest version of Akka (2.3.6.): > > In more details, I am experiencing errors with "*rolling restarts*" of > the