akka
akka copied to clipboard
akka
Build highly concurrent, distributed, and resilient message-driven applications on the JVM
We have `akka.persistence.typed.stash-capacity` to configure a global limit how many commands can be stashed within a EventSourcesBehavior / DurableStateBehavior. Provide an api to override this global config per entity.
## First Commit Looks like a documentation error. the example code like this: https://github.com/akka/akka/blob/5a1bccf5aa98556c2a366413d7ae22334894ba9c/akka-cluster-sharding-typed/src/test/java/jdocs/delivery/PointToPointDocExample.java#L111-L121 ## Second Commit i am not sure there is object name like `ProducerConsumer`, i think it...
With Aeron: https://github.com/akka/akka/runs/5546435083?check_suite_focus=true#step:5:3117 ``` [WARN] [03/15/2022 00:22:50.638] [pool-1-thread-1-ScalaTest-running-RemoteFailureSpec] [akka.actor.ActorSystemImpl(RemoteFailureSpec-remote-0)] Failed to load JFR flight recorder, falling back to noop. Exception: java.lang.ClassNotFoundException: akka.remote.artery.jfr.JFRRemotingFlightRecorder 3105 [WARN] [03/15/2022 00:22:50.638] [pool-1-thread-1-ScalaTest-running-RemoteFailureSpec] [akka.remote.RemoteActorRefProvider] Akka Cluster...
https://github.com/akka/akka/runs/5780258482?check_suite_focus=true#step:5:946 ``` [04-01 00:20:20.326] [info] - must log dead letters *** FAILED *** (6 seconds, 56 milliseconds) 947 [04-01 00:20:20.326] [info] java.lang.AssertionError: timeout (6 seconds) waiting for 1 messages on...
https://github.com/akka/akka/runs/5608122450?check_suite_focus=true#step:5:35271 ``` [info] - must deliver unconfirmed if ShardingConsumerController is terminated *** FAILED *** (1 second, 730 milliseconds) [info] Job(msg-3) did not equal Job(msg-4) (ReliableDeliveryShardingSpec.scala:402) [info] org.scalatest.exceptions.TestFailedException: [info] at org.scalatest.matchers.MatchersHelper$.indicateFailure(MatchersHelper.scala:339)...
https://github.com/akka/akka/runs/7484358602?check_suite_focus=true#step:5:1043 ```scala [info] TypedActorRemoteDeploySpec: Coroner Thread Count starts at 37 in akka.remote.TypedActorRemoteDeploySpec [info] Typed actors [info] - must be possible to deploy remotely and communicate with *** FAILED *** (3...
Using version 2.6.19. As the title mentions, setting the following value in `application.conf`, `reference.conf` or `-D` arguments still logs that the messages are sent to deadletters. ``` akka.cluster.pub-sub.send-to-dead-letters-when-no-subscribers=off # or...
We can use `Sink.combine` for some fan-out strategies like `Broadcast`: ```scala Source(List(0, 1, 2)) .to( Sink.combine( Sink.foreach[Int](left => println(s"left = ${left}")), Sink.foreach[Int](right => println(s"right = ${right}")) )(Broadcast[Int](_)) ) .run() ```...
Concept (and implementation of course 😄 ) inspired by Lagom Framework. I'm sure it can be very useful not only for Lagom users but also for Play Framework and Akka...
