[akka-user] Re: Issues using StreamTestKit

Here is my really hacky solution to the execution bounds problem: import java.lang.reflect.Field import akka.actor.ActorSystem import akka.stream.testkit.{TestPublisher, TestSubscriber} import akka.testkit.{TestKit, TestProbe} import scala.concurrent.duration.FiniteDuration /** * Really hacky

[akka-user] Re: How to lookup Maven Artifacts corresponding to Undefined Akka-Scala Classes

Actually I did find RoutingSpec ( https://github.com/akka/akka/search?utf8=%E2%9C%93=RoutingSpec) although it doesn't appear in the public docs. Perhaps what you really wanted was *ScalatestRouteTest*? On Wednesday, 31 August 2016 13:57:15 UTC+12, Jason Steenstra-Pickens wrote: > > Hard to say

[akka-user] Re: How to lookup Maven Artifacts corresponding to Undefined Akka-Scala Classes

Hard to say exactly what you need without more information. What are you trying to compile? Do you know the fully qualified names for these symbols? Some guesses: - *WS* - Not sure what this is, perhaps it was a renamed import? - *RoutingSpec* - This sounds like test class, probably not

[akka-user] Re: Issues using StreamTestKit

Hi Jason, I'm a newbie pursuing Streams testing as well. I was wondering if you had run into; or found a way through a couple of the build.sbt dependency issues I was running into with the v2.9 Docs on Akka WebSocket support with Streams? (Pls see my recent posts!) If so; would you mind

[akka-user] How to lookup Maven Artifacts corresponding to Undefined Akka-Scala Classes

I'm trying to find the build.sbt dependencies for testing Akka-Scala APIs. Would anyone be able to tell me the details for a reliable way in general to track down corresponding Maven Artifacts for undefined symbols with Scala and Akka? Thus far, I've just been copying build.sbts from

[akka-user] Issues using StreamTestKit

Hi, I'm trying to use the Probes in *StreamTestKit* but I have hit a few issues, specifically relating to the various probes. The main one is that for all types of probes (*Publisher*/*Subscriber* *ManualProbe*/*Probe*) the actual *TestProbe* is encapsulated as a private member and most of

[akka-user] Exception during creation of ActorReceiver in Spark CDH 5.5.2

I'm running Spark on CDH 5.5.2 which has a dependency on Akka 2.2.3. I'm attempting to create an actorStream in Spark, but during the creation of the actor I get the following exception. Caused by: java.lang.IllegalArgumentException: constructor public

[akka-user] research about concurrency bugs

Hello, I'm doing a research about concurrency bugs types that can be observed in languages based in actor model. I would like to know what kind of bugs can be observed frequently in Akka? Has anyone experience a behavoir such as deadlocks, livelock, starvation, race conditions, order

[akka-user] Re: Akka v2.9 Server-Side WebSocket Example

ARRR! Answering myself: Found it here: https://github.com/akka/akka/blob/v2.4.9/akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/WebSocketDirectivesSpec.scala On Tuesday, August 30, 2016 at 3:44:58 PM UTC-7, Dagny T wrote: > > > I am trying to run this code here: > >

[akka-user] Akka v2.9 Server-Side WebSocket Example

I am trying to run this code here: http://doc.akka.io/docs/akka/2.4.9/scala/http/routing-dsl/websocket-support.html I've separated out the Test code into a separate Scala Script; and am having trouble tracking down all of the necessary imports for the Test code! I'm hoping this code is part of

Re: [akka-user] How to retrieve a shard region form a different cluster node?

Hmm. ShardRegions are how you get to your sharded Actors. I believe you have to create one on the Front End if it is going to talk to the Back End entities; if you don't want the Front End one to contain any Entities, start it in Proxy Only Mode

Re: [akka-user] Subscribing to PersistentShardCoordinator startup failure

We are not using the auto-down feature, this is most likely caused by network blips in AWS. A version of Split Brain Resolver was implemented in order to avoid split cluster issues. So as far as I understand, your advice on how to detect the problem is: - have a frequent ping being sent out

[akka-user] Re: Can't execute more than 4 requests in parallel

Yes Andrew, that was it! Thanks! On Tuesday, August 30, 2016 at 4:16:20 AM UTC+10, Andrew Gaydenko wrote: > > May be without client ? > > -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html

Re: [akka-user] Method to block Migration of Cluster Sharded Actors in a Certain State

You can define a custom handOffStopMessage that your actors will receive when they are asked to stop for rebalance. You can delay the stop when receiving that message by not calling context.stop(self) until you are done. Note that if you don't stop within the handOffTimeout the rebalance will be

Re: [akka-user] BalancingPool and router actor capacity

If the work is CPU bound you should not have more worker actors than number of cores (and leave some room for other things). /Patrik On Wed, Aug 24, 2016 at 2:51 AM, Mahesh Govind wrote: > Dear Experts , > > > I have a scenario where I need to create a list of worker actors