Re: [akka-user] Testing Akka Persistence Recovery

Thanks, but if I do this: system.stop(subscriber1) val subscriber2 = system.actorOf(props1, "name1") I get an error that "name1" is not unique. The actor's persistence id is: override val persistenceId: String = "subscriber-" + self.path.name On Wed, Oct 12, 2016 at 9:59 PM,

Re: [akka-user] Testing Akka Persistence Recovery

You can stop it and start a new actor with the same persistenceId. /Patrik tors 13 okt. 2016 kl. 06:33 skrev Richard Rodseth : > I've been able to test recovery by using the in-memory journal and sending > a "bomb" message to the actor, which is handled by throwing an

[akka-user] Testing Akka Persistence Recovery

I've been able to test recovery by using the in-memory journal and sending a "bomb" message to the actor, which is handled by throwing an exception : myActorRef ! DoSomething myActorRef ! "bomb" myActorRef ! GetState expectMsg(MyActorState(...)) Is there any way I can do this without having to

[akka-user] Re: MultiNodeSpec- any way to combine a result from multiple nodes?

Never mind, found the solution to this: val node1testActor = system.actorSelection(node(first) / "system" / "testActor1") node1testActor ! results On Wednesday, October 12, 2016 at 3:53:12 PM UTC-7, Evan Chan wrote: > > Hi Hakkers, > > So I'm using MultiNodeSpec to test some Akka Cluster

[akka-user] Replaying journal events without actually recovering Actors?

Hello all, In order to test that no unaccounted-for serialization changes have happen before we deploy our service, I need some way for us to *attempt* to deserialize all currently stored events in our event journal and snapshots. Currently, we just use the local leveldb plugin with local

[akka-user] MultiNodeSpec- any way to combine a result from multiple nodes?

Hi Hakkers, So I'm using MultiNodeSpec to test some Akka Cluster functionality. Basically I have a consistent hashing router which hashes based on each node's Akka system address, and thus the port number is essentially random. Thus from run to run of the test I cannot predict how many

Re: [akka-user] Re: Completion of a Graph with a Cycle

Have you seen http://doc.akka.io/docs/akka/2.4/scala/stream/stream-dynamic.html#Controlling_graph_completion_with_KillSwitch ? -- Konrad `ktoso` Malawski Akka @ Lightbend On 12 October 2016 at 15:42:01, external.stefan.wach...@bosch-si.com (

[akka-user] Re: Completion of a Graph with a Cycle

I think I found a general solution in the meantime. We have a "semaphore" component that wraps a flow and tracks / delimits the number of elements that may be "in flight" at the same time in the wrapped flow (the flow must have a 1:1 relationship between its input and output).The semaphore

Re: [akka-user] Re: What's the replacement for Akka Actor Publisher and Subscriber?

+1, especially if either would enable using Akka Streams idiomatically with clustered Actors. That would make Streams *vastly* more useful for those of us who want to use WebSockets and other HTTP streaming input in cluster-sharded applications. I've had to instead build my own (fairly naive and

Re: [akka-user] Re: Journal Plugin Java API question regarding doAsyncWriteMessages

It will not be restarted. It will be stopped. You must anyway handle journal failures. ons 12 okt. 2016 kl. 09:44 skrev Daniel Stoner : > Beware that if you don't handle serialisation failures as rejection - then > you can easily get into a state whereby another actor

Re: [akka-user] How to handle web socket message to upload base64 encoded string of 10mb file

thanks Rafal for reply :) Thanks & Regards | Narayan Kumar Software Consultant *Knoldus Software LLP* Twitter | LinkedIn +91-8510013849 On Tue, Oct 11, 2016 at 9:48 PM, Viktor Klang

[akka-user] Re: akka.http.scaladsl.model.Uri's apply() methods should still take charset and mode parameters?

> The last comment there by 2beaucoup was exactly what I am asking here. That's me BTW. There's no reason one can't pick up on this with an issue/PR in akka/akka-http. ;) Cheers André On Tuesday, October 11, 2016 at 7:39:57 PM UTC+2, Richard Imaoka wrote: > > Thank you, I was missing that

Re: [akka-user] Re: Journal Plugin Java API question regarding doAsyncWriteMessages

Beware that if you don't handle serialisation failures as rejection - then you can easily get into a state whereby another actor keeps sending a message that simply will not serialise when persisted. Your only awareness of this will be the log errors that might occur in your JournalImpl and

[akka-user] Re: ('=') sign still not allowed in query string even with Uri.ParsingMode.Relaxed? (akka/akka#18479)

I know it's long but please read the full discussion in https://github.com/akka/akka/issues/18479. The problem isn't the question mark but the double "=". That's why you get an IllegalUriException: Illegal query: Invalid input '='. > will try to work on #276 if no one is picking it up yet

[akka-user] Completion of a Graph with a Cycle

Hi all, is there a principled way to complete a graph that contains a cycle? The basic problem is that the initial Merge component can either complete eagerly or not. Both settings are suboptimal (if it completes not eager it will complete never, if it completes eager elements in the feedback

Re: [akka-user] Re: What's the replacement for Akka Actor Publisher and Subscriber?

In addition to what has already been said there will be a few more options: - Gearpump is implementing distributed streaming with Akka Streams - We will evaluate if it's suitable to make an Akka Streams API on top of ReactiveSocket