[akka-user] akka-http - state data

2016-01-24 Thread Val P
I am trying to update a spray sample to work with akka-http, first try. It's not immediately obvious to me how I should associate state data with a client connection in my service. Could someone clarify? I may have missed it in the documentation, so I apologize in advance. What I need to

Re: [akka-user] [Akka-Stream] Help to build a looping graph/flow

2016-01-24 Thread Richard Grossman
Hi Your response is crucial because I try to check if Akka stream can fit our application. We can't just think about a linear flow of event where there is only transformation from object1 to object2 *We've to make some job of Group of object from the flow. * For example we need to compare

[akka-user] akka.agent and multi-agent system

2016-01-24 Thread Manar Elkady
Hi, While I am implementing a multi-agent system application, I investigate akka.agent.Agent and I didn't notice any relation between agent in akka and the well known multi-agent concepts. Could anyone has an idea about that? Manar, -- -- >> Read the docs:

[akka-user] Re: Flow[T].map

2016-01-24 Thread Richard Rodseth
D'oh! After clicking on the Scala documentation link then searching for Flow, I then clicked on the Flow object in the java.dsl package instead of scala.dsl. I guess since I had started from the Scala documentation link I wasn't expecting Java stuff in the package hierarchy. I see the apply()

[akka-user] Flow[T].map

2016-01-24 Thread Richard Rodseth
Apologies if this is a dumb question I can do this: def augmentIntervals(extras: Extras):Flow[Interval, IntervalPlus, Unit] = Flow[Interval].map { e => IntervalPlus(e, extras) } Where does the Flow[Interval] come from? I don't see an apply method in the scaladocs for companion object Flow.

[akka-user] Akka akka.remote.Remoting akka.remote.Remoting - Association to [akka.tcp://system@ip:port] with UID [] irrecoverably failed. Quarantining address.

2016-01-24 Thread Hengky Sucanda
Hi Guys, So my system has been up and running for quite some time, but suddenly everything stopped working yesterday and i got this message: ERROR akka.remote.Remoting akka.remote.Remoting - Association to [akka.tcp://system@ip:port] with UID [-] irrecoverably failed. Quarantining address.