pekko
pekko copied to clipboard
apache
Build highly concurrent, distributed, and resilient message-driven applications using Java/Scala
Motivation: The Cluster client is deprecated since Akka 2.6.0 and suggests using Pekko Grpc instead. Modification: Delete Cluster client code and doc. Result: Clean code.
The current one may be nested; we can make use of a chained call. eg: https://smallrye.io/smallrye-mutiny/latest/ ```scala request.ifNoItem().after(ofMillis(100)) .failWith(() -> new TooSlowException("💥")) .onFailure(IOException.class).recoverWithItem(fail -> "📦") .subscribe().with( item -> log("👍 "...
Some users are using an old version of Netty, eg, Netty 4.1.x. If the user upgrades to the new version of Pekko 1.2.x but does not upgrade other dependencies, then...
Pekko build is set up to fail if we get compile warnings. Scala nightly 2.13.17-bin-6a23d33 pekko-actor but there could be more in other modules ``` [error] /Users/pj.fanning/code/pekko/actor/src/main/scala-2.13/org/apache/pekko/util/ByteString.scala:184:15: Calls to parameterless...
We've recently seen a couple of questions around running Pekko with recent versions of Java. Even though Pekko does use sun.misc.Unsafe in some places, Pekko can be used on Java...
refs: https://github.com/apache/pekko/actions/runs/16661369799/job/47159077349?pr=1894#step:7:10408 ``` [07-31 22:45:38.371] [info] - must deliver first message *** FAILED *** (11 seconds, 310 milliseconds) [07-31 22:45:38.371] [info] java.lang.AssertionError: assertion failed: timeout (6 seconds) during expectMsg while...
It would be useful to send signal to behaviour if writing to journal failed at `org.apache.pekko.persistence.typed.internal.Running.PersistingEvents#onJournalResponse`
'must not leak actors' Can run into port binding issues. https://github.com/apache/pekko/actions/runs/15651343284/job/44096493491?pr=1904