[akka-user] akka-http client future+flatMap or flow+asyncMap?

he second one? -- Brice Figureau <brice...@daysofwonder.com> -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additio

[akka-user] Migrating a server from spray to akka-http

ray I was doing: def receive = runRoute { dynamic { services.map(_.route).reduce((a,b) => a ~ b) } ~ ... static routes ... } I'm very unsure how I can migrate this part. Thanks for any suggestions! -- Brice Figureau <brice...@daysofwonder.com> -- >>>>>&

Re: [akka-user] akka.persistence, snapshots and deleting messages from journal

r compaction just after). HTH, -- Brice Figureau My Blog: http://www.masterzen.fr/ -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/

Re: [akka-user] Delaying recovery?

On Wed, 2015-11-25 at 14:05 +0100, Patrik Nordwall wrote: > Good catch. That requires some more thought. Please create an issue. Done in issue #19016: https://github.com/akka/akka/issues/19016 Thanks! -- Brice Figureau <brice...@daysofwonder.com> -- >>>>>>&g

Re: [akka-user] Delaying recovery?

looks like we need a specific Cluster Sharding backoff supervisor that knows how passivation works. Anyway, thanks for all your work! -- Brice Figureau <brice...@daysofwonder.com> -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>

[akka-user] Anyone using akka-persistence-cassandra under production load?

fully in RAM. I'm thinking this is related to static columns and tombstones, or the way compaction is run. So I was wondering if anyone had live production tips to share (even answers like "it works like a charm with X or Y workload") would help comfort me. Many thanks for any answers!

Re: [akka-user] akka sharding monitoring

're looking for (you also receive the global mapping of shards, which can be useful). Unfortunately I hadn't the time to implement such things, it's still on my TODO list :( HTH, -- Brice Figureau <brice...@daysofwonder.com> -- >>>>>>>>>> Read the docs:

[akka-user] Delaying recovery?

options I didn't think about? -- Brice Figureau <brice...@daysofwonder.com> -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs

[akka-user] How to survive recovery failure?

state), but it doesn't seem possible. I'm surprised that this can't be implemented in akka 2.4, and that it doesn't use the supervisor hierarchy to make the decision about what to do. Could that be planned for a future version? -- Brice Figureau <brice...@daysofwonder.com> -- >>>&g

Re: [akka-user] Akka 2.4, how to access the journal ActorRef?

On Fri, 2015-09-11 at 11:02 +0200, Brice Figureau wrote: > Hi all, > > In previous Akka (2.3 or the 2.4-Mx), we could call > > Persistence(system).journalFor() > and > Persistence(system).snapshotFor() > > to get back the various ActorRef. > >

[akka-user] Akka 2.4, how to access the journal ActorRef?

tests. I couldn't find a way to get back the ActorRef for the journals/snapshot stores, since those methods are now private to Akka. Is there a way I can do the same thing? -- Brice Figureau <brice...@daysofwonder.com> -- >>>>>>>>>> Read the docs: http:/

[akka-user] Multijvm test runs during sbt test

small. Any idea on how I can debug the problem? Thanks! -- Brice Figureau My Blog: http://www.masterzen.fr/ -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka

Re: [akka-user] Re: Mapping an akka cluster?

were running the ActorSelection in your cluster ? Do you have this actor in only one place in your cluster, or one per node ? Thanks! -- Brice Figureau brice...@daysofwonder.com -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional

[akka-user] Mapping an akka cluster?

was wondering if there would be a better way to do that? Thanks! -- Brice Figureau brice...@daysofwonder.com -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user

Re: [akka-user] How to control excessive logging from LocalActorRefprovider

the event log. Yes, that would make sense. Does /user/token-mgr-proxy/TokenManager send messages to a persistent actor, or do you know what is causing the failing resolve? I'll let the OP answer this question. -- Brice Figureau brice...@daysofwonder.com -- Read the docs: http://akka.io

[akka-user] PersistentActor and sender() use in a persist/persistAsync handler?

handlers? Thanks -- Brice Figureau My Blog: http://www.masterzen.fr/ -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because

Re: [akka-user] ClusterSharding and node address/port

a restart delay until the remote system understands there's no ActorSystem running there. I'm not sure there is a solution, though. Does this deserve a bug report? -- Brice Figureau brice...@daysofwonder.com -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs

[akka-user] ClusterSharding watching an entry?

Hi, Is it possible to watch a specific ClusterSharding entry? I just want for some actors to be notified when a given entry starts to Passivate. It's mainly to keep a record of what entries are running at one time for monitoring purposes. Thanks! -- Brice Figureau My Blog: http

[akka-user] ClusterSharding entry persistence

! -- Brice Figureau My Blog: http://www.masterzen.fr/ -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives: https://groups.google.com/group/akka-user --- You received this message because you

[akka-user] ClusterSingleton, multiple proxies?

the second solution, but unfortunately it makes the various tests a bit more complex (setup a registry instead of injecting TestProbe). What do you think? Is there a better solution I didn't think about? -- Brice Figureau My Blog: http://www.masterzen.fr/ -- Read the docs: http://akka.io

[akka-user] Persistent View needs to recover to work correctly

) probe.expectMsg(done) Thread.sleep(500) view.!(check)(probe.ref) probe.expectMsg(true) } The documentation says that it works like PersistentActor recovery (which also explains how to prevent recovery). Is that a bug or did I miss something? -- Brice Figureau My Blog: http

[akka-user] How to tell if a given persistent actor ever persisted something?

time answers queries about session existence * I'm stupid and I forgot a very obvious idea If anything, I'd like any advice on the aforementioned solutions, Many thanks, -- Brice Figureau My Blog: http://www.masterzen.fr/ -- Read the docs: http://akka.io/docs/ Check the FAQ: http

Re: [akka-user] How to tell if a given persistent actor ever persisted something?

. I'm new to this too. Thanks, I'm new too and it's a bit hard to retrofit something written to a very different persistence paradigm :) -- Brice Figureau My Blog: http://www.masterzen.fr/ -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current

[akka-user] Testing a PersistentActor

of the normal behavior of a persistent actor (I'm not yet interested in testing the persistence itself). Would it work to create a special journal that throws every event to the bitbucket and never return anything? -- Brice Figureau My Blog: http://www.masterzen.fr/ -- Read the docs: http://akka.io

Re: [akka-user] Re: Testing a PersistentActor

(currently cucumber tests) share the same actor persistent id, so the next test gets a replay of the previous events, whereas they should be fully isolated. -- Brice Figureau My Blog: http://www.masterzen.fr/ -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs

Re: [akka-user] Re: Akka 2.2.x - 2.3.y upgrade problem

and I had to recompile some of our dependencies that were using protobuf compiled files with 2.4.1. -- Brice Figureau My Blog: http://www.masterzen.fr/ -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search

[akka-user] Implicitely wrapping messages and TestKit

beside those two ones? (I really wish akka would support custom envelope data or message metadata, that would allow to create incredible things without touching any line of a given actor code :)) Thanks! -- Brice Figureau My Blog: http://www.masterzen.fr/ -- Read the docs: http://akka.io/docs