Re: [akka-user] Unit testing Akka-http low level API

Noted, will do :) On Sep 22, 2015 19:30, "Val P" wrote: > Thank you, that helps. Yes, it would be helpful to have a note in the > documentation, or even an example on how to test the low level examples in > the documentation. > > > On Monday, September 14, 2015 at 10:56:00

Re: [akka-user] Which actor methods are ok to call in a future callback?

Let me say it again: Don’t ever use callbacks in actors! How could I say it any clearer? Heiko -- Heiko Seeberger Home: heikoseeberger.de Twitter: @hseeberger Public key: keybase.io/hseeberger > On 22

Re: [akka-user] Unit testing Akka-http low level API

Thank you, that helps. Yes, it would be helpful to have a note in the documentation, or even an example on how to test the low level examples in the documentation. On Monday, September 14, 2015 at 10:56:00 AM UTC-5, Konrad Malawski wrote: > > Hi Val, > notice that the high-level API has it's

Re: [akka-user] Re: Which actor methods are ok to call in a future callback?

On Tue, Sep 22, 2015 at 9:20 AM, John Ulric wrote: > @Heiko, @Roland, thanks. The callback in my case essentially makes a > decision where to send the future result (to self, to a delegee actor, to > the calling actor) plus some error handling, logging and monitoring, so it >

Re: [akka-user] Re: Akka behaviour

Hi Patrik, Thank you for clarification. I have been using onComplete() procedure in order to check response status, but now I have replaced it with the Future.map(). As result of map() operation I have a new transformed Future. In my case all child actors send to response to caller actor

Re: [akka-user] [akka-streams] controlling deployment of children of ActorSubscriber via conf

Isn't it typically that you just want to configure one or a few things of your router, like the pool size? Then you can read that from a separate config property. Another solution that might work is to use wildcards in the the deployement config path. It is still a bit fragile in respect to

Re: [akka-user] [akka-streams] Flow mapAsync implemented with Actor ask pattern does not work

That should work. I see one problem with you example. In flickrRdfToJson you are using context of the enclosing actor to create the FullSubjectQueryActor. It is not allowed to use context from other threads than the actor's receive thread. In this case you are calling it from the stream execution

Re: [akka-user] akka-cluster handling of network failures - no remote actors and no auto-down

Hi, On Wed, Sep 9, 2015 at 10:17 PM, Andrzej Dębski wrote: > Hello, > > Currently I am in process of rewriting and unifying old JGroups based > messaging mechanisms in an application to akka based solution. > > For now akka-cluster will be used as a mechanism to know

[akka-user] How to run multi-node test

I am using Intellij 14.1 and I run the multi-node test. I notice a few things 1) The multi-jvm folder is automatically unmarked as the *Test Sources Root* 2) It causes an exception : *Caused by: java.lang.IllegalStateException: need system property multinode.max-nodes to be set* Here are

Re: [akka-user] Akka persistence - compatibility of file-persistence journals and snapshots

On Fri, Sep 18, 2015 at 11:59 AM, Muthukumaran Kothandaraman < muthu.kmk2...@gmail.com> wrote: > Following are the aspects of my usage > > - Using same app code which uses same akka version and its dependencies on > more than 1 node > - All nodes are symmetric and use their individual disks to

Re: [akka-user] Re: Akka behaviour

The supervisor strategy comes into play when a child actor throws an exception. That is not something that happens automatically because of a ask timeout. Normally you use ask together with pipeTo and then you will receive a akka.actor.Status.Failure message with the exception cause. Note that

Re: [akka-user] How to recover from network partition quarantine

For the archives (and I promised to get back): Akka Split Brain Resolver (Akka SBR) is a new commercial feature available exclusively to Typesafe PSS subscribers. It's part of the Typesafe Reactive Platform and implements a number of strategies on how downing can be performed more safely than

Re: [akka-user] Re: Problem creating a balancing router for a stream sink

