[akka-user] Re: CommandFailed, bad state, can't recover

2015-07-03 Thread Sam Halliday
This is the fuller example: you need to edit the hostname and port: https://github.com/fommil/simple-spray-websockets/blob/master/src/test/scala/testing/Buggy.scala#L78 On Friday, 3 July 2015 14:25:42 UTC+1, Sam Halliday wrote: I should point out that this example is just a way that I can

[akka-user] How forgiving can my cluster fail over detector be?

2015-07-03 Thread john . vieten
In my akka cluster I see that the fail over detector often downs nodes. This happens because sometimes I have A) too much load from other processes or B) simply my actors are under heavy load (proably bad programming (-:) How can I configure my fail-over detector so that A) will not be

[akka-user] Re: CommandFailed, bad state, can't recover

2015-07-03 Thread Sam Halliday
I should point out that this example is just a way that I can reliably recreate the problem on my desktop. I have seen the same symptoms in a situation where I was expecting Acks on all messages, and not sending until the last message had cleared. Wandoulabs may have been sending ping/pong

[akka-user] CommandFailed, bad state, can't recover

2015-07-03 Thread Sam Halliday
Hi all, I'm using akka-io (and spray-io) with wandoulabs WebSockets to send messages across a network. If I send a message of this size, without expecting an Ack: connection ! Tcp.Write(FrameRender(TextFrame(A * 36040033))) and then send a message (any size), expecting an Ack:

[akka-user] Akka HTTP Streams vs Pulse Queues

2015-07-03 Thread Eric Kolotyluk
I have prototyped an application that basically multiplexes messages, assembles them into blocks, and then segments them. The application tries to do as much concurrently as possible. I have used something I call a 'pulse queue' which is based on a non-blocking concurrent queue.

Re: [akka-user] [akka-streams-1.0-RC4 scala] using actor in a FlowGraph which is a ActorPublisher and ActorSubscriber in one

2015-07-03 Thread Krisztian Lachata
Hi Martynas, I am using mapAsync with a simple method which returns a Future. The actor solution just made it unnecessarily complex. Probably custom stages would be good as well but it seemed a bit complicated for my scenario. Thanks your comment, Krisztian On Friday, July 3, 2015 at 7:47:06

[akka-user] Akka-http 1.0-RC4 on android 5.0.1 : that rocks !

2015-07-03 Thread alain marcel
Hi everybody ! Following code is a server realized with akka-http on android that serves files. For this to work, just call new ServerForDownloadFile() in an android AsyncTask. class ServerForDownloadTask extends AsyncTask[AnyRef, Void, AnyRef] { protected def doInBackground(args: AnyRef*):

Re: [akka-user] [akka-streams-1.0-RC4 scala] using actor in a FlowGraph which is a ActorPublisher and ActorSubscriber in one

2015-07-03 Thread Martynas Mickevičius
Hi Krisztian, is there any particular reason you want to use an actor for custom transformations? From the description it looks like a custom stage http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-RC4/scala/stream-customize.html would fit here better. On Tue, Jun 30, 2015 at 2:31

Re: [akka-user] Re: akka-http-extensions 0.0.1 released

2015-07-03 Thread Akka Team
Thanks for sharing! -- Konrad On Fri, Jul 3, 2015 at 6:25 AM, Anton Kulaga antonkul...@gmail.com wrote: I released another minor version of akka-http extensions and moved docs to scalatex http://denigma.github.io/akka-http-extensions/#Gettingstarted On Friday, June 19, 2015 at 10:16:05 PM