This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a change to branch feat/sink-watch-termination
in repository https://gitbox.apache.org/repos/asf/pekko.git
omit d9127e264d fix: format WatchedSink and fix concurrent materialization
race in Sink.watchTermination
omit 5f5f9dd52e feat: support arbitrary composite sinks in
Sink.watchTermination
omit 4e056af7af fix: delegate dynamically to inner handler in
WatchedSinkLogic
omit 269a2d3d51 style: scalafmt formatting for WatchedSink
omit df56648f25 refactor: fuse InHandler into WatchedSinkLogic and use
OptionVal
omit 9f13fb3eaa feat: add Sink.watchTermination operator
add 87d45050f5 warn if pekko-remote is not using tls (#3400)
add 9de429085b chore(deps): bump sbt/setup-sbt from 1.5.4 to 1.5.6 (#3405)
add c946594ebd Clean up todos in traversal builder (#3371)
add bea68d076c Update netty-handler, netty-transport to 4.2.17.Final
(#3412)
add 75d6a6bd75 Remove Test Reports step from workflow (#3413)
add 718bc072bb filter messages from remember-entities store (#3411)
add 2e5c450633 feat: add timeout duration to ReceiveTimeout message (#3399)
add dfde20edcd Update lz4-java to 1.11.2 (#3415)
add 851569fa5e Update junit-jupiter-engine to 6.1.3 (#3417)
add 72d580eabf Update sbt-paradox, sbt-paradox-theme to 0.11.0 (#3416)
add d7a252ef7e Update sbt, scripted-plugin to 1.12.15 (#3419)
add 3040667e5d Update junit-platform-launcher to 6.1.3 (#3418)
add 65704fa51c chore(deps): bump coursier/setup-action from 3.0.0 to 3.0.2
(#3424)
add fe18b8d6c1 Update logback-classic to 1.6.2 (#3426)
add e5698257bf ByteString performance (#3427)
add e33ed4ea5a Update jacksonAnnotationsVersion to 2.22 (#3431)
add 54c60e2061 Add LeaseHealthCheck (#3423)
add 72e663f9d2 add akka PRs from v2.8.4 (#3432)
add 6574499688 support PEKK TCP magic (#3425)
add fd478baa90 test: add Java test for retry short-circuit with Predicate2
(#3435)
add 5293186b72 test: harden PersistentActorRecoveryTimeoutSpec receive
timeout test (#3436)
add 3183f6d5f4 improve ByteString slice method (#3428)
add cbd431bd6d ByteStrings: cross-boundary swar (#3430)
add b1b9b2924b Update logback-classic to 1.6.3 (#3441)
add 26937c3779 Update jctools-core to 4.0.7 (#3442)
add f4ae024eb5 Update jackson-core to 3.2.2 (#3443)
add 44e6eaf68d chore(deps): bump sbt/setup-sbt from 1.5.6 to 1.5.7 (#3447)
add 6a249a9582 Update jimfs to 1.3.2 (#3451)
add 734e128724 Update jackson-core to 2.22.2 (#3450)
add 336474b413 Update biz.aQute.bndlib to 7.4.0 (#3449)
add f3d21d6619 release notes for 1.7.0 (#3445)
add 27267bc7ec Update workflow to use Pekko 1.7.x (#3454)
add 064f24ed52 Update sbt, scripted-plugin to 1.13.0 (#3456)
add 2525858f07 Update protobuf-java to 4.36.0 (#3455)
add f9a08e0487 link-validator: record summary (#3457)
add 9d9771347e release notes for 2.0.0-M4 (#3448)
add 3a601fa751 refactor: replace immutable.Traversable in the public io
and stream APIs (#3468)
add c10661e205 refactor: replace deprecated collection aliases in internal
io code (#3467)
add 901643c433 Fix image paths in substream docs (#3470)
add 6be39c658f chore(deps): bump sbt/setup-sbt from 1.5.6 to 1.5.8 (#3460)
add a054f9cef4 fix: preserve StageActor demand across fused streams (#3461)
add 90b02d6068 fix: make AbstractPersistentActorWithTimers and
AbstractFSMWithStash subclassable from Java on Scala 3 (#3475)
add 3534c14917 Update aeron-client, aeron-driver to 1.52.3 (#3480)
add 6bbd5d041d fix: log the classic hostname verification warning at
warning level (#3479)
add 2d7f8187d5 build: stop CI switching the default SecureRandom away from
NativePRNG (#3482)
add cd5aff211b docs: correct the stale SHA1PRNG entropy note (#3481)
add fde63d427e docs: document the internal APIs that the OpenTelemetry
agent instruments (#3473)
add d23eb51f3a perf: avoid copying the temp buffer in
ByteStringBuilder.result (#3471)
add b58311c76c fix: handle post-Java 8 constant pool entries in
LineNumbers (#3465)
add 3d32394c3a perf: faster ByteString equality and fragment lookup (#3463)
add 0546b2cdc6 docs: document post-handshake session verification for TLS
(#3462)
add 3911c03a27 refactor: use bit operations for the DNS over TCP length
prefix (#3466)
add 4063556db3 feat: add ByteString slice-free copyToArray and
decodeString overloads (#3464)
add ed135b6172 Update metrics-core, metrics-jvm to 4.2.40 (#3486)
add 6c4615a18e Update aeron-client, aeron-driver to 1.53.0 (#3485)
add 0f676613b5 chore: update scala3Next to 3.9.0 (#3303)
add 80477d3d21 docs: remove stale Java 8/11 framing now that JDK 17 is the
minimum (#3487)
add d0048e448e docs: refresh stale TLS security recommendations in
remoting docs (#3489)
add 21f4702f9c build: bump agrona to 2.5.0 to match the version aeron
1.52.3 depends on (#3488)
add 43695a7bae fix: use a Seq rather than a Set to hold TCP magic
ByteStrings (#3484)
add ac8d2bfd59 chore(deps): bump actions/setup-java from 5 to 6 (#3497)
add 8391a2212e fix: bound compression-pointer hops in DNS name parsing
(#3490)
add fcc340ce9a fix: bound inbound Artery TCP frame length at framing
(#3492)
add 8181d87721 test: fix flaky FusingSpec activeStage assertion (#3496)
add fd19b01453 fix: bound Jackson payload decompression size (#3491)
add 347264aa0f fix: check the remote deployment allow list before
deserializing constructor args (#3493)
add cffd027b89 fix: don't resolve a wire-supplied manifest class the
serializer will not use (#3495)
add 3def3978a7 fix: bound nesting depth when deserializing enclosed
payloads (#3500)
add 12d3d85260 docs: fix comment placement around
serialization-max-nesting-depth (#3511)
add 6dd3445e38 Update protobuf-java to 4.36.1 (#3512)
add f7b0115d37 fix: don't resolve HOCON includes in config that arrived in
a message (#3505)
add ec6293149b fix: match actor selection wildcards without backtracking
(#3506)
add 6751ab98b7 fix: bound the number of entries in a compression table
advertisement (#3510)
add 67c3b557e5 fix: resolve, check and parse manifests more carefully in
the Jackson serializers (#3503)
add f062f2332b fix: bounds check the lookup table indexes in gossip (#3508)
add 9d80429d4c fix: default the Jackson max-decompressed-size to unlimited
(#3515)
add 4efa8195a5 test: cover the per-stream frame-size bound in TcpFraming
(#3524)
add 6783903abf fix: bound the size a compressed payload may expand to
(#3502)
add 35c9895fbd Update jul-to-slf4j, log4j-over-slf4j, ... to 2.0.19 (#3531)
add 0c1de3363f remove the Akka 2.6.4 rolling-migration manifests from
ClusterMessageSerializer (#3516)
add dcff589c4b protoc 4.36.0 (#3514)
add a2a15df7e6 support "unlimited" for the Jackson stream-read constraints
(#3522)
add 3c5449c137 fix: don't dereference a null superclass in the protobuf
allow list check (#3509)
add ff10ec2cca fix: reject messages whose parallel repeated fields
disagree in length (#3507)
add c9cba616eb Add a draft threat model and wire it for discoverability
(#3478)
add f9f8db5c74 feat: load every certificate in the rotating keys engine
ca-cert-file (#3528)
add 819ec921bd perf: avoid redundant bounds checks on ByteString indexed
reads (#3533)
add 14dc8a676c fix: close IO resources left open on abrupt or failing
paths (#3532)
add 4436b439e0 Update sbt-scalafix to 0.14.8 (#3534)
add dde3e924f0 Update sbt-mima-plugin to 1.2.0 (#3535)
add ce44fbe7a1 Update netty-handler, netty-transport to 4.2.18.Final
(#3536)
add b765c5b19c perf: use slf4j placeholders instead of string
interpolation in logging (#3537)
add 845f933edb Update aeron-client, aeron-driver to 1.53.1 (#3540)
add 6db9cafd59 build: upgrade agrona to 2.6.0 (#3543)
add 769718e1a6 chore: add Apache license headers to logback configs, shell
scripts and benchmark template (#3545)
add 1f573c9932 docs: remove unused warnOldDocs.js and
projectSpecificFooter template (#3547)
add de6afb0459 chore(deps): bump coursier/setup-action from 3.0.2 to 3.0.3
(#3548)
add 78d48900fb build: apply the Develocity Common Custom User Data sbt
plugin (#3546)
add 5f88a2d7b8 Update jackson-core to 3.2.3 (#3561)
add d64c25c64f Update agrona to 2.6.1 (#3560)
add c99cd97c0a Update aeron-client, aeron-driver to 1.53.2 (#3559)
add 9441a2166f Update sbt-api-mappings to 3.1.0 (#3557)
add c064384a1b Update lz4-java to 1.11.3 (#3553)
add ded20b7cd0 Update sbt-scalafix to 0.14.9 (#3554)
add f7d9761ee8 Update protobuf-java to 4.36.2 (#3556)
add 8ef3bf7c6d Update jackson-core to 2.22.3 (#3555)
add a2ab4a06fb Update sbt-mima-plugin to 1.2.1 (#3558)
add c2bc0f1cc1 Update jul-to-slf4j, log4j-over-slf4j, ... to 2.0.20 (#3562)
add ab5897bee1 Ignore "method add in trait Marker is deprecated" warnings
(#3566)
add b1d883410a Update aeron-client, aeron-driver to 1.53.3 (#3565)
add c34d03a844 Update lz4-java to 1.11.4 (#3563)
add 2e1d189db6 Update logback-classic to 1.6.4 (#3564)
add f795440964 Update lz4-java to 1.12.0 (#3568)
add fef71efd85 chore: remove leftover Scala 2.12 idioms (#3539)
add 19b13cf751 Update logback-classic to 1.6.5 (#3570)
add 93a9c52c3f Update sbt-java-formatter to 0.14.0 (#3571)
add 3f7ee114fa Update sbt-paradox, sbt-paradox-theme to 0.11.1 (#3572)
add e3955c6bf9 release notes for 1.7.1 (#3529)
add ecd05d1d64 docs: rename 'Bug Fix' release notes heading to 'Bug Fixes'
(#3575)
add b24ec65a81 Update netty-handler, netty-transport to 4.2.19.Final
(#3578)
add 15fd7dc72a chore(deps): bump coursier/setup-action from 3.0.3 to 3.0.4
(#3576)
add 1dd51690af docs: fix wrong PR links and other mistakes in the release
notes (#3598)
add 0caf3defdd docs: document the Jackson compression
max-decompressed-size limit (#3597)
add 1c79623bdf docs: remove the duplicated external address snippet in
classic serialization (#3596)
add 93b48ec6c0 docs: mention querying durable state changes by slices
(#3595)
add b1a028c2da docs: list the read consistency levels on the classic
Distributed Data page (#3594)
add eb782e3731 docs: add the Scala tab to the reliable delivery sharding
init example (#3593)
add 0f74543359 docs: fix markup that breaks page rendering (#3579)
add 08c841f0f1 docs: link the fault tolerance sample from the fault
tolerance page (#3581)
add 0fa5809069 docs: document jackson3 module, JUnit Jupiter test kit and
missing config (#3585)
add c07a5476af docs: list configuration changes in the 1.x to 2.x
migration guide (#3513)
add 6bddca4f9c docs: fix broken links, anchors and snippet labels (#3587)
add 8a012b9689 docs: fix typos and grammar (#3588)
add 6e32da242f chore: fix limit and limitWeighted Scaladoc (#3591)
add d2d52f30f1 chore: remove stale Akka-era references from Scaladoc and a
log message (#3584)
add 2ca08f43db docs: fix outdated content and wrong config keys and API
names (#3583)
add 947459288d docs: fill stream operator doc gaps and add missing
overloads (#3590)
add 60fb29bca5 chore(deps): bump sbt/setup-sbt from 1.5.8 to 1.5.11 (#3567)
add a5cf13f26c perf: optimise UnsynchronizedByteArrayInputStream bulk
operations (#3541)
add e336453c66 perf: validate actor path elements without String.charAt
(#3542)
add c37d875caf fix: stop entities stuck in passivation after a timeout
(#3573)
add 83e6875962 test: cover clearing of failed in-flight DNS requests so
they can be retried (#3549)
add 41752c0e30 test: make RemotingSpec bind retry match the classic Netty
BindException (#3551)
add a5cb8e9653 test: cover that harmless quarantine does not trigger
DownSelfQuarantinedByRemote (#3550)
add 5fd306e27a perf: resume the ByteStrings fragment hint backward as well
as forward (#3526)
add a0aaee36e4 ci: pin site-link-validator to 0.2.5 and fix broken doc
links (#3604)
add 7244cd1c94 chore: remove @ApiMayChange from APIs that have proven
stable (#3607)
add 7fdcf7dbc1 cluster-sharding: drop Akka 2.3 support from
RemoveInternalClusterShardingData (#3608)
add eeb3b10b88 fix: keep colliding virtual nodes in ConsistentHash (#3611)
add 3b1359aa5a fix: allow overriding testKit in ScalaTestWithActorTestKit
(#3610)
add b8625a6143 fix: resolve LogSource for getClass results on Scala 3
(#3609)
add 559c5b9cee docs: add code examples for migrating off deprecated
Source.queue overloads (#3605)
add b3f259cc6c build: add nightly multi-jvm test workflow (#3602)
add 659fd4db5f feat: add Sink.watchTermination operator
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (d9127e264d)
\
N -- N -- N refs/heads/feat/sink-watch-termination (659fd4db5f)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/binary-compatibility-checks.yml | 4 +-
.github/workflows/build-test-prValidation.yml | 18 +-
.github/workflows/dependency-graph.yml | 2 +-
.github/workflows/format.yml | 2 +-
.github/workflows/generate-doc-check.yml | 4 +-
.github/workflows/headers.yml | 4 +-
.github/workflows/link-validator.yml | 8 +-
.github/workflows/nightly-1.0-builds.yml | 16 +-
.github/workflows/nightly-1.1-builds.yml | 16 +-
.github/workflows/nightly-1.2-builds.yml | 16 +-
.github/workflows/nightly-1.3-builds.yml | 16 +-
.github/workflows/nightly-1.4-builds.yml | 16 +-
.github/workflows/nightly-1.5-builds.yml | 16 +-
.github/workflows/nightly-1.6-builds.yml | 16 +-
.github/workflows/nightly-1.7-builds.yml | 20 +-
.github/workflows/nightly-builds-aeron.yml | 6 +-
.github/workflows/nightly-builds.yml | 16 +-
.github/workflows/nightly-multi-jvm-tests.yml | 82 ++++
.github/workflows/publish-1.0-docs.yml | 4 +-
.github/workflows/publish-1.0-nightly.yml | 4 +-
.github/workflows/publish-1.1-docs.yml | 4 +-
.github/workflows/publish-1.1-nightly.yml | 4 +-
.github/workflows/publish-1.2-docs.yml | 4 +-
.github/workflows/publish-1.2-nightly.yml | 4 +-
.github/workflows/publish-1.3-docs.yml | 4 +-
.github/workflows/publish-1.3-nightly.yml | 4 +-
.github/workflows/publish-1.4-docs.yml | 4 +-
.github/workflows/publish-1.4-nightly.yml | 4 +-
.github/workflows/publish-1.5-docs.yml | 4 +-
.github/workflows/publish-1.5-nightly.yml | 4 +-
.github/workflows/publish-1.6-docs.yml | 4 +-
.github/workflows/publish-1.6-nightly.yml | 4 +-
.../{publish-1.2-docs.yml => publish-1.7-docs.yml} | 32 +-
.github/workflows/publish-1.7-nightly.yml | 4 +-
.github/workflows/publish-2.0-docs.yml | 16 +-
.github/workflows/publish-nightly.yml | 4 +-
.github/workflows/stage-release-candidate.yml | 4 +-
.github/workflows/timing-tests.yml | 15 +-
.jvmopts-ci | 4 +-
.scala-steward.conf | 2 +-
AGENTS.md | 6 +
SECURITY.md | 50 ++
THREAT_MODEL.md | 424 +++++++++++++++++
...enamed-methods.excludes => mima-1.2.0.excludes} | 9 +-
.../2.0.x.backwards.excludes/patience-def.excludes | 4 +-
.../typed/internal/BehaviorTestKitImpl.scala | 5 +-
.../testkit/typed/internal/TestInboxImpl.scala | 3 +-
.../testkit/typed/internal/TestProbeImpl.scala | 15 +-
.../actor/testkit/typed/javadsl/LogCapturing.scala | 6 +-
.../typed/javadsl/LogCapturingExtension.scala | 5 +-
.../actor/testkit/typed/javadsl/TestInbox.scala | 3 +-
.../testkit/typed/scaladsl/BehaviorTestKit.scala | 5 +-
.../testkit/typed/scaladsl/LogCapturing.scala | 4 +-
.../typed/scaladsl/ScalaTestWithActorTestKit.scala | 5 +-
.../actor/testkit/typed/scaladsl/TestInbox.scala | 6 +-
.../actor/testkit/typed/scaladsl/TestProbe.scala | 13 +-
.../javadsl/LogCapturingExtensionExampleTest.java | 1 +
.../src/test/resources/logback-test.xml | 8 +
.../scaladsl/ScalaTestWithActorTestKitSpec.scala | 54 +++
.../pekko/actor/AbstractFSMWithStashActorTest.java | 83 ++++
.../test/java/org/apache/pekko/actor/JavaAPI.java | 1 -
.../pekko/actor/JavaSubclassCompilationCheck.java | 46 ++
.../org/apache/pekko/pattern/PatternsTest.java | 32 ++
.../org/apache/pekko/actor/ActorPathSpec.scala | 80 +++-
.../apache/pekko/actor/ActorSelectionSpec.scala | 17 +
.../org/apache/pekko/actor/DynamicAccessSpec.scala | 5 +-
.../apache/pekko/actor/ReceiveTimeoutSpec.scala | 57 ++-
.../apache/pekko/actor/RelativeActorPathSpec.scala | 4 +-
.../pekko/dispatch/InstrumentationPointsSpec.scala | 85 ++++
.../org/apache/pekko/event/LogSourceSpec.scala | 56 +++
.../org/apache/pekko/io/SimpleDnsCacheSpec.scala | 5 +-
.../org/apache/pekko/io/TcpConnectionSpec.scala | 5 +-
.../UnsynchronizedByteArrayInputStreamSpec.scala | 209 +++++++-
.../io/dns/internal/AsyncDnsManagerSpec.scala | 2 -
.../io/dns/internal/AsyncDnsResolverSpec.scala | 42 ++
.../pekko/io/dns/internal/DomainNameSpec.scala | 67 +++
.../pekko/io/dns/internal/TcpDnsClientSpec.scala | 34 +-
.../pekko/routing/ConfiguredLocalRoutingSpec.scala | 2 +-
.../apache/pekko/routing/ConsistentHashSpec.scala | 83 ++++
.../pekko/serialization/DecompressionSpec.scala | 104 ++++
.../pekko/serialization/WireConfigSpec.scala | 87 ++++
.../WireManifestClassLoadingSpec.scala | 85 ++++
.../util/ByteStringBuilderScala213PlusSpec.scala | 17 +
.../org/apache/pekko/util/ByteStringSpec.scala | 449 +++++++++++++++++
.../scala/org/apache/pekko/util/GlobSpec.scala | 92 ++++
.../pekko/util/LineNumbersConstantPoolSpec.scala | 120 +++++
.../scala/org/apache/pekko/util/ReflectSpec.scala | 33 +-
.../src/test/resources/logback-doc-dev.xml | 8 +
.../src/test/resources/logback-doc-prod.xml | 8 +
.../src/test/resources/logback-doc-test.xml | 8 +
.../src/test/resources/logback-test.xml | 8 +
.../docs/org/apache/pekko/typed/FSMDocSpec.scala | 11 +-
.../pekko/typed/extensions/ExtensionDocSpec.scala | 2 +-
.../actor/typed/CancelReceiveTimeoutSpec.scala | 2 +-
.../2.0.x.backwards.excludes/mima-1.2.0.excludes | 32 ++
.../delivery/internal/ProducerControllerImpl.scala | 9 +-
.../typed/internal/adapter/ActorAdapter.scala | 2 +-
.../io/UnsynchronizedByteArrayInputStream.java | 104 ++--
.../2.0.x.backwards.excludes/mima-1.2.0.excludes | 48 ++
.../receive-timeout-with-duration.excludes | 43 ++
actor/src/main/mima-filters/binary-api | 33 ++
actor/src/main/resources/reference.conf | 24 +-
.../org/apache/pekko/event/LogSourceCompat.scala | 13 +-
.../org/apache/pekko/event/LogSourceCompat.scala | 18 +-
.../scala/org/apache/pekko/actor/AbstractFSM.scala | 13 +-
.../main/scala/org/apache/pekko/actor/Actor.scala | 13 +-
.../scala/org/apache/pekko/actor/ActorCell.scala | 20 +
.../org/apache/pekko/actor/ActorLogMarker.scala | 2 -
.../scala/org/apache/pekko/actor/ActorPath.scala | 67 ++-
.../org/apache/pekko/actor/ActorSelection.scala | 20 +-
.../scala/org/apache/pekko/actor/ActorSystem.scala | 5 +-
.../scala/org/apache/pekko/actor/Address.scala | 2 +-
.../org/apache/pekko/actor/DynamicAccess.scala | 5 +-
.../org/apache/pekko/actor/FaultHandling.scala | 10 +-
.../apache/pekko/actor/IndirectActorProducer.scala | 5 +-
.../pekko/actor/LightArrayRevolverScheduler.scala | 27 +-
.../main/scala/org/apache/pekko/actor/Props.scala | 3 +-
.../pekko/actor/ReflectiveDynamicAccess.scala | 5 +-
.../main/scala/org/apache/pekko/actor/Stash.scala | 3 +-
.../pekko/actor/dungeon/ReceiveTimeout.scala | 2 +-
.../org/apache/pekko/dispatch/Dispatcher.scala | 9 +
.../scala/org/apache/pekko/dispatch/Mailbox.scala | 10 +
.../pekko/dispatch/affinity/AffinityPool.scala | 4 +-
.../scala/org/apache/pekko/event/EventBus.scala | 4 +-
.../scala/org/apache/pekko/event/Logging.scala | 5 +-
.../apache/pekko/io/InetAddressDnsResolver.scala | 7 +-
actor/src/main/scala/org/apache/pekko/io/Tcp.scala | 7 +-
.../scala/org/apache/pekko/io/TcpConnection.scala | 6 +-
.../apache/pekko/io/TcpIncomingConnection.scala | 4 +-
.../apache/pekko/io/TcpOutgoingConnection.scala | 6 +-
actor/src/main/scala/org/apache/pekko/io/Udp.scala | 7 +-
.../scala/org/apache/pekko/io/UdpConnected.scala | 4 +-
.../pekko/io/dns/internal/AsyncDnsResolver.scala | 3 +-
.../apache/pekko/io/dns/internal/DnsMessage.scala | 7 +-
.../apache/pekko/io/dns/internal/DomainName.scala | 46 +-
.../pekko/io/dns/internal/ResolvConfParser.scala | 5 +-
.../pekko/io/dns/internal/TcpDnsClient.scala | 9 +-
.../main/scala/org/apache/pekko/japi/JavaAPI.scala | 14 +-
.../org/apache/pekko/routing/ConsistentHash.scala | 131 ++++-
.../apache/pekko/serialization/Decompression.scala | 80 ++++
.../serialization/NestedDeserialization.scala | 65 +++
.../apache/pekko/serialization/Serialization.scala | 66 +--
.../pekko/serialization/SerializationSetup.scala | 9 +-
.../apache/pekko/serialization/WireConfig.scala | 82 ++++
.../scala/org/apache/pekko/util/ByteString.scala | 530 +++++++++++++++++++--
.../scala/org/apache/pekko/util/Collections.scala | 6 +-
.../org/apache/pekko/util/FrequencyList.scala | 22 +-
.../main/scala/org/apache/pekko/util/Glob.scala | 73 +++
.../scala/org/apache/pekko/util/LineNumbers.scala | 25 +-
.../scala/org/apache/pekko/util/ManifestInfo.scala | 12 +-
.../scala/org/apache/pekko/util/RecencyList.scala | 18 +-
.../main/scala/org/apache/pekko/util/Reflect.scala | 11 +-
.../apache/pekko/util/SegmentedRecencyList.scala | 14 +-
.../org/apache/pekko/util/SubclassifiedIndex.scala | 6 +-
bench-jmh/src/main/resources/logback.xml | 8 +
.../pekko/actor/ActorPathValidationBenchmark.scala | 73 +++
.../pekko/actor/ReceiveTimeoutBenchmark.scala | 2 +-
.../pekko/stream/NewLayoutBenchmark.template | 9 +
.../org/apache/pekko/stream/io/TlsBenchmark.scala | 9 +-
.../util/ByteString_asInputStream_Benchmark.scala | 14 +-
.../ByteString_byteAtUnchecked_Benchmark.scala | 143 ++++++
.../pekko/util/ByteString_equals_Benchmark.scala | 110 +++++
.../protobuf/msg/ClusterMetricsMessages.java | 166 +++----
.../cluster/metrics/ClusterMetricsExtension.scala | 4 +-
.../pekko/cluster/metrics/MetricsCollector.scala | 2 +-
.../metrics/protobuf/MessageSerializer.scala | 17 +-
.../cluster/metrics/sample/StatsService.scala | 2 +-
.../src/test/resources/logback-test.xml | 8 +
.../apache/pekko/cluster/metrics/MetricSpec.scala | 27 +-
.../typed/internal/protobuf/ShardingMessages.java | 50 +-
.../src/main/mima-filters/binary-api | 7 +-
.../sharding/typed/ClusterShardingSettings.scala | 9 +-
.../sharding/typed/ReplicatedEntityProvider.scala | 3 +-
.../typed/internal/ClusterShardingImpl.scala | 15 +-
.../src/multi-jvm/resources/logback-test.xml | 8 +
.../src/test/resources/logback-test.xml | 8 +
.../pekko/cluster/sharding/FlightRecording.scala | 4 +-
.../typed/internal/ExtractorAdapterSpec.scala | 90 ++++
.../protobuf/msg/ClusterShardingMessages.java | 414 +++++++---------
.../2.0.x.backwards.excludes/mima-1.2.0.excludes | 36 ++
.../remove-akka-2.3-sharding-data-removal.excludes | 8 +-
.../src/main/mima-filters/binary-api | 7 +-
cluster-sharding/src/main/resources/reference.conf | 8 +
.../cluster/sharding/ClusterShardingSettings.scala | 11 +-
.../RemoveInternalClusterShardingData.scala | 42 +-
.../org/apache/pekko/cluster/sharding/Shard.scala | 33 ++
.../pekko/cluster/sharding/ShardCoordinator.scala | 12 +-
.../pekko/cluster/sharding/ShardRegion.scala | 2 +-
.../pekko/cluster/sharding/ShardingLogMarker.scala | 2 -
.../external/ExternalShardAllocation.scala | 2 -
.../javadsl/ExternalShardAllocationClient.scala | 2 -
.../scaladsl/ExternalShardAllocationClient.scala | 2 -
.../internal/EntityPassivationStrategy.scala | 11 +-
.../ClusterShardingMessageSerializer.scala | 10 +-
.../cluster/sharding/ClusterShardingSpec.scala | 12 +-
.../RemoveInternalClusterShardingDataSpec.scala | 3 +-
.../passivation/PassivationStopTimeoutSpec.scala | 152 ++++++
.../sharding/passivation/simulator/Simulator.scala | 22 +-
.../passivation/simulator/SimulatorSettings.scala | 5 +-
.../client/protobuf/msg/ClusterClientMessages.java | 16 +-
.../protobuf/msg/DistributedPubSubMessages.java | 166 +++----
.../pekko/cluster/client/ClusterClient.scala | 4 +-
.../DistributedPubSubMessageSerializer.scala | 9 +-
.../typed/internal/protobuf/ClusterMessages.java | 24 +-
.../typed/internal/protobuf/ReliableDelivery.java | 116 ++---
.../org/apache/pekko/cluster/typed/Cluster.scala | 3 +-
.../src/multi-jvm/resources/logback-test.xml | 8 +
cluster-typed/src/test/resources/logback-test.xml | 8 +
.../pekko/cluster/typed/ClusterApiSpec.scala | 2 +-
.../cluster/protobuf/msg/ClusterMessages.java | 364 +++++---------
...ecated-methods.excludes => mima-1.2.0.excludes} | 36 +-
.../scala/org/apache/pekko/cluster/Cluster.scala | 8 +-
.../org/apache/pekko/cluster/ClusterEvent.scala | 18 +-
.../apache/pekko/cluster/ClusterLogMarker.scala | 2 -
.../org/apache/pekko/cluster/Reachability.scala | 2 +-
.../org/apache/pekko/cluster/SeedNodeProcess.scala | 6 +-
.../protobuf/ClusterMessageSerializer.scala | 90 ++--
.../cluster/routing/ClusterRouterConfig.scala | 8 +-
cluster/src/multi-jvm/resources/logback-test.xml | 8 +
...henOtherHasQuarantinedThisActorSystemSpec.scala | 116 +++--
.../pekko/cluster/MultiNodeClusterSpec.scala | 7 +-
.../cluster/UnreachableNodeJoinsAgainSpec.scala | 3 +-
.../org/apache/pekko/cluster/ClusterSpec.scala | 6 +-
...ClusterMessageSerializerDecompressionSpec.scala | 83 ++++
.../protobuf/ClusterMessageSerializerSpec.scala | 207 +++++---
.../coordination/lease/LeaseHealthCheck.scala | 90 ++++
.../lease/scaladsl/LeaseProvider.scala | 5 +-
.../coordination/lease/LeaseHealthCheckSpec.scala | 128 +++++
.../apache/pekko/discovery/ServiceDiscovery.scala | 7 +-
.../aggregate/AggregateServiceDiscoverySpec.scala | 11 +-
.../config/ConfigServiceDiscoverySpec.scala | 7 +-
.../config/ConfigServicesParserSpec.scala | 6 +-
.../ddata/protobuf/msg/ReplicatedDataMessages.java | 398 +++++-----------
.../ddata/protobuf/msg/ReplicatorMessages.java | 396 +++++----------
.../apache/pekko/cluster/ddata/Replicator.scala | 10 +-
.../ddata/protobuf/SerializationSupport.scala | 14 +-
.../SerializationSupportDecompressionSpec.scala | 66 +++
.../ddata/protobuf/msg/TwoPhaseSetMessages.java | 32 +-
.../docs/persistence/proto/FlightAppModels.java | 18 +-
.../paradox/_template/projectSpecificFooter.st | 1 -
docs/src/main/paradox/actors.md | 24 +-
docs/src/main/paradox/additional/deploying.md | 5 +-
docs/src/main/paradox/additional/operations.md | 4 +-
docs/src/main/paradox/additional/osgi.md | 2 +-
docs/src/main/paradox/additional/packaging.md | 39 +-
.../src/main/paradox/additional/rolling-updates.md | 31 +-
docs/src/main/paradox/assets/js/warnOldDocs.js | 188 --------
docs/src/main/paradox/cluster-client.md | 14 +-
docs/src/main/paradox/cluster-metrics.md | 6 +-
docs/src/main/paradox/cluster-routing.md | 10 +-
docs/src/main/paradox/cluster-sharding.md | 6 +-
docs/src/main/paradox/cluster-usage.md | 22 +-
.../paradox/common/binary-compatibility-rules.md | 6 +-
docs/src/main/paradox/common/circuitbreaker.md | 8 +-
docs/src/main/paradox/common/io-layer.md | 4 +-
docs/src/main/paradox/common/may-change.md | 2 +-
docs/src/main/paradox/coordinated-shutdown.md | 2 +-
docs/src/main/paradox/coordination.md | 2 +-
docs/src/main/paradox/discovery/index.md | 29 +-
docs/src/main/paradox/dispatchers.md | 6 +-
docs/src/main/paradox/distributed-data.md | 14 +-
docs/src/main/paradox/distributed-pub-sub.md | 11 +-
.../paradox/durable-state/persistence-query.md | 17 +-
docs/src/main/paradox/event-bus.md | 6 +-
docs/src/main/paradox/extending-pekko.md | 4 +-
docs/src/main/paradox/fault-tolerance.md | 15 +-
docs/src/main/paradox/fsm.md | 8 +-
docs/src/main/paradox/futures.md | 2 +-
docs/src/main/paradox/general/addressing.md | 2 +-
.../paradox/general/configuration-reference.md | 17 +-
docs/src/main/paradox/general/configuration.md | 8 +-
docs/src/main/paradox/general/jmm.md | 4 +-
.../main/paradox/general/stream/stream-design.md | 10 +-
docs/src/main/paradox/includes/cluster.md | 6 +-
docs/src/main/paradox/io-dns.md | 6 +-
docs/src/main/paradox/io-tcp.md | 10 +-
docs/src/main/paradox/io-udp.md | 12 +-
docs/src/main/paradox/io.md | 2 +-
docs/src/main/paradox/logging.md | 6 +-
docs/src/main/paradox/mailboxes.md | 6 +-
.../paradox/migration/migration-guide-1.x-2.x.md | 195 +++++++-
docs/src/main/paradox/multi-jvm-testing.md | 48 +-
docs/src/main/paradox/multi-node-testing.md | 20 +-
docs/src/main/paradox/persistence-journals.md | 2 +-
docs/src/main/paradox/persistence-plugins.md | 15 +-
docs/src/main/paradox/persistence-query-leveldb.md | 6 +-
docs/src/main/paradox/persistence-query.md | 10 +-
.../main/paradox/persistence-schema-evolution.md | 14 +-
docs/src/main/paradox/persistence.md | 21 +-
.../paradox/project/downstream-upgrade-strategy.md | 2 +-
docs/src/main/paradox/project/immutable.md | 4 +-
docs/src/main/paradox/project/links.md | 2 +-
docs/src/main/paradox/project/rolling-update.md | 17 +-
docs/src/main/paradox/release-notes/index.md | 1 +
.../src/main/paradox/release-notes/releases-1.0.md | 10 +-
.../src/main/paradox/release-notes/releases-1.1.md | 14 +-
.../src/main/paradox/release-notes/releases-1.2.md | 16 +-
.../src/main/paradox/release-notes/releases-1.3.md | 6 +-
.../src/main/paradox/release-notes/releases-1.4.md | 2 +-
.../src/main/paradox/release-notes/releases-1.5.md | 2 +-
.../src/main/paradox/release-notes/releases-1.6.md | 4 +-
.../src/main/paradox/release-notes/releases-1.7.md | 45 ++
.../src/main/paradox/release-notes/releases-2.0.md | 24 +-
docs/src/main/paradox/remote-security.md | 71 ++-
docs/src/main/paradox/remoting-artery.md | 44 +-
docs/src/main/paradox/remoting.md | 41 +-
docs/src/main/paradox/routing.md | 12 +-
docs/src/main/paradox/scheduler.md | 2 +-
docs/src/main/paradox/security/index.md | 6 +-
docs/src/main/paradox/serialization-classic.md | 12 +-
docs/src/main/paradox/serialization-jackson.md | 45 +-
docs/src/main/paradox/serialization.md | 6 +-
docs/src/main/paradox/split-brain-resolver.md | 34 +-
docs/src/main/paradox/stream/actor-interop.md | 54 +--
docs/src/main/paradox/stream/futures-interop.md | 2 +-
.../main/paradox/stream/operators/ActorFlow/ask.md | 2 +-
.../stream/operators/ActorFlow/askWithContext.md | 2 +-
.../stream/operators/ActorFlow/askWithStatus.md | 4 +-
.../operators/ActorFlow/askWithStatusAndContext.md | 4 +-
.../paradox/stream/operators/ActorSink/actorRef.md | 2 +-
.../ActorSink/actorRefWithBackpressure.md | 4 +-
docs/src/main/paradox/stream/operators/Balance.md | 4 +
.../src/main/paradox/stream/operators/Broadcast.md | 4 +-
.../stream/operators/Compression/deflate.md | 7 +
.../paradox/stream/operators/Compression/gzip.md | 7 +
.../stream/operators/Compression/inflate.md | 2 +-
.../stream/operators/Flow/completionStageFlow.md | 6 +-
.../paradox/stream/operators/Flow/contramap.md | 2 +-
.../main/paradox/stream/operators/Flow/dimap.md | 2 +-
.../stream/operators/Flow/flattenOptional.md | 6 +-
.../stream/operators/Flow/fromSinkAndSource.md | 2 +-
.../paradox/stream/operators/Flow/futureFlow.md | 2 -
.../operators/Flow/lazyCompletionStageFlow.md | 6 +-
.../main/paradox/stream/operators/Flow/lazyFlow.md | 2 -
.../stream/operators/Flow/lazyFutureFlow.md | 2 -
.../main/paradox/stream/operators/PubSub/sink.md | 2 +-
.../main/paradox/stream/operators/PubSub/source.md | 2 +-
.../operators/RestartFlow/onFailuresWithBackoff.md | 2 +-
.../main/paradox/stream/operators/Sink/actorRef.md | 2 +-
.../main/paradox/stream/operators/Sink/collect.md | 2 +-
.../paradox/stream/operators/Sink/collection.md | 4 +-
.../stream/operators/Sink/completionStageSink.md | 2 +-
.../main/paradox/stream/operators/Sink/count.md | 2 +-
.../main/paradox/stream/operators/Sink/exists.md | 2 +-
.../main/paradox/stream/operators/Sink/forall.md | 2 +-
.../paradox/stream/operators/Sink/futureSink.md | 2 +-
.../operators/Sink/lazyCompletionStageSink.md | 6 +-
.../stream/operators/Sink/lazyFutureSink.md | 6 +-
.../main/paradox/stream/operators/Sink/never.md | 2 +-
.../src/main/paradox/stream/operators/Sink/none.md | 2 +-
.../stream/operators/Sink/preMaterialize.md | 4 +-
.../main/paradox/stream/operators/Sink/queue.md | 2 +-
docs/src/main/paradox/stream/operators/Sink/seq.md | 4 +-
.../main/paradox/stream/operators/Sink/source.md | 2 +-
.../main/paradox/stream/operators/Sink/takeLast.md | 4 +-
.../stream/operators/Sink/watchTermination.md | 27 +-
.../stream/operators/Source-or-Flow/alsoToAll.md | 8 +-
.../stream/operators/Source-or-Flow/batch.md | 4 +-
.../operators/Source-or-Flow/batchWeighted.md | 6 +-
.../stream/operators/Source-or-Flow/buffer.md | 4 +-
.../stream/operators/Source-or-Flow/collect.md | 4 +-
.../operators/Source-or-Flow/collectFirst.md | 2 +-
.../stream/operators/Source-or-Flow/collectType.md | 4 +-
.../stream/operators/Source-or-Flow/concatLazy.md | 4 +-
.../operators/Source-or-Flow/conflateWithSeed.md | 2 +-
.../stream/operators/Source-or-Flow/delay.md | 6 +-
.../stream/operators/Source-or-Flow/delayWith.md | 6 +-
.../stream/operators/Source-or-Flow/detach.md | 2 +-
.../operators/Source-or-Flow/dropRepeated.md | 9 +-
.../stream/operators/Source-or-Flow/dropWhile.md | 6 +-
.../stream/operators/Source-or-Flow/dropWithin.md | 2 +-
.../stream/operators/Source-or-Flow/expand.md | 2 +-
.../operators/Source-or-Flow/flatMapConcat.md | 6 +
.../operators/Source-or-Flow/flatMapPrefix.md | 8 +-
.../stream/operators/Source-or-Flow/foldWhile.md | 6 +-
.../stream/operators/Source-or-Flow/groupBy.md | 7 +-
.../stream/operators/Source-or-Flow/grouped.md | 4 +-
.../operators/Source-or-Flow/groupedAdjacentBy.md | 4 +-
.../Source-or-Flow/groupedAdjacentByWeighted.md | 4 +-
.../operators/Source-or-Flow/groupedWeighted.md | 4 +-
.../Source-or-Flow/groupedWeightedWithin.md | 8 +-
.../operators/Source-or-Flow/groupedWithin.md | 6 +-
.../operators/Source-or-Flow/initialTimeout.md | 4 +-
.../stream/operators/Source-or-Flow/interleave.md | 2 +-
.../operators/Source-or-Flow/interleaveAll.md | 6 +-
.../stream/operators/Source-or-Flow/limit.md | 2 +-
.../operators/Source-or-Flow/limitWeighted.md | 4 +-
.../stream/operators/Source-or-Flow/mapAsync.md | 4 +-
.../Source-or-Flow/mapAsyncPartitioned.md | 6 +-
.../Source-or-Flow/mapAsyncPartitionedUnordered.md | 6 +-
.../operators/Source-or-Flow/mapAsyncUnordered.md | 2 +-
.../stream/operators/Source-or-Flow/mapConcat.md | 4 +-
.../stream/operators/Source-or-Flow/mapError.md | 6 +-
.../stream/operators/Source-or-Flow/mapOption.md | 2 +-
.../operators/Source-or-Flow/mapWithResource.md | 10 +-
.../Source-or-Flow/materializeIntoSource.md | 2 +-
.../stream/operators/Source-or-Flow/mergeAll.md | 4 +-
.../stream/operators/Source-or-Flow/mergeLatest.md | 8 +-
.../stream/operators/Source-or-Flow/monitor.md | 8 +-
.../operators/Source-or-Flow/onErrorContinue.md | 22 +-
.../stream/operators/Source-or-Flow/optionalVia.md | 2 +-
.../operators/Source-or-Flow/preMaterialize.md | 2 +-
.../operators/Source-or-Flow/prefixAndTail.md | 4 +-
.../stream/operators/Source-or-Flow/prepend.md | 11 +-
.../stream/operators/Source-or-Flow/prependLazy.md | 6 +-
.../stream/operators/Source-or-Flow/recoverWith.md | 2 +-
.../stream/operators/Source-or-Flow/sliding.md | 5 +-
.../stream/operators/Source-or-Flow/splitAfter.md | 2 +-
.../stream/operators/Source-or-Flow/splitWhen.md | 4 +-
.../operators/Source-or-Flow/statefulMapConcat.md | 2 +-
.../stream/operators/Source-or-Flow/takeUntil.md | 6 +-
.../stream/operators/Source-or-Flow/takeWhile.md | 9 +-
.../stream/operators/Source-or-Flow/watch.md | 2 +-
.../operators/Source-or-Flow/watchTermination.md | 10 +-
.../stream/operators/Source-or-Flow/wireTap.md | 2 +
.../stream/operators/Source-or-Flow/zipAll.md | 3 +-
.../operators/Source-or-Flow/zipLatestWith.md | 12 +-
.../paradox/stream/operators/Source/actorRef.md | 14 +-
.../stream/operators/Source/asSubscriber.md | 10 +-
.../main/paradox/stream/operators/Source/from.md | 4 +-
.../stream/operators/Source/fromPublisher.md | 8 +-
.../main/paradox/stream/operators/Source/items.md | 2 -
.../paradox/stream/operators/Source/iterate.md | 14 +-
.../paradox/stream/operators/Source/lazySource.md | 4 +-
.../main/paradox/stream/operators/Source/maybe.md | 4 +-
.../stream/operators/Source/mergePrioritizedN.md | 2 +-
.../main/paradox/stream/operators/Source/queue.md | 70 ++-
.../main/paradox/stream/operators/Source/single.md | 2 +-
.../stream/operators/Source/unfoldResource.md | 2 +-
.../main/paradox/stream/operators/Source/zipN.md | 2 +-
.../paradox/stream/operators/Source/zipWithN.md | 2 +-
.../operators/StreamConverters/asInputStream.md | 2 +-
.../operators/StreamConverters/asJavaStream.md | 2 +-
.../operators/StreamConverters/fromOutputStream.md | 8 +-
.../javaCollectorParallelUnordered.md | 17 +-
docs/src/main/paradox/stream/operators/Unzip.md | 6 +-
.../src/main/paradox/stream/operators/UnzipWith.md | 2 +
docs/src/main/paradox/stream/operators/index.md | 2 +-
.../paradox/stream/reactive-streams-interop.md | 12 +-
docs/src/main/paradox/stream/stream-composition.md | 12 +-
docs/src/main/paradox/stream/stream-context.md | 4 +-
docs/src/main/paradox/stream/stream-cookbook.md | 10 +-
docs/src/main/paradox/stream/stream-customize.md | 29 +-
docs/src/main/paradox/stream/stream-dynamic.md | 6 +-
docs/src/main/paradox/stream/stream-error.md | 2 +-
.../main/paradox/stream/stream-flows-and-basics.md | 22 +-
docs/src/main/paradox/stream/stream-graphs.md | 10 +-
.../src/main/paradox/stream/stream-introduction.md | 10 +-
docs/src/main/paradox/stream/stream-io.md | 10 +-
docs/src/main/paradox/stream/stream-quickstart.md | 13 +-
docs/src/main/paradox/stream/stream-rate.md | 6 +-
docs/src/main/paradox/stream/stream-refs.md | 29 +-
docs/src/main/paradox/stream/stream-substream.md | 16 +-
docs/src/main/paradox/stream/stream-testkit.md | 6 +-
docs/src/main/paradox/supervision-classic.md | 6 +-
docs/src/main/paradox/testing.md | 9 +-
docs/src/main/paradox/typed/actor-discovery.md | 12 +-
docs/src/main/paradox/typed/actors.md | 12 +-
docs/src/main/paradox/typed/cluster-concepts.md | 6 +-
.../typed/cluster-sharded-daemon-process.md | 4 +-
docs/src/main/paradox/typed/cluster-sharding.md | 26 +-
docs/src/main/paradox/typed/cluster-singleton.md | 6 +-
docs/src/main/paradox/typed/cluster.md | 12 +-
docs/src/main/paradox/typed/dispatchers.md | 12 +-
docs/src/main/paradox/typed/distributed-data.md | 29 +-
docs/src/main/paradox/typed/distributed-pub-sub.md | 6 +-
.../typed/durable-state/persistence-style.md | 4 +-
.../paradox/typed/durable-state/persistence.md | 16 +-
docs/src/main/paradox/typed/failure-detector.md | 4 +-
docs/src/main/paradox/typed/from-classic.md | 2 +-
.../main/paradox/typed/guide/actors-motivation.md | 2 +-
docs/src/main/paradox/typed/guide/modules.md | 18 +-
docs/src/main/paradox/typed/guide/tutorial.md | 2 +-
docs/src/main/paradox/typed/guide/tutorial_1.md | 4 +-
docs/src/main/paradox/typed/guide/tutorial_3.md | 14 +-
docs/src/main/paradox/typed/guide/tutorial_4.md | 4 +-
.../src/main/paradox/typed/interaction-patterns.md | 28 +-
docs/src/main/paradox/typed/logging.md | 2 +-
docs/src/main/paradox/typed/mailboxes.md | 8 +-
.../src/main/paradox/typed/persistence-snapshot.md | 2 +-
docs/src/main/paradox/typed/persistence-style.md | 6 +-
docs/src/main/paradox/typed/persistence-testing.md | 6 +-
docs/src/main/paradox/typed/persistence.md | 14 +-
docs/src/main/paradox/typed/reliable-delivery.md | 9 +-
.../typed/replicated-eventsourcing-auction.md | 12 +-
.../main/paradox/typed/replicated-eventsourcing.md | 26 +-
docs/src/main/paradox/typed/routers.md | 6 +-
docs/src/main/paradox/typed/style-guide.md | 8 +-
docs/src/main/paradox/typed/testing-async.md | 30 +-
docs/src/main/paradox/typed/testing-sync.md | 2 +-
.../java/jdocs/actor/FaultHandlingDocSample.java | 4 +-
.../java/jdocs/sharding/ClusterShardingTest.java | 2 +-
.../operators/source/QueueMigrationDocTest.java | 213 +++++++++
docs/src/test/resources/logback-test.xml | 8 +
docs/src/test/scala/docs/actor/ActorDocSpec.scala | 2 +-
docs/src/test/scala/docs/actor/FSMDocSpec.scala | 11 +-
.../scala/docs/actor/FaultHandlingDocSample.scala | 2 +-
.../circuitbreaker/CircuitBreakerDocSpec.scala | 2 +-
.../scala/docs/cluster/FactorialFrontend.scala | 2 +-
.../persistence/PersistencePluginDocSpec.scala | 3 +-
.../query/PersistenceQueryDocSpec.scala | 5 +-
.../docs/remoting/SSLEngineProviderDocSpec.scala | 58 +++
.../test/scala/docs/stream/GraphDSLDocSpec.scala | 5 +-
.../test/scala/docs/stream/GraphStageDocSpec.scala | 2 +-
.../test/scala/docs/stream/KillSwitchDocSpec.scala | 8 +-
.../docs/stream/RateTransformationDocSpec.scala | 5 +-
.../stream/cookbook/RecipeCollectingMetrics.scala | 2 +-
.../docs/stream/cookbook/RecipeMultiGroupBy.scala | 3 +-
.../docs/stream/operators/WithContextSpec.scala | 17 +-
.../converters/StreamConvertersToJava.scala | 5 +-
.../operators/source/QueueMigrationDocSpec.scala | 158 ++++++
.../test/scala/docs/testkit/TestKitUsageSpec.scala | 7 +-
.../test/scala/docs/testkit/TestkitDocSpec.scala | 5 +-
kubernetes/setup.sh | 8 +
.../testconductor/TestConductorProtocol.java | 108 ++---
.../2.0.x.backwards.excludes/mima-1.2.0.excludes | 23 +-
.../apache/pekko/remote/testconductor/Player.scala | 5 +-
.../pekko/remote/testkit/MultiNodeSpec.scala | 15 +-
osgi/src/test/resources/logback-test.xml | 8 +
.../pekko/osgi/ActorSystemActivatorTest.scala | 5 +-
.../org/apache/pekko/osgi/PojoSRTestSupport.scala | 5 +-
.../query/internal/protobuf/QueryMessages.java | 70 +--
.../typed/scaladsl/CurrentEventsBySliceQuery.scala | 4 +-
...ntEventsBySliceStartingFromSnapshotsQuery.scala | 4 +-
.../scaladsl/DurableStateStoreBySliceQuery.scala | 4 +-
.../scaladsl/EventsBySliceFirehoseQuery.scala | 3 +-
.../query/typed/scaladsl/EventsBySliceQuery.scala | 4 +-
.../EventsBySliceStartingFromSnapshotsQuery.scala | 4 +-
.../persistence/journal/JournalPerfSpec.scala | 3 +-
.../persistence/snapshot/SnapshotStoreSpec.scala | 2 -
.../pekko/persistence/testkit/EventStorage.scala | 21 +-
.../testkit/PersistenceTestKitPlugin.scala | 3 +-
.../internal/EventSourcedBehaviorTestKitImpl.scala | 9 +-
.../testkit/internal/PersistenceProbeImpl.scala | 9 +-
.../testkit/internal/TestKitStorage.scala | 10 +-
.../scaladsl/PersistenceTestKitReadJournal.scala | 3 +-
.../scaladsl/EventSourcedBehaviorTestKit.scala | 3 +-
.../testkit/scaladsl/PersistenceTestKit.scala | 15 +-
.../persistence/testkit/scaladsl/TestOps.scala | 10 +-
.../PersistenceTestKitDurableStateStore.scala | 3 +-
.../src/test/resources/logback-test.xml | 8 +
.../testkit/query/EventsBySliceSpec.scala | 1 -
.../testkit/query/EventsByTagSpec.scala | 1 -
.../src/test/resources/logback-test.xml | 8 +
.../typed/internal/EventWriterSpec.scala | 214 +++++++++
.../scaladsl/EventSourcedBehaviorFailureSpec.scala | 3 +-
.../scaladsl/EventSourcedBehaviorSignalSpec.scala | 3 +-
.../typed/scaladsl/EventSourcedBehaviorSpec.scala | 69 ++-
.../serialization/ReplicatedEventSourcing.java | 246 +++-------
.../2.0.x.backwards.excludes/mima-1.2.0.excludes | 144 ++++++
.../src/main/resources/reference.conf | 8 +
.../pekko/persistence/typed/EventAdapter.scala | 11 +-
.../persistence/typed/internal/BehaviorSetup.scala | 4 +-
.../persistence/typed/internal/EffectImpl.scala | 10 +-
.../typed/internal/EventSourcedBehaviorImpl.scala | 2 +-
.../persistence/typed/internal/EventWriter.scala | 391 +++++++++++++++
.../typed/internal/ExternalInteractions.scala | 5 +-
.../typed/internal/ReplayingEvents.scala | 8 +-
.../typed/internal/RequestingRecoveryPermit.scala | 2 +-
.../pekko/persistence/typed/internal/Running.scala | 21 +-
.../typed/state/internal/BehaviorSetup.scala | 4 +-
.../typed/state/internal/EffectImpl.scala | 4 +-
.../state/internal/RequestingRecoveryPermit.scala | 2 +-
.../persistence/typed/state/internal/Running.scala | 15 +-
.../persistence/typed/state/javadsl/Effect.scala | 7 +-
.../typed/DurableStatePersistentBehaviorTest.java | 5 +
.../src/test/resources/logback-test.xml | 8 +
.../persistence/serialization/MessageFormats.java | 122 ++---
.../2.0.x.backwards.excludes/mima-1.2.0.excludes | 49 ++
persistence/src/main/resources/reference.conf | 3 +
.../pekko/persistence/AtLeastOnceDelivery.scala | 4 +-
.../apache/pekko/persistence/Eventsourced.scala | 6 +-
.../apache/pekko/persistence/JournalProtocol.scala | 4 +-
.../pekko/persistence/PersistencePlugin.scala | 2 +-
.../org/apache/pekko/persistence/Persistent.scala | 4 +-
.../apache/pekko/persistence/PersistentActor.scala | 23 +-
.../pekko/persistence/fsm/PersistentFSM.scala | 3 +-
.../persistence/journal/AsyncWriteJournal.scala | 6 +-
.../persistence/journal/AsyncWriteProxy.scala | 9 +-
.../pekko/persistence/journal/EventAdapter.scala | 7 +-
.../pekko/persistence/journal/EventAdapters.scala | 15 +-
.../journal/PersistencePluginProxy.scala | 6 +-
.../persistence/journal/WriteJournalBase.scala | 6 +-
.../persistence/journal/inmem/InmemJournal.scala | 19 +-
.../journal/japi/AsyncWriteJournal.scala | 2 +-
.../persistence/journal/leveldb/LeveldbStore.scala | 3 +-
.../snapshot/local/LocalSnapshotStore.scala | 6 +-
.../persistence/JavaTimerPersistentActor.java | 69 +++
.../fsm/JavaSubclassCompilationCheck.java | 37 ++
.../persistence/EventSourcedActorFailureSpec.scala | 7 +-
.../apache/pekko/persistence/PersistenceSpec.scala | 5 +-
.../PersistentActorRecoveryTimeoutSpec.scala | 37 +-
.../PersistentActorReplayBatchingSpec.scala | 3 +-
.../pekko/persistence/PersistentActorSpec.scala | 35 +-
.../persistence/TimerPersistentActorSpec.scala | 6 +
.../AsyncWriteJournalResponseOrderSpec.scala | 4 +-
.../persistence/journal/SteppingInmemJournal.scala | 1 -
.../persistence/journal/chaos/ChaosJournal.scala | 3 +-
project/Dependencies.scala | 36 +-
project/Paradox.scala | 4 +-
project/PekkoBuild.scala | 7 +-
project/SbtMultiJvmPlugin.scala | 71 ++-
project/StreamOperatorsIndexGenerator.scala | 3 -
project/build.properties | 2 +-
project/plugins.sbt | 13 +-
project/scripts/find-replace | 8 +
project/scripts/validate-automatic-module-names | 7 +
.../pekko/remote/artery/MaxThroughputSpec.scala | 2 +-
.../artery/aeron/AeronStreamMultiNodeSpec.scala | 2 +-
.../pekko/remote/artery/protobuf/TestMessages.java | 42 +-
.../apache/pekko/remote/ArteryControlFormats.java | 132 ++---
.../org/apache/pekko/remote/ContainerFormats.java | 194 +++-----
.../apache/pekko/remote/SystemMessageFormats.java | 78 +--
.../java/org/apache/pekko/remote/WireFormats.java | 312 +++++-------
.../2.0.x.backwards.excludes/mima-1.2.0.excludes | 37 +-
.../src/main/mima-filters/binary-api | 8 +-
remote/src/main/resources/reference.conf | 24 +-
.../scala/org/apache/pekko/remote/Endpoint.scala | 20 +
.../pekko/remote/RemoteActorRefProvider.scala | 43 +-
.../org/apache/pekko/remote/RemoteDaemon.scala | 50 +-
.../org/apache/pekko/remote/RemoteLogMarker.scala | 2 -
.../org/apache/pekko/remote/RemoteSettings.scala | 5 +-
.../scala/org/apache/pekko/remote/Remoting.scala | 14 +-
.../pekko/remote/artery/ArterySettings.scala | 24 +
.../apache/pekko/remote/artery/Association.scala | 5 +-
.../pekko/remote/artery/InboundEnvelope.scala | 18 +
.../remote/artery/InboundQuarantineCheck.scala | 4 +-
.../pekko/remote/artery/MessageDispatcher.scala | 9 +
.../pekko/remote/artery/OutboundEnvelope.scala | 27 ++
.../pekko/remote/artery/RemoteInstrument.scala | 40 ++
.../artery/aeron/ArteryAeronUdpTransport.scala | 8 +-
.../remote/artery/tcp/ArteryTcpTransport.scala | 6 +-
.../pekko/remote/artery/tcp/TcpFraming.scala | 54 ++-
.../artery/tcp/ssl/PemManagersProvider.scala | 71 ++-
.../tcp/ssl/RotatingKeysSSLEngineProvider.scala | 23 +-
.../serialization/ArteryMessageSerializer.scala | 60 ++-
.../serialization/DaemonMsgCreateSerializer.scala | 51 ++
.../serialization/MiscMessageSerializer.scala | 10 +-
.../remote/serialization/ProtobufSerializer.scala | 9 +-
.../serialization/WrappedPayloadSupport.scala | 10 +-
.../transport/AbstractTransportAdapter.scala | 2 +-
.../pekko/remote/transport/PekkoPduCodec.scala | 18 +
.../remote/transport/netty/SSLEngineProvider.scala | 2 +-
.../org/apache/pekko/remote/ProtobufProtocol.java | 14 +-
.../remote/protobuf/v3/ProtobufProtocolV3.java | 18 +-
remote/src/test/resources/ssl/README.md | 6 +
...signed-certificate.pem => exampleca-bundle.crt} | 14 +
.../resources/ssl/exampleca-rotated-bundle.crt | 28 ++
.../src/test/resources/ssl/exampleca-rotated.crt | 14 +
.../resources/ssl/gen-artery-nodes.example.com.sh | 7 +
remote/src/test/resources/ssl/gen-ca-bundles.sh | 59 +++
remote/src/test/resources/ssl/gen-functions.sh | 7 +
remote/src/test/resources/ssl/genca.sh | 7 +
remote/src/test/resources/ssl/gencerts.sh | 10 +
.../pekko/remote/InstrumentationPointsSpec.scala | 101 ++++
.../apache/pekko/remote/NonTlsWarningSpec.scala | 136 ++++++
.../org/apache/pekko/remote/RemoteRouterSpec.scala | 4 +-
.../pekko/remote/artery/ArterySettingsSpec.scala | 81 ++++
.../pekko/remote/artery/RemoteRouterSpec.scala | 4 +-
.../apache/pekko/remote/artery/TestContext.scala | 2 +-
.../pekko/remote/artery/tcp/TcpFramingSpec.scala | 91 +++-
.../artery/tcp/ssl/PemManagersProviderSpec.scala | 63 ++-
.../pekko/remote/classic/ActorsLeakSpec.scala | 5 +-
.../apache/pekko/remote/classic/RemotingSpec.scala | 32 +-
.../ArteryMessageSerializerSpec.scala | 78 ++-
.../DaemonMsgCreateSerializerAllowListSpec.scala | 187 ++++++++
.../serialization/MiscMessageSerializerSpec.scala | 21 +-
.../serialization/NestedPayloadDepthSpec.scala | 107 +++++
.../serialization/ProtobufSerializerSpec.scala | 18 +
scripts/link-validator.conf | 11 +-
.../src/main/resources/reference.conf | 18 +-
.../jackson/JacksonObjectMapperProvider.scala | 58 +--
.../serialization/jackson/JacksonSerializer.scala | 73 ++-
.../jackson/CaseObjectInitializationProbe.scala | 22 +-
.../serialization/jackson/JacksonFactorySpec.scala | 15 +
.../jackson/JacksonSerializerSpec.scala | 135 +++++-
.../src/main/resources/reference.conf | 18 +-
.../jackson3/JacksonObjectMapperProvider.scala | 66 +--
.../serialization/jackson3/JacksonSerializer.scala | 73 ++-
.../jackson3/CaseObjectInitializationProbe.scala | 22 +-
.../jackson3/JacksonFactorySpec.scala | 15 +
.../jackson3/JacksonSerializerSpec.scala | 135 +++++-
slf4j/src/test/resources/logback-test.xml | 8 +
.../apache/pekko/event/slf4j/Slf4jLoggerSpec.scala | 2 +
.../pekko/stream/testkit/StreamTestKit.scala | 22 +-
.../org/apache/pekko/stream/javadsl/SinkTest.java | 12 +
.../stream/stage/JavaSubclassCompilationCheck.java | 17 +-
.../scala/org/apache/pekko/stream/FusingSpec.scala | 170 ++++++-
.../pekko/stream/impl/TraversalBuilderSpec.scala | 41 +-
.../stream/impl/fusing/GraphInterpreterSpec.scala | 65 +++
.../impl/fusing/InstrumentationPointsSpec.scala | 44 ++
.../pekko/stream/io/InputStreamSourceSpec.scala | 20 +-
.../scala/org/apache/pekko/stream/io/TcpSpec.scala | 7 +-
.../scala/org/apache/pekko/stream/io/TlsSpec.scala | 14 +-
.../scaladsl/AggregateWithBoundarySpec.scala | 6 +-
.../pekko/stream/scaladsl/BidiFlowSpec.scala | 3 +-
.../pekko/stream/scaladsl/CollectionSinkSpec.scala | 10 +-
.../pekko/stream/scaladsl/FlowCompileSpec.scala | 1 -
.../pekko/stream/scaladsl/FlowFutureFlowSpec.scala | 6 +-
.../pekko/stream/scaladsl/FlowGroupedSpec.scala | 6 +-
.../stream/scaladsl/FlowGroupedWeightedSpec.scala | 9 +-
.../stream/scaladsl/FlowGroupedWithinSpec.scala | 75 ++-
.../pekko/stream/scaladsl/FlowJoinSpec.scala | 4 +-
.../scaladsl/FlowMapAsyncPartitionedSpec.scala | 5 +-
.../pekko/stream/scaladsl/FlowOrElseSpec.scala | 1 -
.../stream/scaladsl/FlowPrefixAndTailSpec.scala | 19 +-
.../pekko/stream/scaladsl/FlowScanAsyncSpec.scala | 9 +-
.../pekko/stream/scaladsl/FlowScanSpec.scala | 5 +-
.../apache/pekko/stream/scaladsl/FlowSpec.scala | 5 +-
.../stream/scaladsl/FlowSupervisionSpec.scala | 3 +-
.../scaladsl/GraphMergePrioritizedNSpec.scala | 3 +-
.../stream/scaladsl/GraphMergeSequenceSpec.scala | 5 +-
.../stream/scaladsl/GraphMergeSortedSpec.scala | 2 +-
.../stream/scaladsl/GraphOpsIntegrationSpec.scala | 18 +-
.../pekko/stream/scaladsl/GraphZipNSpec.scala | 35 +-
.../pekko/stream/scaladsl/GraphZipWithNSpec.scala | 19 +-
.../org/apache/pekko/stream/scaladsl/HubSpec.scala | 3 +-
.../pekko/stream/scaladsl/JsonFramingSpec.scala | 1 -
.../pekko/stream/scaladsl/LazyFlowSpec.scala | 25 +-
.../pekko/stream/scaladsl/LazySourceSpec.scala | 1 -
.../apache/pekko/stream/scaladsl/SeqSinkSpec.scala | 13 +-
.../apache/pekko/stream/scaladsl/SinkSpec.scala | 17 +-
.../stream/scaladsl/SinkWatchTerminationSpec.scala | 352 +++++++++++++-
.../apache/pekko/stream/scaladsl/SourceSpec.scala | 125 +++--
.../pekko/stream/scaladsl/StreamRefsSpec.scala | 3 +-
.../pekko/stream/scaladsl/TakeLastSinkSpec.scala | 19 +-
.../stream/scaladsl/WithContextUsageSpec.scala | 4 +-
.../pekko/stream/MapAsyncPartitionedSpec.scala | 17 +-
stream-typed/src/test/resources/logback-test.xml | 8 +
.../test/scala/docs/scaladsl/ActorFlowSpec.scala | 15 +-
.../org/apache/pekko/stream/StreamRefMessages.java | 84 ++--
.../2.0.x.backwards.excludes/mima-1.2.0.excludes | 54 +++
.../scala-2.13-idioms.excludes} | 6 +-
stream/src/main/mima-filters/binary-api | 39 ++
.../scala/org/apache/pekko/stream/Attributes.scala | 19 -
.../scala/org/apache/pekko/stream/FanInShape.scala | 11 +-
.../org/apache/pekko/stream/FanOutShape.scala | 11 +-
.../main/scala/org/apache/pekko/stream/Shape.scala | 33 +-
.../org/apache/pekko/stream/SslTlsOptions.scala | 5 +-
.../apache/pekko/stream/UniformFanInShape.scala | 5 +-
.../apache/pekko/stream/UniformFanOutShape.scala | 5 +-
.../pekko/stream/impl/ActorMaterializerImpl.scala | 3 +-
.../apache/pekko/stream/impl/ActorPublisher.scala | 5 +-
.../org/apache/pekko/stream/impl/FanOut.scala | 3 +-
.../stream/impl/FanoutPublisherBridgeStage.scala | 7 +-
.../scala/org/apache/pekko/stream/impl/Sinks.scala | 4 +-
.../pekko/stream/impl/TraversalBuilder.scala | 20 +-
.../stream/impl/fusing/ActorGraphInterpreter.scala | 89 +++-
.../pekko/stream/impl/fusing/FlatMapPrefix.scala | 3 +-
.../stream/impl/fusing/GraphInterpreter.scala | 114 ++++-
.../impl/fusing/GroupedAdjacentByWeighted.scala | 11 +-
.../org/apache/pekko/stream/impl/fusing/Ops.scala | 17 +-
.../pekko/stream/impl/fusing/StreamOfStreams.scala | 6 +-
.../pekko/stream/impl/fusing/WatchedSink.scala | 292 +++++-------
.../pekko/stream/impl/io/ByteStringParser.scala | 3 +-
.../pekko/stream/impl/io/InputStreamSource.scala | 7 +
.../org/apache/pekko/stream/javadsl/Flow.scala | 31 +-
.../apache/pekko/stream/javadsl/RetryFlow.scala | 3 -
.../org/apache/pekko/stream/javadsl/Sink.scala | 20 +-
.../org/apache/pekko/stream/javadsl/Source.scala | 40 +-
.../org/apache/pekko/stream/javadsl/SubFlow.scala | 31 +-
.../apache/pekko/stream/javadsl/SubSource.scala | 31 +-
.../org/apache/pekko/stream/scaladsl/Flow.scala | 43 +-
.../pekko/stream/scaladsl/FlowWithContextOps.scala | 5 +-
.../org/apache/pekko/stream/scaladsl/Graph.scala | 12 +-
.../apache/pekko/stream/scaladsl/RetryFlow.scala | 3 -
.../org/apache/pekko/stream/scaladsl/Sink.scala | 31 +-
.../org/apache/pekko/stream/scaladsl/Source.scala | 34 +-
.../org/apache/pekko/stream/scaladsl/Tcp.scala | 15 +-
.../pekko/stream/snapshot/MaterializerState.scala | 40 +-
.../org/apache/pekko/stream/stage/GraphStage.scala | 129 +++--
.../apache/pekko/testkit/TestEventListener.scala | 9 +-
.../scala/org/apache/pekko/testkit/TestKit.scala | 33 +-
.../scala/org/apache/pekko/testkit/package.scala | 5 +-
.../apache/pekko/testkit/TestActorRefSpec.scala | 2 +-
775 files changed, 14199 insertions(+), 5907 deletions(-)
create mode 100644 .github/workflows/nightly-multi-jvm-tests.yml
copy .github/workflows/{publish-1.2-docs.yml => publish-1.7-docs.yml} (86%)
create mode 100644 SECURITY.md
create mode 100644 THREAT_MODEL.md
copy
actor-testkit-typed/src/main/mima-filters/2.0.x.backwards.excludes/{renamed-methods.excludes
=> mima-1.2.0.excludes} (67%)
copy actor/src/main/mima-filters/2.0.x.backwards.excludes/scheduler.excludes
=>
actor-testkit-typed/src/main/mima-filters/2.0.x.backwards.excludes/patience-def.excludes
(83%)
create mode 100644
actor-testkit-typed/src/test/scala/org/apache/pekko/actor/testkit/typed/scaladsl/ScalaTestWithActorTestKitSpec.scala
create mode 100644
actor-tests/src/test/java/org/apache/pekko/actor/AbstractFSMWithStashActorTest.java
create mode 100644
actor-tests/src/test/java/org/apache/pekko/actor/JavaSubclassCompilationCheck.java
create mode 100644
actor-tests/src/test/scala/org/apache/pekko/dispatch/InstrumentationPointsSpec.scala
create mode 100644
actor-tests/src/test/scala/org/apache/pekko/event/LogSourceSpec.scala
create mode 100644
actor-tests/src/test/scala/org/apache/pekko/io/dns/internal/DomainNameSpec.scala
create mode 100644
actor-tests/src/test/scala/org/apache/pekko/routing/ConsistentHashSpec.scala
create mode 100644
actor-tests/src/test/scala/org/apache/pekko/serialization/DecompressionSpec.scala
create mode 100644
actor-tests/src/test/scala/org/apache/pekko/serialization/WireConfigSpec.scala
create mode 100644
actor-tests/src/test/scala/org/apache/pekko/serialization/WireManifestClassLoadingSpec.scala
create mode 100644
actor-tests/src/test/scala/org/apache/pekko/util/GlobSpec.scala
create mode 100644
actor-tests/src/test/scala/org/apache/pekko/util/LineNumbersConstantPoolSpec.scala
create mode 100644
actor-typed/src/main/mima-filters/2.0.x.backwards.excludes/mima-1.2.0.excludes
create mode 100644
actor/src/main/mima-filters/2.0.x.backwards.excludes/mima-1.2.0.excludes
create mode 100644
actor/src/main/mima-filters/2.0.x.backwards.excludes/receive-timeout-with-duration.excludes
create mode 100644 actor/src/main/mima-filters/binary-api
copy testkit/src/main/java/org/apache/pekko/testkit/javadsl/package-info.java
=> actor/src/main/scala-2.13/org/apache/pekko/event/LogSourceCompat.scala (76%)
copy
persistence-query/src/main/java/org/apache/pekko/persistence/query/javadsl/package-info.java
=> actor/src/main/scala-3/org/apache/pekko/event/LogSourceCompat.scala (60%)
create mode 100644
actor/src/main/scala/org/apache/pekko/serialization/Decompression.scala
create mode 100644
actor/src/main/scala/org/apache/pekko/serialization/NestedDeserialization.scala
create mode 100644
actor/src/main/scala/org/apache/pekko/serialization/WireConfig.scala
create mode 100644 actor/src/main/scala/org/apache/pekko/util/Glob.scala
create mode 100644
bench-jmh/src/main/scala/org/apache/pekko/util/ByteString_byteAtUnchecked_Benchmark.scala
create mode 100644
bench-jmh/src/main/scala/org/apache/pekko/util/ByteString_equals_Benchmark.scala
copy
actor/src/main/mima-filters/2.0.x.backwards.excludes/fsm-transition-listeners.excludes
=> cluster-sharding-typed/src/main/mima-filters/binary-api (63%)
create mode 100644
cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/internal/ExtractorAdapterSpec.scala
create mode 100644
cluster-sharding/src/main/mima-filters/2.0.x.backwards.excludes/mima-1.2.0.excludes
copy
stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-gunzip.excludes =>
cluster-sharding/src/main/mima-filters/2.0.x.backwards.excludes/remove-akka-2.3-sharding-data-removal.excludes
(77%)
copy
actor/src/main/mima-filters/2.0.x.backwards.excludes/fsm-transition-listeners.excludes
=> cluster-sharding/src/main/mima-filters/binary-api (68%)
create mode 100644
cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/passivation/PassivationStopTimeoutSpec.scala
copy
cluster/src/main/mima-filters/2.0.x.backwards.excludes/{remove-deprecated-methods.excludes
=> mima-1.2.0.excludes} (56%)
create mode 100644
cluster/src/test/scala/org/apache/pekko/cluster/protobuf/ClusterMessageSerializerDecompressionSpec.scala
create mode 100644
coordination/src/main/scala/org/apache/pekko/coordination/lease/LeaseHealthCheck.scala
create mode 100644
coordination/src/test/scala/org/apache/pekko/coordination/lease/LeaseHealthCheckSpec.scala
create mode 100644
distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/protobuf/SerializationSupportDecompressionSpec.scala
delete mode 100644 docs/src/main/paradox/_template/projectSpecificFooter.st
delete mode 100644 docs/src/main/paradox/assets/js/warnOldDocs.js
create mode 100644 docs/src/main/paradox/release-notes/releases-1.7.md
create mode 100644
docs/src/test/java/jdocs/stream/operators/source/QueueMigrationDocTest.java
create mode 100644
docs/src/test/scala/docs/remoting/SSLEngineProviderDocSpec.scala
create mode 100644
docs/src/test/scala/docs/stream/operators/source/QueueMigrationDocSpec.scala
mode change 100755 => 100644 kubernetes/setup.sh
copy
stream/src/main/mima-filters/1.0.x.backwards.excludes/pr-991-remove-unused-attributes.backwards.excludes
=>
multi-node-testkit/src/main/mima-filters/2.0.x.backwards.excludes/mima-1.2.0.excludes
(56%)
create mode 100644
persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/internal/EventWriterSpec.scala
create mode 100644
persistence-typed/src/main/mima-filters/2.0.x.backwards.excludes/mima-1.2.0.excludes
create mode 100644
persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/internal/EventWriter.scala
create mode 100644
persistence/src/main/mima-filters/2.0.x.backwards.excludes/mima-1.2.0.excludes
create mode 100644
persistence/src/test/java/org/apache/pekko/persistence/JavaTimerPersistentActor.java
create mode 100644
persistence/src/test/java/org/apache/pekko/persistence/fsm/JavaSubclassCompilationCheck.java
mode change 100755 => 100644 project/scripts/find-replace
mode change 100755 => 100644 project/scripts/validate-automatic-module-names
copy
stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-substream-cancel-strategy.excludes
=> remote/src/main/mima-filters/2.0.x.backwards.excludes/mima-1.2.0.excludes
(51%)
copy
actor/src/main/mima-filters/2.0.x.backwards.excludes/fsm-transition-listeners.excludes
=> remote/src/main/mima-filters/binary-api (60%)
copy remote/src/test/resources/ssl/{pem/selfsigned-certificate.pem =>
exampleca-bundle.crt} (56%)
create mode 100644 remote/src/test/resources/ssl/exampleca-rotated-bundle.crt
create mode 100644 remote/src/test/resources/ssl/exampleca-rotated.crt
mode change 100755 => 100644
remote/src/test/resources/ssl/gen-artery-nodes.example.com.sh
create mode 100644 remote/src/test/resources/ssl/gen-ca-bundles.sh
mode change 100755 => 100644 remote/src/test/resources/ssl/genca.sh
mode change 100755 => 100644 remote/src/test/resources/ssl/gencerts.sh
create mode 100644
remote/src/test/scala/org/apache/pekko/remote/InstrumentationPointsSpec.scala
create mode 100644
remote/src/test/scala/org/apache/pekko/remote/NonTlsWarningSpec.scala
create mode 100644
remote/src/test/scala/org/apache/pekko/remote/artery/ArterySettingsSpec.scala
create mode 100644
remote/src/test/scala/org/apache/pekko/remote/serialization/DaemonMsgCreateSerializerAllowListSpec.scala
create mode 100644
remote/src/test/scala/org/apache/pekko/remote/serialization/NestedPayloadDepthSpec.scala
copy
cluster-sharding-typed/src/main/java/org/apache/pekko/cluster/sharding/typed/javadsl/package-info.java
=>
serialization-jackson/src/test/scala/org/apache/pekko/serialization/jackson/CaseObjectInitializationProbe.scala
(56%)
copy
cluster-sharding-typed/src/main/java/org/apache/pekko/cluster/sharding/typed/javadsl/package-info.java
=>
serialization-jackson3/src/test/scala/org/apache/pekko/serialization/jackson3/CaseObjectInitializationProbe.scala
(56%)
copy
actor-typed/src/main/java/org/apache/pekko/actor/typed/javadsl/package-info.java
=>
stream-tests/src/test/java/org/apache/pekko/stream/stage/JavaSubclassCompilationCheck.java
(59%)
create mode 100644
stream-tests/src/test/scala/org/apache/pekko/stream/impl/fusing/InstrumentationPointsSpec.scala
create mode 100644
stream/src/main/mima-filters/2.0.x.backwards.excludes/mima-1.2.0.excludes
copy
stream/src/main/mima-filters/{1.1.x.backwards.excludes/pr-1669-avoid-boxing-in-zipWithIndex.backwards.excludes
=> 2.0.x.backwards.excludes/scala-2.13-idioms.excludes} (78%)
create mode 100644 stream/src/main/mima-filters/binary-api
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