I think there have been some issues around balancing pool configuration that are fixed in 2.4. You can try with Akka version 2.4.0-RC3. On Tue, Sep 15, 2015 at 11:13 AM, Yusuke Yasuda wrote: > I got the same error. My situation is same as @Nicolau, using >

Re: [akka-user] [streams] Trouble merging multiple Sources in FlowGraph

I think it should be: val graph = FlowGraph.closed() { implicit b => val merge = b.add(Merge[(SerialNumber, Double)](sensorSources.size)) sensorSources.zipWithIndex.foreach { case (src, i) => b.addEdge(b.add(src), merge.in(i)) } b.addEdge(merge.out, b.add(consoleSink)) }

Re: [akka-user] Akka at Comcast: SOA on Steroids and the Actor Service Registry for Akka

Hi David, Thanks for sharing! /Patrik On Sat, Sep 19, 2015 at 8:19 PM, 'David Bolene' via Akka User List < akka-user@googlegroups.com> wrote: > At the Scala by the Bay meetup this week Comcast presented how the Akka > platform has been applied successfully at scale to continuous delivery and >

[akka-user] Combine FSM[S, D] and DiagnosticActorLogging

Hi together, *Overview:* I want to combine the FSM trait with DiagnosticActorLogging. This leads to compile time errors. I was able to resolve the error by overriding the log value, however I don't like the solution... Maybe one of you has a better idea ! *Details:* Consider the following

Re: [akka-user] Re: CORS Support Akka-http

Hi Everyone, I ended up porting and modifying Ganta's original CORS support with an existing one I had that I pulled from the Spray mailing list awhile back and posted it here: https://gist.github.com/pcting/2e65c36f868c5cee7d6a The most frustrating part was finding a way around the loss of

Re: [akka-user] Flow/Stage from reactive Publisher

Have you looked at flatten (concat)? /Patrik On Sun, Sep 20, 2015 at 2:57 PM, Muki wrote: > Hi, > > I'm currently experimenting with elastic4s reactive streams extension > and akka > streams. What I want

Re: [akka-user] Akka Spring Extension with non default constructor

Perhaps you can find something useful in this Activator tutorial: http://www.typesafe.com/activator/template/akka-java-spring /Patrik On Mon, Sep 21, 2015 at 11:55 AM, Michał Wasilewski wrote: > Hi, > > I am using Spring extension to support autowiring capabilities

Re: [akka-user] not-experimental streams?

All new modules are initially marked as experimental to be able to change the APIs more easily based on our users’ feedback. Experimental does not mean that it has lower quality. Some experiments fail and are phased out, typically with another replacement. We are confident that Akka Streams will

Re: [akka-user] not-experimental streams?

On Tuesday, September 22, 2015 at 12:57:19 PM UTC+3, Patrik Nordwall wrote: > > We are confident that Akka Streams will be successful. > Great, thanks for the clarification! > -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] Akka persistence - compatibility of file-persistence journals and snapshots

Thanks Patrik. I am yet to test this. I was suspecting if the entries made to journal or snapshot could be encoded with node-specific data. On second thought, since persistence also stores journals to other shared databases like Cassandra, there is no reason why this should have issues with

[akka-user] Re: Which actor methods are ok to call in a future callback?

@Heiko, @Roland, thanks. The callback in my case essentially makes a decision where to send the future result (to self, to a delegee actor, to the calling actor) plus some error handling, logging and monitoring, so it is a pipe, essentially. I found the code more readable when I make these

Re: [akka-user] [akka-streams] Flow mapAsync implemented with Actor ask pattern does not work

Thanks a lot! I guess there is no way for the actor system to detect and warn for this erroneous pattern? Or hopefully I am the only one making this error :-) Op dinsdag 22 september 2015 10:02:48 UTC+2 schreef Patrik Nordwall: > > That should work. I see one problem with you example. In