This is an automated email from the ASF dual-hosted git repository.
hepin pushed a change to branch duration
in repository https://gitbox.apache.org/repos/asf/pekko.git
omit cf73007b7f chore: sortImports
omit 02cc83f04d chore: Use scala.jdk.DurationConverters
add 4d7bc6899e chore: remove scala.compat.java8 in osgi (#2211)
add c0ffd72dec Update protobuf-java to 4.32.1 (#2216)
add 94ae86fa6f Update sbt-header to 5.11.0 (#2217)
add daf3458185 Use stdlib IntFunction to not allow throwing (#2200)
add db43bf4697 Update metrics-core, metrics-jvm to 4.2.37 (#2224)
add ee704f7e5a Update sbt-develocity to 1.4 (#2223)
add e66cda2899 remove some stray java version checks (#2227)
add 5acdace08c chore: Remove compat Future (#2212)
add 8c48393cd3 chore: Remove pekko.dispatch.ExecutionContexts.parasitic
(#2208)
add 3969ae8276 chore: Remove serialversion-remover-plugin (#2204)
add d07c755732 chore: Use scala.jdk.DurationConverters
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 (cf73007b7f)
\
N -- N -- N refs/heads/duration (d07c755732)
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:
.../actor/testkit/typed/CapturedLogEvent.scala | 6 +--
.../apache/pekko/actor/testkit/typed/Effect.scala | 2 +-
.../pekko/actor/testkit/typed/LoggingEvent.scala | 8 +--
.../actor/testkit/typed/TestKitSettings.scala | 6 +--
.../testkit/typed/internal/ActorSystemStub.scala | 12 ++---
.../typed/internal/BehaviorTestKitImpl.scala | 3 +-
.../typed/internal/EffectfulActorContext.scala | 10 ++--
.../actor/testkit/typed/internal/LogbackUtil.scala | 7 ++-
.../typed/internal/LoggingTestKitImpl.scala | 4 +-
.../typed/internal/StubbedActorContext.scala | 16 +++---
.../testkit/typed/internal/TestAppender.scala | 6 +--
.../testkit/typed/internal/TestProbeImpl.scala | 2 +-
.../actor/testkit/typed/javadsl/ActorTestKit.scala | 5 +-
.../testkit/typed/javadsl/BehaviorTestKit.scala | 9 ++--
.../actor/testkit/typed/javadsl/Effects.scala | 3 +-
.../typed/javadsl/JUnit5TestKitBuilder.scala | 3 +-
.../actor/testkit/typed/javadsl/LogCapturing.scala | 3 +-
.../typed/javadsl/LogCapturingExtension.scala | 11 ++--
.../testkit/typed/javadsl/LoggingTestKit.scala | 4 +-
.../actor/testkit/typed/javadsl/ManualTime.scala | 6 +--
.../typed/javadsl/TestKitJUnit5Extension.scala | 3 +-
.../typed/javadsl/TestKitJunitResource.scala | 5 +-
.../actor/testkit/typed/javadsl/TestProbe.scala | 2 +-
.../testkit/typed/scaladsl/ActorTestKit.scala | 9 ++--
.../testkit/typed/scaladsl/ActorTestKitBase.scala | 6 +--
.../testkit/typed/scaladsl/BehaviorTestKit.scala | 14 +++--
.../testkit/typed/scaladsl/LogCapturing.scala | 5 +-
.../testkit/typed/scaladsl/LoggingTestKit.scala | 4 +-
.../actor/testkit/typed/scaladsl/ManualTime.scala | 4 +-
.../typed/scaladsl/ScalaTestWithActorTestKit.scala | 11 ++--
.../testkit/typed/scaladsl/ActorTestKitSpec.scala | 11 ++--
.../typed/scaladsl/BehaviorTestKitSpec.scala | 14 +++--
.../typed/scaladsl/JUnit5TestKitBuilderSpec.scala | 6 +--
.../typed/scaladsl/LoggingEventFilterSpec.scala | 5 +-
.../testkit/typed/scaladsl/TestAppenderSpec.scala | 5 +-
.../testkit/typed/scaladsl/TestProbeSpec.scala | 5 +-
.../org/apache/pekko/util/TypedMultiMapSpec.scala | 1 -
.../dispatch/ForkJoinPoolVirtualThreadSpec.scala | 4 +-
.../dispatch/ThreadPoolVirtualThreadSpec.scala | 3 +-
.../dispatch/VirtualThreadPoolDispatcherSpec.scala | 4 +-
.../org/apache/pekko/PekkoExceptionSpec.scala | 4 +-
.../actor/ActorConfigurationVerificationSpec.scala | 4 +-
.../apache/pekko/actor/ActorCreationPerfSpec.scala | 6 +--
.../apache/pekko/actor/ActorLifeCycleSpec.scala | 4 +-
.../org/apache/pekko/actor/ActorMailboxSpec.scala | 6 +--
.../pekko/actor/ActorSystemDispatcherSpec.scala | 4 +-
.../org/apache/pekko/actor/ActorSystemSpec.scala | 5 +-
.../pekko/actor/ActorWithBoundedStashSpec.scala | 7 ++-
.../apache/pekko/actor/ActorWithStashSpec.scala | 6 +--
.../pekko/actor/CoordinatedShutdownSpec.scala | 25 ++++-----
.../pekko/actor/DeadLetterSupressionSpec.scala | 2 +-
.../pekko/actor/DeadLetterSuspensionSpec.scala | 2 +-
.../org/apache/pekko/actor/DeathWatchSpec.scala | 3 +-
.../org/apache/pekko/actor/DeployerSpec.scala | 6 +--
.../org/apache/pekko/actor/ExtensionSpec.scala | 9 ++--
.../org/apache/pekko/actor/FSMActorSpec.scala | 4 +-
.../org/apache/pekko/actor/FunctionRefSpec.scala | 2 +-
.../pekko/actor/LocalActorRefProviderSpec.scala | 3 +-
.../apache/pekko/actor/ProviderSelectionSpec.scala | 4 +-
.../apache/pekko/actor/RestartStrategySpec.scala | 5 +-
.../org/apache/pekko/actor/SchedulerSpec.scala | 8 ++-
.../pekko/actor/SupervisorHierarchySpec.scala | 5 +-
.../apache/pekko/actor/SupervisorMiscSpec.scala | 5 +-
.../org/apache/pekko/actor/SupervisorSpec.scala | 9 ++--
.../org/apache/pekko/actor/Ticket669Spec.scala | 6 +--
.../pekko/actor/dispatch/ActorModelSpec.scala | 9 ++--
.../pekko/actor/dispatch/DispatcherActorSpec.scala | 2 +-
.../pekko/actor/dispatch/DispatchersSpec.scala | 6 +--
.../pekko/actor/dispatch/PinnedActorSpec.scala | 4 +-
.../pekko/actor/setup/ActorSystemSetupSpec.scala | 6 +--
.../scala/org/apache/pekko/config/ConfigSpec.scala | 7 ++-
.../pekko/dispatch/DispatcherShutdownSpec.scala | 6 +--
.../pekko/dispatch/ExecutionContextSpec.scala | 2 +-
.../dispatch/ForkJoinPoolStarvationSpec.scala | 4 +-
.../apache/pekko/dispatch/MailboxConfigSpec.scala | 7 ++-
.../pekko/dispatch/PriorityDispatcherSpec.scala | 4 +-
.../dispatch/SameThreadExecutionContextSpec.scala | 11 ++--
.../dispatch/StablePriorityDispatcherSpec.scala | 4 +-
.../org/apache/pekko/event/EventBusSpec.scala | 7 ++-
.../org/apache/pekko/event/EventStreamSpec.scala | 4 +-
.../scala/org/apache/pekko/event/LoggerSpec.scala | 9 ++--
.../apache/pekko/event/LoggingReceiveSpec.scala | 9 ++--
.../org/apache/pekko/io/SimpleDnsCacheSpec.scala | 6 +--
.../org/apache/pekko/io/TcpConnectionSpec.scala | 6 +--
.../org/apache/pekko/io/TcpIntegrationSpec.scala | 4 +-
.../pekko/io/TcpIntegrationSpecSupport.scala | 4 +-
.../pekko/io/UdpConnectedIntegrationSpec.scala | 2 +-
.../org/apache/pekko/io/UdpIntegrationSpec.scala | 1 -
.../io/dns/AsyncDnsResolverIntegrationSpec.scala | 10 ++--
.../org/apache/pekko/io/dns/DnsSettingsSpec.scala | 4 +-
.../apache/pekko/io/dns/DockerBindDnsService.scala | 6 +--
.../io/dns/internal/AsyncDnsResolverSpec.scala | 3 +-
.../pekko/io/dns/internal/DnsClientSpec.scala | 2 -
.../apache/pekko/io/dns/internal/MessageSpec.scala | 6 +--
.../scala/org/apache/pekko/pattern/AskSpec.scala | 2 +-
.../pattern/BackoffOnRestartSupervisorSpec.scala | 3 +-
.../pekko/pattern/BackoffSupervisorSpec.scala | 6 +--
.../apache/pekko/pattern/CircuitBreakerSpec.scala | 1 -
.../pekko/pattern/CircuitBreakerStressSpec.scala | 2 +-
.../org/apache/pekko/pattern/PatternSpec.scala | 1 -
.../scala/org/apache/pekko/pattern/RetrySpec.scala | 4 +-
.../org/apache/pekko/pattern/StatusReplySpec.scala | 4 +-
.../org/apache/pekko/routing/BalancingSpec.scala | 6 +--
.../pekko/routing/ConfiguredLocalRoutingSpec.scala | 6 +--
.../org/apache/pekko/routing/ResizerSpec.scala | 4 +-
.../org/apache/pekko/routing/RoutingSpec.scala | 4 +-
.../pekko/serialization/AsyncSerializeSpec.scala | 5 +-
.../PrimitivesSerializationSpec.scala | 4 +-
.../serialization/SerializationSetupSpec.scala | 4 +-
.../apache/pekko/serialization/SerializeSpec.scala | 3 +-
.../testkit/CallingThreadDispatcherModelSpec.scala | 4 +-
.../pekko/util/BoundedBlockingQueueSpec.scala | 11 ++--
.../org/apache/pekko/util/ByteIteratorSpec.scala | 4 +-
.../org/apache/pekko/util/ByteStringSpec.scala | 5 +-
.../org/apache/pekko/util/FrequencyListSpec.scala | 4 +-
.../apache/pekko/util/FrequencySketchSpec.scala | 4 +-
.../scala/org/apache/pekko/util/IndexSpec.scala | 6 +--
.../org/apache/pekko/util/MessageBufferSpec.scala | 4 +-
.../org/apache/pekko/util/RecencyListSpec.scala | 4 +-
.../org/apache/pekko/util/Scala212CompatTest.scala | 7 ++-
.../pekko/util/SegmentedRecencyListSpec.scala | 4 +-
.../pekko/actor/typed/ActorContextSpec.scala | 4 +-
.../pekko/actor/typed/ActorRefIgnoreSpec.scala | 6 +--
.../pekko/actor/typed/ActorRefResolverSpec.scala | 8 +--
.../apache/pekko/actor/typed/ActorSystemSpec.scala | 5 +-
.../org/apache/pekko/actor/typed/AskSpec.scala | 5 +-
.../apache/pekko/actor/typed/BehaviorSpec.scala | 8 ++-
.../apache/pekko/actor/typed/DeferredSpec.scala | 6 +--
.../apache/pekko/actor/typed/ExtensionsSpec.scala | 7 ++-
.../apache/pekko/actor/typed/InterceptSpec.scala | 4 +-
.../LocalActorRefProviderLogMessagesSpec.scala | 1 -
.../apache/pekko/actor/typed/LogMessagesSpec.scala | 7 ++-
.../pekko/actor/typed/MailboxSelectorSpec.scala | 4 +-
.../org/apache/pekko/actor/typed/MonitorSpec.scala | 4 +-
.../org/apache/pekko/actor/typed/OrElseSpec.scala | 6 +--
.../org/apache/pekko/actor/typed/PropsSpec.scala | 4 +-
.../pekko/actor/typed/SpawnProtocolSpec.scala | 6 +--
.../apache/pekko/actor/typed/SupervisionSpec.scala | 16 +++---
.../apache/pekko/actor/typed/TerminatedSpec.scala | 6 +--
.../org/apache/pekko/actor/typed/TimerSpec.scala | 4 +-
.../pekko/actor/typed/TransformMessagesSpec.scala | 4 +-
.../org/apache/pekko/actor/typed/WatchSpec.scala | 4 +-
.../coexistence/ClassicSupervisingTypedSpec.scala | 9 ++--
.../coexistence/TypedSupervisingClassicSpec.scala | 4 +-
.../typed/delivery/ConsumerControllerSpec.scala | 6 +--
.../delivery/DurableProducerControllerSpec.scala | 7 ++-
.../typed/delivery/DurableProducerQueueSpec.scala | 8 +--
.../typed/delivery/DurableWorkPullingSpec.scala | 3 +-
.../typed/delivery/ProducerControllerSpec.scala | 7 ++-
.../delivery/ReliableDeliveryRandomSpec.scala | 9 ++--
.../typed/delivery/ReliableDeliverySpec.scala | 9 ++--
.../pekko/actor/typed/delivery/TestConsumer.scala | 10 ++--
.../actor/typed/delivery/TestProducerWithAsk.scala | 2 +-
.../actor/typed/delivery/WorkPullingSpec.scala | 4 +-
.../typed/eventstream/EventStreamDocSpec.scala | 1 -
.../actor/typed/eventstream/EventStreamSpec.scala | 4 +-
.../typed/internal/ActorRefSerializationSpec.scala | 7 ++-
.../actor/typed/internal/ActorSystemSpec.scala | 18 +++----
.../typed/internal/adpater/PropsAdapterSpec.scala | 6 +--
.../receptionist/LocalReceptionistSpec.scala | 6 +--
.../receptionist/ServiceKeySerializationSpec.scala | 4 +-
.../typed/internal/routing/PoolRouterSpec.scala | 4 +-
.../typed/internal/routing/RoutingLogicSpec.scala | 6 +--
.../typed/javadsl/AdaptationFailureSpec.scala | 4 +-
.../pekko/actor/typed/pubsub/LocalPubSubSpec.scala | 4 +-
.../actor/typed/scaladsl/ActorContextAskSpec.scala | 10 ++--
.../typed/scaladsl/ActorContextDelegateSpec.scala | 1 -
.../scaladsl/ActorContextPipeToSelfSpec.scala | 7 ++-
.../actor/typed/scaladsl/ActorLoggingSpec.scala | 14 +++--
.../actor/typed/scaladsl/ActorThreadSpec.scala | 1 -
.../typed/scaladsl/AdaptationFailureSpec.scala | 4 +-
.../typed/scaladsl/DispatcherSelectorSpec.scala | 11 ++--
.../actor/typed/scaladsl/GracefulStopSpec.scala | 4 +-
.../pekko/actor/typed/scaladsl/LoggerOpsSpec.scala | 7 ++-
.../actor/typed/scaladsl/MailboxSelectorSpec.scala | 9 ++--
.../actor/typed/scaladsl/MessageAdapterSpec.scala | 10 ++--
.../pekko/actor/typed/scaladsl/OnSignalSpec.scala | 4 +-
.../actor/typed/scaladsl/ReceivePartialSpec.scala | 4 +-
.../pekko/actor/typed/scaladsl/RoutersSpec.scala | 6 +--
.../actor/typed/scaladsl/StashBufferSpec.scala | 6 +--
.../pekko/actor/typed/scaladsl/StashSpec.scala | 4 +-
.../pekko/actor/typed/scaladsl/StopSpec.scala | 4 +-
.../actor/typed/scaladsl/adapter/AdapterSpec.scala | 8 +--
.../scaladsl/adapter/GuardianStartupSpec.scala | 8 +--
.../org/apache/pekko/actor/typed/ActorSystem.scala | 6 +--
.../org/apache/pekko/actor/typed/LogOptions.scala | 4 +-
.../pekko/actor/typed/SupervisorStrategy.scala | 6 +--
.../actor/typed/delivery/ConsumerController.scala | 6 +--
.../actor/typed/delivery/ProducerController.scala | 8 +--
.../delivery/WorkPullingProducerController.scala | 6 +--
.../actor/typed/eventstream/EventStream.scala | 1 -
.../actor/typed/internal/ActorContextImpl.scala | 18 +++----
.../pekko/actor/typed/internal/ActorMdc.scala | 4 +-
.../pekko/actor/typed/internal/BehaviorImpl.scala | 6 +--
.../actor/typed/internal/InterceptorImpl.scala | 6 +--
.../actor/typed/internal/StashBufferImpl.scala | 7 ++-
.../pekko/actor/typed/internal/Supervision.scala | 5 +-
.../actor/typed/internal/TimerSchedulerImpl.scala | 13 +++--
.../internal/WithMdcBehaviorInterceptor.scala | 4 +-
.../internal/adapter/ActorSystemAdapter.scala | 6 +--
.../typed/internal/routing/PoolRouterImpl.scala | 6 +--
.../pekko/actor/typed/javadsl/ActorContext.scala | 4 +-
.../pekko/actor/typed/javadsl/AskPattern.scala | 3 +-
.../pekko/actor/typed/javadsl/ReceiveBuilder.scala | 4 +-
.../apache/pekko/actor/typed/javadsl/Routers.scala | 4 +-
.../pekko/actor/typed/javadsl/StashBuffer.scala | 4 +-
.../pekko/actor/typed/scaladsl/ActorContext.scala | 4 +-
.../pekko/actor/typed/scaladsl/AskPattern.scala | 3 +-
.../pekko/actor/typed/scaladsl/Behaviors.scala | 1 -
.../actor/typed/scaladsl/TimerScheduler.scala | 4 +-
.../apache/pekko/japi/function/IntFunction.java | 37 --------------
.../apache/pekko/japi/function/package-info.java | 19 -------
.../future-converters.excludes | 3 ++
.../remove-scala-2.12-support.excludes | 2 +
.../internal/SameThreadExecutionContext.scala | 29 -----------
.../org/apache/pekko/util/ByteIterator.scala | 5 +-
.../org/apache/pekko/util/ByteString.scala | 1 -
.../org/apache/pekko/util/FutureConverters.scala | 5 +-
.../org/apache/pekko/util/OptionConverters.scala | 5 +-
.../internal/SameThreadExecutionContext.scala | 30 -----------
.../scala/org/apache/pekko/actor/AbstractFSM.scala | 2 +-
.../org/apache/pekko/actor/AbstractProps.scala | 2 +-
.../scala/org/apache/pekko/actor/ActorPath.scala | 3 +-
.../org/apache/pekko/actor/ActorSelection.scala | 10 ++--
.../scala/org/apache/pekko/actor/ActorSystem.scala | 6 +--
.../apache/pekko/actor/CoordinatedShutdown.scala | 13 +++--
.../scala/org/apache/pekko/actor/Deployer.scala | 6 +--
.../org/apache/pekko/actor/FaultHandling.scala | 17 +++----
.../apache/pekko/actor/IndirectActorProducer.scala | 3 +-
.../pekko/actor/LightArrayRevolverScheduler.scala | 3 +-
.../apache/pekko/actor/RepointableActorRef.scala | 3 +-
.../main/scala/org/apache/pekko/actor/Timers.scala | 2 +-
.../org/apache/pekko/actor/dungeon/Children.scala | 3 +-
.../org/apache/pekko/actor/dungeon/Dispatch.scala | 3 +-
.../scala/org/apache/pekko/compat/Future.scala | 59 ----------------------
.../apache/pekko/dispatch/BatchingExecutor.scala | 7 ++-
.../apache/pekko/dispatch/CompletionStages.scala | 7 ++-
.../org/apache/pekko/dispatch/Dispatcher.scala | 3 +-
.../org/apache/pekko/dispatch/Dispatchers.scala | 4 +-
.../dispatch/ForkJoinExecutorConfigurator.scala | 5 +-
.../scala/org/apache/pekko/dispatch/Future.scala | 17 -------
.../scala/org/apache/pekko/dispatch/Mailbox.scala | 5 +-
.../org/apache/pekko/dispatch/Mailboxes.scala | 4 +-
.../apache/pekko/dispatch/ThreadPoolBuilder.scala | 9 ++--
.../pekko/dispatch/VirtualThreadSupport.scala | 9 ++--
.../dispatch/VirtualizedExecutorService.scala | 4 +-
.../pekko/dispatch/affinity/AffinityPool.scala | 7 ++-
.../org/apache/pekko/event/LoggerMailbox.scala | 4 +-
.../scala/org/apache/pekko/event/Logging.scala | 6 ++-
actor/src/main/scala/org/apache/pekko/io/Dns.scala | 3 +-
.../apache/pekko/io/InetAddressDnsResolver.scala | 4 +-
.../org/apache/pekko/io/SelectionHandler.scala | 4 +-
.../org/apache/pekko/io/SimpleDnsManager.scala | 2 -
actor/src/main/scala/org/apache/pekko/io/Tcp.scala | 8 +--
.../scala/org/apache/pekko/io/TcpConnection.scala | 3 +-
.../apache/pekko/io/TcpIncomingConnection.scala | 3 +-
actor/src/main/scala/org/apache/pekko/io/Udp.scala | 6 +--
.../scala/org/apache/pekko/io/UdpConnected.scala | 3 +-
.../main/scala/org/apache/pekko/io/UdpSender.scala | 2 +-
.../org/apache/pekko/io/dns/CachePolicy.scala | 2 +-
.../org/apache/pekko/io/dns/DnsSettings.scala | 6 +--
.../org/apache/pekko/io/dns/IdGenerator.scala | 4 +-
.../pekko/io/dns/internal/AsyncDnsManager.scala | 4 +-
.../pekko/io/dns/internal/AsyncDnsResolver.scala | 4 +-
.../apache/pekko/io/dns/internal/DnsClient.scala | 4 +-
.../apache/pekko/io/dns/internal/DnsMessage.scala | 3 +-
.../pekko/io/dns/internal/TcpDnsClient.scala | 1 -
.../org/apache/pekko/japi/function/Function.scala | 4 +-
.../org/apache/pekko/pattern/AskSupport.scala | 4 +-
.../org/apache/pekko/pattern/BackoffOptions.scala | 6 +--
.../org/apache/pekko/pattern/CircuitBreaker.scala | 8 ++-
.../pekko/pattern/CircuitBreakersRegistry.scala | 2 -
.../pekko/pattern/FutureTimeoutSupport.scala | 2 +-
.../apache/pekko/pattern/GracefulStopSupport.scala | 4 +-
.../scala/org/apache/pekko/pattern/Patterns.scala | 10 ++--
.../org/apache/pekko/pattern/RetrySupport.scala | 4 +-
.../org/apache/pekko/pattern/StatusReply.scala | 5 +-
.../scala/org/apache/pekko/routing/Balancing.scala | 8 +--
.../scala/org/apache/pekko/routing/Broadcast.scala | 6 +--
.../apache/pekko/routing/ConsistentHashing.scala | 4 +-
.../routing/OptimalSizeExploringResizer.scala | 5 +-
.../scala/org/apache/pekko/routing/Random.scala | 6 +--
.../scala/org/apache/pekko/routing/Resizer.scala | 4 +-
.../org/apache/pekko/routing/RoundRobin.scala | 6 +--
.../org/apache/pekko/routing/RouterConfig.scala | 3 +-
.../routing/ScatterGatherFirstCompleted.scala | 10 ++--
.../org/apache/pekko/routing/SmallestMailbox.scala | 6 +--
.../org/apache/pekko/routing/TailChopping.scala | 6 +--
.../apache/pekko/serialization/Serialization.scala | 4 +-
.../scala/org/apache/pekko/util/ConstantFun.scala | 4 +-
.../org/apache/pekko/util/DoubleLinkedList.scala | 4 +-
.../apache/pekko/util/FlightRecorderLoader.scala | 4 +-
.../org/apache/pekko/util/FrequencyList.scala | 4 +-
.../org/apache/pekko/util/FrequencySketch.scala | 4 +-
.../org/apache/pekko/util/FunctionConverters.scala | 4 +-
.../main/scala/org/apache/pekko/util/Helpers.scala | 2 -
.../scala/org/apache/pekko/util/ManifestInfo.scala | 3 +-
.../scala/org/apache/pekko/util/RecencyList.scala | 4 +-
.../apache/pekko/util/SegmentedRecencyList.scala | 4 +-
.../org/apache/pekko/actor/ActorBenchmark.scala | 3 +-
.../actor/AffinityPoolComparativeBenchmark.scala | 3 +-
.../actor/AffinityPoolIdleCPULevelBenchmark.scala | 3 +-
.../AffinityPoolRequestResponseBenchmark.scala | 3 +-
.../pekko/actor/ForkJoinActorBenchmark.scala | 3 +-
.../org/apache/pekko/actor/JCToolsMailbox.scala | 3 +-
.../apache/pekko/actor/ManyToOneArrayMailbox.scala | 3 +-
.../pekko/actor/StashCreationBenchmark.scala | 3 +-
.../org/apache/pekko/actor/TellOnlyBenchmark.scala | 3 +-
.../pekko/actor/typed/TypedActorBenchmark.scala | 3 +-
.../actor/typed/TypedForkJoinActorBenchmark.scala | 3 +-
.../typed/delivery/ReliableDeliveryBenchmark.scala | 3 +-
.../ddata/ORSetSerializationBenchmark.scala | 3 +-
.../pekko/dispatch/CachingConfigBenchmark.scala | 3 +-
.../apache/pekko/dispatch/NodeQueueBenchmark.scala | 3 +-
.../apache/pekko/io/dns/IdGeneratorBanchmark.scala | 6 +--
.../persistence/LevelDbBatchingBenchmark.scala | 6 +--
.../pekko/remote/artery/CodecBenchmark.scala | 5 +-
.../pekko/remote/artery/SendQueueBenchmark.scala | 3 +-
.../SerializationFormatCacheBenchmark.scala | 23 ++++-----
.../jackson/JacksonSerializationBench.scala | 5 +-
.../org/apache/pekko/stream/AskBenchmark.scala | 3 +-
.../org/apache/pekko/stream/CollectBenchmark.scala | 17 +++----
.../pekko/stream/FlatMapConcatBenchmark.scala | 3 +-
.../org/apache/pekko/stream/FlowMapBenchmark.scala | 3 +-
.../org/apache/pekko/stream/FramingBenchmark.scala | 5 +-
.../apache/pekko/stream/FusedGraphsBenchmark.scala | 3 +-
.../apache/pekko/stream/InterpreterBenchmark.scala | 2 +-
.../pekko/stream/LazyFutureSourceBenchmark.scala | 3 +-
.../apache/pekko/stream/MapAsyncBenchmark.scala | 3 +-
.../pekko/stream/PartitionHubBenchmark.scala | 3 +-
.../apache/pekko/stream/SourceRefBenchmark.scala | 3 +-
.../pekko/stream/ZipWithIndexBenchmark.scala | 4 +-
.../apache/pekko/util/ArrayCopyOf_Benchmark.scala | 4 +-
.../pekko/util/FastFrequencySketchBenchmark.scala | 4 +-
.../pekko/util/FrequencySketchBenchmark.scala | 4 +-
build.sbt | 19 +------
.../cluster/metrics/ClusterMetricsCollector.scala | 3 +-
.../cluster/metrics/ClusterMetricsExtension.scala | 4 +-
.../cluster/metrics/ClusterMetricsRouting.scala | 6 +--
.../cluster/metrics/ClusterMetricsSettings.scala | 4 +-
.../cluster/metrics/ClusterMetricsStrategy.scala | 4 +-
.../org/apache/pekko/cluster/metrics/Metric.scala | 3 +-
.../metrics/protobuf/MessageSerializer.scala | 2 -
.../metrics/ClusterMetricsExtensionSpec.scala | 4 +-
.../metrics/ClusterMetricsRoutingSpec.scala | 8 +--
.../metrics/ClusterMetricsRoutingSpec.scala | 6 +--
.../metrics/ClusterMetricsSettingsSpec.scala | 4 +-
.../apache/pekko/cluster/metrics/EWMASpec.scala | 3 +-
.../apache/pekko/cluster/metrics/MetricSpec.scala | 10 ++--
.../cluster/metrics/MetricsCollectorSpec.scala | 3 +-
.../apache/pekko/cluster/metrics/TestUtil.scala | 3 +-
.../cluster/metrics/WeightedRouteesSpec.scala | 4 +-
.../metrics/protobuf/NumberInputStreamSpec.scala | 1 -
.../sharding/typed/ClusterShardingQuery.scala | 2 +-
.../sharding/typed/ClusterShardingSettings.scala | 6 +--
.../sharding/typed/ReplicatedEntityProvider.scala | 14 ++---
.../typed/ReplicatedShardingExtension.scala | 3 +-
.../typed/ShardedDaemonProcessSettings.scala | 6 +--
.../delivery/ShardingConsumerController.scala | 4 +-
.../delivery/ShardingProducerController.scala | 6 +--
.../typed/internal/ClusterShardingImpl.scala | 2 +-
.../JoinConfigCompatCheckerClusterSharding.scala | 4 +-
.../internal/ReplicatedShardingExtensionImpl.scala | 15 +++---
.../typed/internal/ShardedDaemonProcessImpl.scala | 3 +-
.../typed/internal/ShardingSerializer.scala | 4 +-
.../typed/internal/testkit/TestEntityRefImpl.scala | 3 +-
.../sharding/typed/javadsl/ClusterSharding.scala | 1 -
.../typed/javadsl/ShardedDaemonProcess.scala | 2 +-
.../sharding/typed/scaladsl/ClusterSharding.scala | 1 -
.../ClusterShardingRememberEntitiesPerfSpec.scala | 8 ++-
.../ClusterShardingPreparingForShutdownSpec.scala | 5 +-
.../sharding/typed/ClusterShardingStatsSpec.scala | 7 ++-
.../typed/MultiDcClusterShardingSpec.scala | 7 +--
.../sharding/typed/ReplicatedShardingSpec.scala | 8 ++-
.../sharding/typed/ShardedDaemonProcessSpec.scala | 7 ++-
.../typed/delivery/DeliveryThroughputSpec.scala | 4 +-
...oinConfigCompatCheckerClusterShardingSpec.scala | 9 ++--
.../ReplicatedShardingDirectReplicationSpec.scala | 5 +-
.../sharding/typed/ReplicatedShardingSpec.scala | 17 +++----
.../sharding/typed/ShardingSerializerSpec.scala | 7 ++-
.../typed/delivery/DurableShardingSpec.scala | 8 ++-
.../delivery/ReliableDeliveryShardingSpec.scala | 7 ++-
.../sharding/typed/internal/Murmur2Spec.scala | 4 +-
.../scaladsl/ClusterShardingPersistenceSpec.scala | 7 ++-
.../typed/scaladsl/ClusterShardingSpec.scala | 7 ++-
.../typed/scaladsl/ClusterShardingStateSpec.scala | 4 +-
.../typed/scaladsl/ClusterShardingStatsSpec.scala | 4 +-
.../typed/scaladsl/ShardedDaemonProcessSpec.scala | 7 ++-
.../typed/testkit/scaladsl/TestEntityRefSpec.scala | 4 +-
.../sharding/ClusterShardingHealthCheck.scala | 13 +++--
.../cluster/sharding/ClusterShardingSettings.scala | 9 ++--
.../sharding/JoinConfigCompatCheckSharding.scala | 4 +-
.../RemoveInternalClusterShardingData.scala | 4 +-
.../org/apache/pekko/cluster/sharding/Shard.scala | 9 ++--
.../pekko/cluster/sharding/ShardCoordinator.scala | 15 +++---
.../pekko/cluster/sharding/ShardRegion.scala | 4 +-
.../external/ExternalShardAllocationStrategy.scala | 2 +-
.../ExternalShardAllocationClientImpl.scala | 2 +-
.../AbstractLeastShardAllocationStrategy.scala | 8 +--
.../internal/DDataRememberEntitiesShardStore.scala | 4 +-
.../internal/EntityPassivationStrategy.scala | 8 +--
...ntSourcedRememberEntitiesCoordinatorStore.scala | 8 +--
.../internal/LeastShardAllocationStrategy.scala | 1 -
.../sharding/internal/RememberEntityStarter.scala | 6 +--
.../cluster/sharding/internal/jfr/Events.scala | 3 +-
.../ClusterShardingMessageSerializer.scala | 6 +--
.../pekko/cluster/sbr/GremlinController.scala | 3 +-
.../RandomizedBrainResolverIntegrationSpec.scala | 9 ++--
.../sbr/SplitBrainResolverIntegrationSpec.scala | 11 ++--
.../ClusterShardCoordinatorDowning2Spec.scala | 3 +-
.../ClusterShardCoordinatorDowningSpec.scala | 3 +-
.../sharding/ClusterShardingGetStateSpec.scala | 4 +-
.../sharding/ClusterShardingGetStatsSpec.scala | 1 -
...ClusterShardingGracefulShutdownOldestSpec.scala | 4 +-
.../ClusterShardingGracefulShutdownSpec.scala | 7 +--
.../sharding/ClusterShardingQueriesSpec.scala | 6 +--
...rShardingRememberEntitiesNewExtractorSpec.scala | 4 +-
.../ClusterShardingRememberEntitiesSpec.scala | 6 +--
.../ClusterShardingRolePartitioningSpec.scala | 4 +-
.../cluster/sharding/ClusterShardingSpec.scala | 7 ++-
.../sharding/ExternalShardAllocationSpec.scala | 6 +--
.../sharding/MultiDcClusterShardingSpec.scala | 4 +-
.../sharding/MultiNodeClusterShardingConfig.scala | 4 +-
.../sharding/MultiNodeClusterShardingSpec.scala | 6 +--
.../RollingUpdateShardAllocationSpec.scala | 6 +--
.../sharding/ClusterShardingHealthCheckSpec.scala | 6 +--
.../sharding/ClusterShardingInternalsSpec.scala | 2 +-
.../sharding/ClusterShardingLeaseSpec.scala | 6 +--
.../sharding/ClusterShardingSettingsSpec.scala | 6 +--
.../sharding/ConcurrentStartupShardingSpec.scala | 3 +-
...eprecatedLeastShardAllocationStrategySpec.scala | 4 +-
.../pekko/cluster/sharding/EntitiesSpec.scala | 1 -
.../cluster/sharding/EntityTerminationSpec.scala | 7 ++-
.../JoinConfigCompatCheckShardingSpec.scala | 6 +--
...eastShardAllocationStrategyRandomizedSpec.scala | 4 +-
.../LeastShardAllocationStrategySpec.scala | 4 +-
.../sharding/PersistentShardingMigrationSpec.scala | 9 ++--
.../RememberEntitiesAndStartEntitySpec.scala | 9 ++--
.../RememberEntitiesBatchedUpdatesSpec.scala | 4 +-
.../sharding/RememberEntitiesFailureSpec.scala | 14 +++--
...ememberEntitiesShardIdExtractorChangeSpec.scala | 9 ++--
.../RemoveInternalClusterShardingDataSpec.scala | 2 +-
.../pekko/cluster/sharding/ShardRegionSpec.scala | 8 ++-
.../cluster/sharding/ShardWithLeaseSpec.scala | 12 ++---
.../pekko/cluster/sharding/StartEntitySpec.scala | 6 +--
.../pekko/cluster/sharding/SupervisionSpec.scala | 6 +--
.../internal/RememberEntitiesShardStoreSpec.scala | 6 +--
.../internal/RememberEntitiesStarterSpec.scala | 5 +-
.../sharding/passivation/CompositeSpec.scala | 5 +-
.../passivation/EntityPassivationSpec.scala | 10 ++--
.../HillClimbingAdmissionOptimizerSpec.scala | 1 -
.../cluster/sharding/passivation/IdleSpec.scala | 4 +-
.../passivation/LeastFrequentlyUsedSpec.scala | 5 +-
.../passivation/LeastRecentlyUsedSpec.scala | 5 +-
.../passivation/MostRecentlyUsedSpec.scala | 5 +-
.../passivation/simulator/AccessPattern.scala | 4 +-
.../sharding/passivation/simulator/Simulator.scala | 15 +++---
.../passivation/simulator/SimulatorSettings.scala | 8 ++-
.../passivation/simulator/SimulatorStats.scala | 4 +-
.../ClusterShardingMessageSerializerSpec.scala | 1 -
.../pekko/cluster/client/ClusterClient.scala | 4 +-
.../cluster/pubsub/DistributedPubSubMediator.scala | 4 +-
.../DistributedPubSubMessageSerializer.scala | 2 -
.../singleton/ClusterSingletonManager.scala | 8 ++-
.../cluster/singleton/ClusterSingletonProxy.scala | 4 +-
.../cluster/client/ClusterClientHandoverSpec.scala | 6 +--
.../pekko/cluster/client/ClusterClientSpec.scala | 4 +-
.../cluster/client/ClusterClientStopSpec.scala | 6 +--
.../pubsub/DistributedPubSubMediatorSpec.scala | 4 +-
.../pubsub/DistributedPubSubRestartSpec.scala | 4 +-
.../ClusterSingletonManagerChaosSpec.scala | 4 +-
.../ClusterSingletonManagerDownedSpec.scala | 4 +-
.../ClusterSingletonManagerLeaseSpec.scala | 4 +-
.../ClusterSingletonManagerLeave2Spec.scala | 4 +-
.../ClusterSingletonManagerLeaveSpec.scala | 4 +-
...rSingletonManagerPreparingForShutdownSpec.scala | 5 +-
.../singleton/ClusterSingletonManagerSpec.scala | 4 +-
.../ClusterSingletonManagerStartupSpec.scala | 4 +-
.../singleton/MultiDcSingletonManagerSpec.scala | 4 +-
.../DistributedPubSubMediatorRouterSpec.scala | 7 ++-
.../singleton/ClusterSingletonLeaseSpec.scala | 4 +-
.../ClusterSingletonLeavingSpeedSpec.scala | 4 +-
.../singleton/ClusterSingletonProxySpec.scala | 11 ++--
.../singleton/ClusterSingletonRestart2Spec.scala | 4 +-
.../singleton/ClusterSingletonRestartSpec.scala | 4 +-
.../ddata/typed/internal/ReplicatorBehavior.scala | 2 +-
.../ddata/typed/javadsl/DistributedData.scala | 3 +-
.../cluster/ddata/typed/javadsl/Replicator.scala | 3 +-
.../typed/javadsl/ReplicatorMessageAdapter.scala | 5 +-
.../ddata/typed/javadsl/ReplicatorSettings.scala | 4 +-
.../ddata/typed/scaladsl/DistributedData.scala | 6 +--
.../ddata/typed/scaladsl/ReplicatorSettings.scala | 4 +-
.../pekko/cluster/typed/ClusterSingleton.scala | 3 +-
.../typed/internal/AdaptedClusterImpl.scala | 2 +-
.../delivery/ReliableDeliverySerializer.scala | 5 +-
.../ClusterReceptionistConfigCompatChecker.scala | 4 +-
.../receptionist/ClusterReceptionistSettings.scala | 4 +-
.../cluster/typed/ChunkLargeMessageSpec.scala | 3 +-
.../typed/MultiDcClusterSingletonSpec.scala | 4 +-
.../cluster/typed/MultiNodeTypedClusterSpec.scala | 12 ++---
.../apache/pekko/cluster/typed/PubSubSpec.scala | 4 +-
.../ClusterReceptionistUnreachabilitySpec.scala | 4 +-
.../ddata/typed/scaladsl/ReplicatorSpec.scala | 4 +-
.../typed/ActorRefIgnoreSerializationSpec.scala | 13 +++--
.../pekko/cluster/typed/ActorSystemSpec.scala | 17 +++----
.../cluster/typed/ClusterActorLoggingSpec.scala | 9 ++--
.../pekko/cluster/typed/ClusterApiSpec.scala | 7 ++-
.../typed/ClusterDispatcherSelectorSpec.scala | 4 +-
.../cluster/typed/ClusterSingletonApiSpec.scala | 7 ++-
.../typed/ClusterSingletonPoisonPillSpec.scala | 4 +-
.../pekko/cluster/typed/GroupRouterSpec.scala | 6 +--
.../pekko/cluster/typed/RemoteContextAskSpec.scala | 7 ++-
.../cluster/typed/RemoteDeployNotAllowedSpec.scala | 7 ++-
.../pekko/cluster/typed/RemoteMessageSpec.scala | 4 +-
.../internal/PekkoClusterTypedSerializerSpec.scala | 4 +-
.../delivery/ReliableDeliverySerializerSpec.scala | 4 +-
.../receptionist/ClusterReceptionistSpec.scala | 10 ++--
.../ClusterReceptionistStateSpec.scala | 6 +--
.../scala/org/apache/pekko/cluster/Cluster.scala | 4 +-
.../pekko/cluster/ClusterActorRefProvider.scala | 5 +-
.../org/apache/pekko/cluster/ClusterDaemon.scala | 4 +-
.../pekko/cluster/ClusterRemoteWatcher.scala | 1 -
.../org/apache/pekko/cluster/ClusterSettings.scala | 6 +--
.../org/apache/pekko/cluster/ConfigUtil.scala | 4 +-
.../scala/org/apache/pekko/cluster/Gossip.scala | 1 -
.../cluster/JoinConfigCompatCheckCluster.scala | 4 +-
.../pekko/cluster/JoinConfigCompatChecker.scala | 4 +-
.../scala/org/apache/pekko/cluster/Member.scala | 3 +-
.../protobuf/ClusterMessageSerializer.scala | 5 +-
.../cluster/routing/ClusterRouterConfig.scala | 7 +--
.../apache/pekko/cluster/sbr/DowningStrategy.scala | 1 -
.../pekko/cluster/sbr/SplitBrainResolver.scala | 2 +-
.../cluster/sbr/SplitBrainResolverSettings.scala | 4 +-
.../ClusterAccrualFailureDetectorSpec.scala | 4 +-
.../pekko/cluster/ClusterDeathWatchSpec.scala | 7 ++-
.../apache/pekko/cluster/ClusterShutdownSpec.scala | 5 +-
.../ClusterWatcherNoClusterWatcheeSpec.scala | 7 ++-
.../org/apache/pekko/cluster/ConvergenceSpec.scala | 4 +-
.../DeterministicOldestWhenJoiningSpec.scala | 4 +-
...henOtherHasQuarantinedThisActorSystemSpec.scala | 2 -
.../pekko/cluster/InitialHeartbeatSpec.scala | 4 +-
.../pekko/cluster/InitialMembersOfNewDcSpec.scala | 4 +-
.../apache/pekko/cluster/JoinInProgressSpec.scala | 4 +-
.../apache/pekko/cluster/JoinSeedNodeSpec.scala | 4 +-
.../pekko/cluster/LargeMessageClusterSpec.scala | 3 +-
.../cluster/LeaderDowningAllOtherNodesSpec.scala | 4 +-
.../LeaderDowningNodeThatIsUnreachableSpec.scala | 4 +-
.../apache/pekko/cluster/LeaderLeavingSpec.scala | 4 +-
.../scala/org/apache/pekko/cluster/MBeanSpec.scala | 8 +--
.../apache/pekko/cluster/MemberWeaklyUpSpec.scala | 4 +-
.../pekko/cluster/MinMembersBeforeUpSpec.scala | 4 +-
.../apache/pekko/cluster/MultiDcClusterSpec.scala | 4 +-
.../cluster/MultiDcHeartbeatTakingOverSpec.scala | 4 +-
.../apache/pekko/cluster/MultiDcJoin2Spec.scala | 4 +-
.../org/apache/pekko/cluster/MultiDcJoinSpec.scala | 4 +-
.../apache/pekko/cluster/MultiDcLastNodeSpec.scala | 4 +-
.../pekko/cluster/MultiDcSplitBrainSpec.scala | 4 +-
.../pekko/cluster/MultiDcSunnyWeatherSpec.scala | 4 +-
.../pekko/cluster/MultiNodeClusterSpec.scala | 11 ++--
.../org/apache/pekko/cluster/NodeChurnSpec.scala | 4 +-
.../cluster/NodeDowningAndBeingRemovedSpec.scala | 4 +-
.../apache/pekko/cluster/QuickRestartSpec.scala | 4 +-
.../cluster/RemoteFeaturesWithClusterSpec.scala | 7 ++-
.../pekko/cluster/RestartFirstSeedNodeSpec.scala | 4 +-
.../apache/pekko/cluster/RestartNode2Spec.scala | 4 +-
.../apache/pekko/cluster/RestartNode3Spec.scala | 4 +-
.../org/apache/pekko/cluster/RestartNodeSpec.scala | 4 +-
.../pekko/cluster/SharedMediaDriverSupport.scala | 3 +-
.../pekko/cluster/SingletonClusterSpec.scala | 4 +-
.../pekko/cluster/SplitBrainQuarantineSpec.scala | 5 +-
.../org/apache/pekko/cluster/SplitBrainSpec.scala | 4 +-
.../org/apache/pekko/cluster/StreamRefSpec.scala | 6 +--
.../org/apache/pekko/cluster/StressSpec.scala | 11 ++--
.../apache/pekko/cluster/SunnyWeatherSpec.scala | 4 +-
.../cluster/SurviveNetworkInstabilitySpec.scala | 6 +--
.../org/apache/pekko/cluster/TransitionSpec.scala | 3 +-
.../cluster/UnreachableNodeJoinsAgainSpec.scala | 4 +-
.../ClusterConsistentHashingRouterSpec.scala | 4 +-
.../cluster/routing/ClusterRoundRobinSpec.scala | 4 +-
.../pekko/cluster/routing/UseRoleIgnoredSpec.scala | 4 +-
.../sbr/DownAllIndirectlyConnected5NodeSpec.scala | 4 +-
.../cluster/sbr/DownAllUnstable5NodeSpec.scala | 4 +-
.../cluster/sbr/IndirectlyConnected3NodeSpec.scala | 4 +-
.../cluster/sbr/IndirectlyConnected5NodeSpec.scala | 4 +-
.../pekko/cluster/sbr/LeaseMajority5NodeSpec.scala | 8 +--
.../apache/pekko/cluster/ClusterConfigSpec.scala | 6 +--
.../ClusterDeathWatchNotificationSpec.scala | 6 +--
.../apache/pekko/cluster/ClusterDeployerSpec.scala | 4 +-
.../cluster/ClusterDomainEventPublisherSpec.scala | 6 +--
.../pekko/cluster/ClusterDomainEventSpec.scala | 6 +--
.../cluster/ClusterHeartbeatSenderStateSpec.scala | 6 +--
.../org/apache/pekko/cluster/ClusterLogSpec.scala | 4 +-
.../org/apache/pekko/cluster/ClusterSpec.scala | 8 +--
.../org/apache/pekko/cluster/ClusterTestKit.scala | 4 +-
.../org/apache/pekko/cluster/ConfigUtilSpec.scala | 4 +-
.../pekko/cluster/CrossDcHeartbeatSenderSpec.scala | 2 +-
.../apache/pekko/cluster/DowningProviderSpec.scala | 11 ++--
.../pekko/cluster/FailureDetectorPuppet.scala | 4 +-
.../org/apache/pekko/cluster/GossipSpec.scala | 6 +--
.../pekko/cluster/GossipTargetSelectorSpec.scala | 6 +--
.../pekko/cluster/HeartbeatNodeRingPerfSpec.scala | 4 +-
.../pekko/cluster/HeartbeatNodeRingSpec.scala | 4 +-
.../cluster/JoinConfigCompatCheckClusterSpec.scala | 6 +--
.../JoinConfigCompatCheckerRollingUpdateSpec.scala | 4 +-
.../cluster/JoinConfigCompatCheckerSpec.scala | 4 +-
.../JoinConfigCompatPreDefinedChecksSpec.scala | 3 +-
.../apache/pekko/cluster/MemberOrderingSpec.scala | 6 +--
.../apache/pekko/cluster/MembershipStateSpec.scala | 6 +--
.../pekko/cluster/MixedProtocolClusterSpec.scala | 4 +-
.../pekko/cluster/ReachabilityPerfSpec.scala | 5 +-
.../apache/pekko/cluster/ReachabilitySpec.scala | 4 +-
.../pekko/cluster/StartupWithOneThreadSpec.scala | 2 +-
.../protobuf/ClusterMessageSerializerSpec.scala | 7 ++-
.../pekko/cluster/sbr/LeaseMajoritySpec.scala | 4 +-
.../pekko/cluster/sbr/SplitBrainResolverSpec.scala | 11 ++--
.../coordination/lease/LeaseUsageSettings.scala | 2 +-
.../pekko/coordination/lease/TimeoutSettings.scala | 3 +-
.../pekko/coordination/lease/TestLease.scala | 4 +-
.../coordination/lease/TimeoutSettingsSpec.scala | 3 +-
.../lease/scaladsl/LeaseProviderSpec.scala | 4 +-
.../aggregate/AggregateServiceDiscovery.scala | 4 +-
.../discovery/config/ConfigServiceDiscovery.scala | 4 +-
.../discovery/DiscoveryConfigurationSpec.scala | 9 ++--
.../aggregate/AggregateServiceDiscoverySpec.scala | 13 +++--
.../config/ConfigServiceDiscoverySpec.scala | 11 ++--
.../config/ConfigServicesParserSpec.scala | 9 ++--
.../pekko/discovery/dns/DnsDiscoverySpec.scala | 4 +-
.../discovery/dns/DnsServiceDiscoverySpec.scala | 8 +--
.../apache/pekko/cluster/ddata/DurableStore.scala | 3 +-
.../apache/pekko/cluster/ddata/Replicator.scala | 8 +--
.../ddata/protobuf/ReplicatedDataSerializer.scala | 4 +-
.../protobuf/ReplicatorMessageSerializer.scala | 2 -
.../ddata/protobuf/SerializationSupport.scala | 2 -
.../pekko/cluster/ddata/DurableDataSpec.scala | 7 ++-
.../pekko/cluster/ddata/DurablePruningSpec.scala | 4 +-
.../cluster/ddata/JepsenInspiredInsertSpec.scala | 4 +-
.../pekko/cluster/ddata/PerformanceSpec.scala | 4 +-
.../pekko/cluster/ddata/ReplicatorChaosSpec.scala | 4 +-
.../pekko/cluster/ddata/ReplicatorDeltaSpec.scala | 4 +-
.../pekko/cluster/ddata/ReplicatorGossipSpec.scala | 4 +-
.../cluster/ddata/ReplicatorMapDeltaSpec.scala | 4 +-
.../cluster/ddata/ReplicatorORSetDeltaSpec.scala | 4 +-
.../cluster/ddata/ReplicatorPruningSpec.scala | 4 +-
.../pekko/cluster/ddata/ReplicatorSpec.scala | 4 +-
.../pekko/cluster/ddata/STMultiNodeSpec.scala | 4 +-
.../pekko/cluster/ddata/DataEnvelopeSpec.scala | 6 +--
.../ddata/DeltaPropagationSelectorSpec.scala | 5 +-
.../org/apache/pekko/cluster/ddata/FlagSpec.scala | 4 +-
.../apache/pekko/cluster/ddata/GCounterSpec.scala | 6 +--
.../org/apache/pekko/cluster/ddata/GSetSpec.scala | 4 +-
.../apache/pekko/cluster/ddata/LWWMapSpec.scala | 6 +--
.../pekko/cluster/ddata/LWWRegisterSpec.scala | 6 +--
.../pekko/cluster/ddata/LocalConcurrencySpec.scala | 11 ++--
.../apache/pekko/cluster/ddata/LotsOfDataBot.scala | 4 +-
.../org/apache/pekko/cluster/ddata/ORMapSpec.scala | 6 +--
.../pekko/cluster/ddata/ORMultiMapSpec.scala | 6 +--
.../org/apache/pekko/cluster/ddata/ORSetSpec.scala | 6 +--
.../pekko/cluster/ddata/PNCounterMapSpec.scala | 6 +--
.../apache/pekko/cluster/ddata/PNCounterSpec.scala | 6 +--
.../pekko/cluster/ddata/PruningStateSpec.scala | 6 +--
.../cluster/ddata/ReplicatorSettingsSpec.scala | 5 +-
.../pekko/cluster/ddata/VersionVectorSpec.scala | 8 +--
.../protobuf/ReplicatedDataSerializerSpec.scala | 11 ++--
.../protobuf/ReplicatorMessageSerializerSpec.scala | 11 ++--
.../pekko/remote/testconductor/Conductor.scala | 5 +-
.../pekko/remote/testconductor/DataTypes.scala | 6 +--
.../pekko/remote/testconductor/Extension.scala | 4 +-
.../apache/pekko/remote/testconductor/Player.scala | 6 +--
.../remote/testconductor/RemoteConnection.scala | 8 +--
.../pekko/remote/testkit/MultiNodeSpec.scala | 7 +--
.../apache/pekko/osgi/ActorSystemActivator.scala | 3 +-
.../apache/pekko/osgi/OsgiActorSystemFactory.scala | 3 +-
.../pekko/osgi/ActorSystemActivatorTest.scala | 5 +-
.../org/apache/pekko/osgi/PojoSRTestSupport.scala | 3 +-
.../pekko/persistence/query/EventEnvelope.scala | 1 -
.../pekko/persistence/query/PersistenceQuery.scala | 4 +-
.../query/internal/QuerySerializer.scala | 2 -
.../query/javadsl/DurableStateStoreQuery.scala | 2 +-
.../leveldb/EventsByPersistenceIdStage.scala | 1 -
.../query/journal/leveldb/EventsByTagStage.scala | 1 -
.../leveldb/LeveldbReadJournalProvider.scala | 3 +-
.../leveldb/scaladsl/LeveldbReadJournal.scala | 4 +-
.../query/scaladsl/DurableStateStoreQuery.scala | 2 +-
.../pekko/persistence/query/DummyReadJournal.scala | 4 +-
.../persistence/query/PersistenceQuerySpec.scala | 9 ++--
.../journal/leveldb/AllPersistenceIdsSpec.scala | 6 +--
.../leveldb/EventsByPersistenceIdSpec.scala | 6 +--
.../query/journal/leveldb/EventsByTagSpec.scala | 6 +--
.../leveldb/PersistencePluginProxySpec.scala | 4 +-
.../journal/leveldb/SharedLeveldbJournalSpec.scala | 4 +-
.../persistence/serialization/SerializerSpec.scala | 3 +-
.../org/apache/pekko/persistence/PluginSpec.scala | 9 ++--
.../apache/pekko/persistence/TestSerializer.scala | 4 +-
.../japi/journal/JavaJournalPerfSpec.scala | 6 +--
.../persistence/japi/journal/JavaJournalSpec.scala | 4 +-
.../japi/snapshot/JavaSnapshotStoreSpec.scala | 4 +-
.../persistence/journal/JournalPerfSpec.scala | 6 +--
.../pekko/persistence/journal/JournalSpec.scala | 4 +-
.../pekko/persistence/scalatest/MayVerb.scala | 1 -
.../persistence/scalatest/OptionalTests.scala | 4 +-
.../persistence/snapshot/SnapshotStoreSpec.scala | 6 +--
.../apache/pekko/persistence/PluginCleanup.scala | 1 -
.../persistence/japi/JavaJournalSpecSpec.scala | 5 +-
.../snapshot/local/LocalSnapshotStoreSpec.scala | 4 +-
.../pekko/persistence/testkit/EventStorage.scala | 4 +-
.../testkit/PersistenceTestKitPlugin.scala | 10 ++--
.../persistence/testkit/ProcessingPolicy.scala | 4 +-
.../persistence/testkit/SnapshotStorage.scala | 4 +-
.../internal/EventSourcedBehaviorTestKitImpl.scala | 1 -
.../testkit/internal/InMemStorageExtension.scala | 2 +-
.../SnapshotStorageEmulatorExtension.scala | 2 +-
.../testkit/internal/TestKitStorage.scala | 4 +-
.../javadsl/EventSourcedBehaviorTestKit.scala | 7 ++-
.../testkit/javadsl/PersistenceInit.scala | 3 +-
.../testkit/javadsl/PersistenceTestKit.scala | 3 +-
.../testkit/javadsl/SnapshotTestKit.scala | 3 +-
.../PersistenceTestKitReadJournalProvider.scala | 1 -
.../query/internal/EventsBySliceStage.scala | 8 +--
.../testkit/query/internal/EventsByTagStage.scala | 6 +--
.../scaladsl/PersistenceTestKitReadJournal.scala | 24 ++++-----
.../scaladsl/EventSourcedBehaviorTestKit.scala | 6 +--
.../testkit/scaladsl/PersistenceTestKit.scala | 4 +-
...rsistenceTestKitDurableStateStoreProvider.scala | 4 +-
.../PersistenceTestKitDurableStateStore.scala | 3 +-
.../PersistenceTestKitDurableStateStore.scala | 4 +-
.../pekko/persistence/testkit/CommonUtils.scala | 7 ++-
.../testkit/javadsl/CommonSnapshotTests.scala | 4 +-
.../testkit/javadsl/CommonTestKitTests.scala | 4 +-
.../testkit/query/CurrentEventsBySlicesSpec.scala | 4 +-
.../testkit/query/CurrentEventsByTagSpec.scala | 1 -
.../testkit/query/EventsByPersistenceIdSpec.scala | 6 +--
.../testkit/query/EventsBySliceSpec.scala | 10 ++--
.../testkit/query/EventsByTagSpec.scala | 10 ++--
.../testkit/scaladsl/CommonSnapshotTests.scala | 4 +-
.../testkit/scaladsl/CommonTestKitTests.scala | 4 +-
...EventSourcedBehaviorNoSnapshotTestKitSpec.scala | 4 +-
.../scaladsl/EventSourcedBehaviorTestKitSpec.scala | 4 +-
.../testkit/scaladsl/MultipleJournalsSpec.scala | 4 +-
.../testkit/scaladsl/RuntimeJournalsSpec.scala | 4 +-
.../PersistenceTestKitDurableStateStoreSpec.scala | 3 +-
.../persistence/typed/EventPublishingSpec.scala | 1 -
.../typed/EventSourcedBehaviorLoggingSpec.scala | 7 ++-
.../typed/MultiJournalReplicationSpec.scala | 8 ++-
.../typed/ReplicatedEventPublishingSpec.scala | 3 +-
.../typed/ReplicatedEventSourcingSpec.scala | 1 -
.../typed/ReplicatedEventSourcingTaggingSpec.scala | 5 +-
.../persistence/typed/ReplicationBaseSpec.scala | 1 -
.../typed/ReplicationIllegalAccessSpec.scala | 1 -
.../typed/ReplicationSnapshotSpec.scala | 3 +-
.../pekko/persistence/typed/crdt/CounterSpec.scala | 2 +-
.../pekko/persistence/typed/crdt/LwwSpec.scala | 10 ++--
.../pekko/persistence/typed/crdt/ORSetSpec.scala | 9 ++--
.../ReplicatedEventSourcingJacksonSpec.scala | 4 +-
.../scaladsl/EventSourcedBehaviorFailureSpec.scala | 14 +++--
.../EventSourcedBehaviorInterceptorSpec.scala | 8 ++-
.../EventSourcedBehaviorRecoveryTimeoutSpec.scala | 11 ++--
.../scaladsl/EventSourcedBehaviorReplySpec.scala | 5 +-
.../EventSourcedBehaviorRetentionSpec.scala | 12 ++---
.../scaladsl/EventSourcedBehaviorSignalSpec.scala | 14 +++--
.../typed/scaladsl/EventSourcedBehaviorSpec.scala | 27 +++++-----
.../scaladsl/EventSourcedBehaviorStashSpec.scala | 15 +++---
.../scaladsl/EventSourcedBehaviorTimersSpec.scala | 8 ++-
.../scaladsl/EventSourcedBehaviorWatchSpec.scala | 16 +++---
.../scaladsl/EventSourcedEventAdapterSpec.scala | 6 +--
.../scaladsl/EventSourcedSequenceNumberSpec.scala | 6 +--
.../scaladsl/EventSourcedSnapshotAdapterSpec.scala | 6 +--
.../scaladsl/EventSourcedStashOverflowSpec.scala | 6 +--
.../typed/scaladsl/LoggerSourceSpec.scala | 6 +--
.../typed/scaladsl/NullEmptyStateSpec.scala | 4 +-
.../typed/scaladsl/OptionalSnapshotStoreSpec.scala | 5 +-
.../typed/scaladsl/PerformanceSpec.scala | 9 ++--
.../typed/scaladsl/PrimitiveStateSpec.scala | 4 +-
.../typed/scaladsl/SlowInMemorySnapshotStore.scala | 8 +--
.../typed/scaladsl/SnapshotMutableStateSpec.scala | 8 ++-
.../SnapshotRecoveryWithEmptyJournalSpec.scala | 13 ++---
.../DurableStateBehaviorInterceptorSpec.scala | 10 ++--
.../scaladsl/DurableStateBehaviorReplySpec.scala | 10 ++--
.../DurableStateBehaviorStashOverflowSpec.scala | 10 ++--
.../scaladsl/DurableStateBehaviorTimersSpec.scala | 12 ++---
.../state/scaladsl/DurableStateRevisionSpec.scala | 9 ++--
.../typed/state/scaladsl/NullEmptyStateSpec.scala | 7 ++-
.../typed/state/scaladsl/PrimitiveStateSpec.scala | 7 ++-
.../pekko/persistence/typed/crdt/ORSet.scala | 3 +-
.../typed/delivery/EventSourcedProducerQueue.scala | 6 +--
.../persistence/typed/internal/BehaviorSetup.scala | 10 ++--
.../typed/internal/EventSourcedBehaviorImpl.scala | 6 +--
.../typed/internal/EventSourcedSettings.scala | 4 +-
.../typed/internal/ExternalInteractions.scala | 1 -
.../typed/internal/ReplayingEvents.scala | 4 +-
.../typed/internal/ReplayingSnapshot.scala | 2 +-
.../pekko/persistence/typed/internal/Running.scala | 14 +++--
.../persistence/typed/internal/VersionVector.scala | 1 -
.../persistence/typed/javadsl/EventHandler.scala | 2 +-
.../typed/javadsl/EventSourcedBehavior.scala | 3 +-
.../typed/javadsl/PersistentFSMMigration.scala | 3 +-
.../typed/javadsl/ReplicatedEventSourcing.scala | 4 +-
.../typed/scaladsl/EventSourcedBehavior.scala | 5 +-
.../ReplicatedEventSourcingSerializer.scala | 12 ++---
.../typed/state/internal/BehaviorSetup.scala | 12 ++---
.../state/internal/DurableStateBehaviorImpl.scala | 6 +--
.../state/internal/DurableStateSettings.scala | 6 +--
.../typed/state/javadsl/CommandHandler.scala | 4 +-
.../state/javadsl/CommandHandlerWithReply.scala | 4 +-
.../typed/state/javadsl/DurableStateBehavior.scala | 4 +-
.../persistence/typed/state/javadsl/Effect.scala | 2 +-
.../state/scaladsl/DurableStateBehavior.scala | 2 +-
.../persistence/typed/state/scaladsl/Effect.scala | 2 +-
.../typed/ClusterSingletonPersistenceSpec.scala | 7 ++-
.../persistence/typed/ManyRecoveriesSpec.scala | 4 +-
.../persistence/typed/PersistenceIdSpec.scala | 4 +-
.../ReplicatedEventSourcingSerializationSpec.scala | 1 -
.../typed/StashingWhenSnapshottingSpec.scala | 7 ++-
.../delivery/EventSourcedProducerQueueSpec.scala | 9 ++--
...DeliveryWithEventSourcedProducerQueueSpec.scala | 9 ++--
...kPullingWithEventSourcedProducerQueueSpec.scala | 10 ++--
.../typed/internal/RecoveryPermitterSpec.scala | 4 +-
.../typed/internal/RetentionCriteriaSpec.scala | 8 +--
.../typed/internal/StashStateSpec.scala | 4 +-
.../scaladsl/PersistentActorCompileOnlyTest.scala | 10 ++--
.../typed/scaladsl/SnapshotIsOptionalSpec.scala | 8 ++-
.../ReplicatedEventSourcingSerializerSpec.scala | 1 -
.../apache/pekko/persistence/Eventsourced.scala | 6 +--
.../org/apache/pekko/persistence/Persistence.scala | 4 +-
.../pekko/persistence/PersistencePlugin.scala | 4 +-
.../apache/pekko/persistence/PersistentActor.scala | 6 +--
.../pekko/persistence/fsm/PersistentFSM.scala | 6 +--
.../pekko/persistence/fsm/PersistentFSMBase.scala | 4 +-
.../pekko/persistence/journal/EventAdapters.scala | 4 +-
.../journal/PersistencePluginProxy.scala | 4 +-
.../persistence/journal/inmem/InmemJournal.scala | 13 +++--
.../persistence/journal/japi/AsyncRecovery.scala | 6 +--
.../journal/japi/AsyncWriteJournal.scala | 6 +--
.../journal/leveldb/LeveldbJournal.scala | 6 +--
.../persistence/journal/leveldb/LeveldbStore.scala | 3 +-
.../journal/leveldb/SharedLeveldbStore.scala | 4 +-
.../serialization/MessageSerializer.scala | 4 +-
.../persistence/snapshot/japi/SnapshotStore.scala | 10 ++--
.../snapshot/local/LocalSnapshotStore.scala | 4 +-
.../state/DurableStateStoreRegistry.scala | 4 +-
.../AtLeastOnceDeliveryFailureSpec.scala | 4 +-
.../persistence/EndToEndEventAdapterSpec.scala | 10 ++--
.../pekko/persistence/EventAdapterSpec.scala | 4 +-
.../apache/pekko/persistence/LoadPluginSpec.scala | 4 +-
.../pekko/persistence/ManyRecoveriesSpec.scala | 4 +-
.../persistence/OptionalSnapshotStoreSpec.scala | 4 +-
.../apache/pekko/persistence/PerformanceSpec.scala | 4 +-
.../apache/pekko/persistence/PersistenceSpec.scala | 8 ++-
.../PersistentActorBoundedStashingSpec.scala | 7 ++-
.../PersistentActorJournalProtocolSpec.scala | 4 +-
.../PersistentActorRecoveryTimeoutSpec.scala | 4 +-
.../pekko/persistence/PersistentActorSpec.scala | 6 +--
.../persistence/PersistentActorStashingSpec.scala | 4 +-
.../pekko/persistence/RecoveryPermitterSpec.scala | 4 +-
.../SnapshotFailureRobustnessSpec.scala | 4 +-
.../persistence/TimerPersistentActorSpec.scala | 4 +-
.../pekko/persistence/fsm/PersistentFSMSpec.scala | 5 +-
.../AsyncWriteJournalResponseOrderSpec.scala | 6 +--
.../journal/InmemEventAdaptersSpec.scala | 5 +-
.../persistence/journal/SteppingInmemJournal.scala | 4 +-
.../journal/leveldb/JournalCompactionSpec.scala | 3 +-
.../SnapshotSerializerMigrationAkkaSpec.scala | 7 ++-
.../SnapshotSerializerNoMigrationSpec.scala | 6 +--
.../serialization/SnapshotSerializerSpec.scala | 4 +-
.../exception/DurableStateExceptionsSpec.scala | 2 +-
.../apache/pekko/pki/pem/DERPrivateKeyLoader.scala | 7 ++-
.../src/main/resources/plugin.properties | 1 -
.../src/main/scala/org/apache/pekko/Plugin.scala | 51 -------------------
project/CopyrightHeader.scala | 2 +-
project/CopyrightHeaderForBoilerplate.scala | 2 +-
project/CopyrightHeaderForBuild.scala | 2 +-
project/CopyrightHeaderForJdk9.scala | 2 +-
project/CopyrightHeaderForProtobuf.scala | 2 +-
project/Dependencies.scala | 26 ++--------
project/MultiNode.scala | 2 +-
project/OSGi.scala | 8 +--
project/PekkoDisciplinePlugin.scala | 2 +-
project/plugins.sbt | 4 +-
project/project-info.conf | 2 +-
.../pekko/remote/AttemptSysMsgRedeliverySpec.scala | 3 +-
.../pekko/remote/LookupRemoteActorSpec.scala | 3 +-
.../apache/pekko/remote/NewRemoteActorSpec.scala | 3 +-
.../remote/PiercingShouldKeepQuarantineSpec.scala | 4 +-
.../apache/pekko/remote/RemoteDeliverySpec.scala | 4 +-
.../remote/RemoteDeploymentDeathWatchSpec.scala | 4 +-
.../apache/pekko/remote/RemoteFeaturesSpec.scala | 4 +-
.../pekko/remote/RemoteNodeDeathWatchSpec.scala | 4 +-
.../remote/RemoteNodeRestartDeathWatchSpec.scala | 4 +-
.../remote/RemoteQuarantinePiercingSpec.scala | 4 +-
.../pekko/remote/RemoteReDeploymentSpec.scala | 4 +-
.../pekko/remote/RemotingMultiNodeSpec.scala | 7 ++-
.../apache/pekko/remote/TransportFailSpec.scala | 8 +--
.../pekko/remote/artery/DirectMemorySpec.scala | 4 +-
.../pekko/remote/artery/FanInThrougputSpec.scala | 4 +-
.../pekko/remote/artery/FanOutThrougputSpec.scala | 4 +-
.../artery/HandshakeRestartReceiverSpec.scala | 4 +-
.../apache/pekko/remote/artery/LatencySpec.scala | 3 +-
.../pekko/remote/artery/MaxThroughputSpec.scala | 3 +-
.../artery/RemoteRestartedQuarantinedSpec.scala | 4 +-
...dStreamRestartWithCompressionInFlightSpec.scala | 7 ++-
.../artery/SurviveNetworkPartitionSpec.scala | 6 +--
.../apache/pekko/remote/artery/TestMessage.scala | 4 +-
.../artery/aeron/AeronStreamConcistencySpec.scala | 3 +-
.../artery/aeron/AeronStreamLatencySpec.scala | 3 +-
.../aeron/AeronStreamMaxThroughputSpec.scala | 3 +-
.../remote/classic/RemoteGatePiercingSpec.scala | 6 +--
.../remote/classic/RemoteNodeRestartGateSpec.scala | 6 +--
.../RemoteNodeShutdownAndComesBackSpec.scala | 4 +-
.../pekko/remote/classic/Ticket15109Spec.scala | 6 +--
.../pekko/remote/routing/RemoteRandomSpec.scala | 4 +-
.../remote/routing/RemoteRoundRobinSpec.scala | 4 +-
.../remote/routing/RemoteScatterGatherSpec.scala | 4 +-
.../remote/testconductor/TestConductorSpec.scala | 4 +-
.../remote/artery/ArteryFailedToBindSpec.scala | 9 ++--
.../remote/classic/RemotingFailedToBindSpec.scala | 10 ++--
.../remote/testconductor/ControllerSpec.scala | 2 +-
.../org/apache/pekko/remote/ByteStringUtils.scala | 2 +-
.../pekko/remote/DeadlineFailureDetector.scala | 4 +-
.../scala/org/apache/pekko/remote/Endpoint.scala | 5 +-
.../pekko/remote/FailureDetectorRegistry.scala | 4 +-
.../apache/pekko/remote/MessageSerializer.scala | 1 -
.../pekko/remote/PhiAccrualFailureDetector.scala | 5 +-
.../pekko/remote/RemoteActorRefProvider.scala | 3 +-
.../org/apache/pekko/remote/RemoteDeployer.scala | 4 +-
.../pekko/remote/RemoteMetricsExtension.scala | 3 +-
.../org/apache/pekko/remote/RemoteSettings.scala | 6 +--
.../org/apache/pekko/remote/RemoteTransport.scala | 2 +-
.../org/apache/pekko/remote/RemoteWatcher.scala | 3 +-
.../scala/org/apache/pekko/remote/Remoting.scala | 8 +--
.../pekko/remote/artery/ArterySettings.scala | 10 ++--
.../pekko/remote/artery/ArteryTransport.scala | 3 +-
.../apache/pekko/remote/artery/Association.scala | 2 +-
.../org/apache/pekko/remote/artery/Codecs.scala | 4 +-
.../pekko/remote/artery/EnvelopeBufferPool.scala | 2 -
.../pekko/remote/artery/FlushOnShutdown.scala | 1 -
.../org/apache/pekko/remote/artery/Handshake.scala | 4 +-
.../pekko/remote/artery/RemoteInstrument.scala | 4 +-
.../remote/artery/SystemMessageDelivery.scala | 4 +-
.../org/apache/pekko/remote/artery/TestStage.scala | 2 -
.../remote/artery/tcp/ArteryTcpTransport.scala | 3 +-
.../artery/tcp/ConfigSSLEngineProvider.scala | 19 ++++---
.../remote/artery/tcp/SSLEngineProvider.scala | 5 +-
.../remote/artery/tcp/SecureRandomFactory.scala | 1 -
.../artery/tcp/ssl/PemManagersProvider.scala | 7 +--
.../tcp/ssl/RotatingKeysSSLEngineProvider.scala | 15 +++---
.../remote/artery/tcp/ssl/SSLEngineConfig.scala | 7 ++-
.../remote/artery/tcp/ssl/SessionVerifier.scala | 2 +-
.../pekko/remote/artery/tcp/ssl/X509Readers.scala | 2 +-
.../pekko/remote/routing/RemoteRouterConfig.scala | 3 +-
.../serialization/ArteryMessageSerializer.scala | 4 +-
.../serialization/DaemonMsgCreateSerializer.scala | 4 +-
.../serialization/MessageContainerSerializer.scala | 1 -
.../serialization/MiscMessageSerializer.scala | 4 +-
.../serialization/WrappedPayloadSupport.scala | 6 +--
.../FailureInjectorTransportAdapter.scala | 2 +-
.../pekko/remote/transport/PekkoPduCodec.scala | 1 -
.../remote/transport/PekkoProtocolTransport.scala | 8 +--
.../pekko/remote/transport/TestTransport.scala | 4 +-
.../transport/ThrottlerTransportAdapter.scala | 9 ++--
.../apache/pekko/remote/transport/Transport.scala | 3 +-
.../remote/transport/netty/NettySSLSupport.scala | 3 +-
.../remote/transport/netty/NettyTransport.scala | 7 ++-
.../pekko/remote/AccrualFailureDetectorSpec.scala | 3 +-
.../apache/pekko/remote/AckedDeliverySpec.scala | 3 +-
.../org/apache/pekko/remote/DaemonicSpec.scala | 4 +-
.../apache/pekko/remote/MessageLoggingSpec.scala | 5 +-
.../apache/pekko/remote/NetworkFailureSpec.scala | 2 +-
.../pekko/remote/RemoteActorMailboxSpec.scala | 4 +-
.../org/apache/pekko/remote/RemoteConfigSpec.scala | 6 +--
.../apache/pekko/remote/RemoteDeployerSpec.scala | 4 +-
.../apache/pekko/remote/RemoteFeaturesSpec.scala | 8 +--
.../org/apache/pekko/remote/RemoteRouterSpec.scala | 4 +-
.../pekko/remote/Ticket1978CommunicationSpec.scala | 6 +--
.../remote/TransientSerializationErrorSpec.scala | 4 +-
.../ActorRefResolveCacheQuarantineSpec.scala | 4 +-
.../pekko/remote/artery/ArteryMultiNodeSpec.scala | 7 ++-
.../remote/artery/BindCanonicalAddressSpec.scala | 9 ++--
.../pekko/remote/artery/DuplicateFlushSpec.scala | 2 +-
.../remote/artery/DuplicateHandshakeSpec.scala | 2 +-
.../pekko/remote/artery/EnvelopeBufferSpec.scala | 1 -
.../pekko/remote/artery/HandshakeDenySpec.scala | 4 +-
.../pekko/remote/artery/HandshakeFailureSpec.scala | 4 +-
.../pekko/remote/artery/HandshakeRetrySpec.scala | 4 +-
.../remote/artery/HarmlessQuarantineSpec.scala | 6 +--
.../pekko/remote/artery/ImmutableLongMapSpec.scala | 4 +-
.../remote/artery/InboundControlJunctionSpec.scala | 2 +-
.../pekko/remote/artery/InboundHandshakeSpec.scala | 2 +-
.../pekko/remote/artery/LateConnectSpec.scala | 4 +-
.../pekko/remote/artery/LruBoundedCacheSpec.scala | 3 +-
.../artery/OutboundControlJunctionSpec.scala | 2 +-
.../remote/artery/OutboundHandshakeSpec.scala | 2 +-
.../remote/artery/OutboundIdleShutdownSpec.scala | 6 +--
.../pekko/remote/artery/RemoteDeathWatchSpec.scala | 6 +--
.../pekko/remote/artery/RemoteDeployerSpec.scala | 4 +-
.../pekko/remote/artery/RemoteDeploymentSpec.scala | 4 +-
.../RemoteInstrumentsSerializationSpec.scala | 5 +-
.../remote/artery/RemoteInstrumentsSpec.scala | 3 +-
.../artery/RemoteMessageSerializationSpec.scala | 3 +-
.../pekko/remote/artery/RemoteRouterSpec.scala | 4 +-
.../remote/artery/RemoteSendConsistencySpec.scala | 4 +-
.../pekko/remote/artery/RemoteWatcherSpec.scala | 4 +-
.../remote/artery/RemotingFlightRecorderSpec.scala | 4 +-
.../apache/pekko/remote/artery/SendQueueSpec.scala | 2 +-
.../remote/artery/SystemMessageAckerSpec.scala | 2 +-
.../remote/artery/SystemMessageDeliverySpec.scala | 6 +--
.../apache/pekko/remote/artery/TestContext.scala | 8 +--
.../apache/pekko/remote/artery/UntrustedSpec.scala | 4 +-
.../pekko/remote/artery/aeron/AeronSinkSpec.scala | 2 +-
.../compress/CompressionIntegrationSpec.scala | 6 +--
.../HandshakeShouldDropCompressionTableSpec.scala | 7 ++-
.../artery/jfr/JFRRemotingFlightRecorderSpec.scala | 4 +-
.../pekko/remote/artery/tcp/TcpFramingSpec.scala | 2 +-
.../pekko/remote/artery/tcp/TlsTcpSpec.scala | 14 +++--
.../artery/tcp/ssl/CipherSuiteSupportCheck.scala | 7 ++-
.../artery/tcp/ssl/PeerSubjectVerifierSpec.scala | 2 +-
.../artery/tcp/ssl/PemManagersProviderSpec.scala | 1 -
.../ssl/RotatingKeysSSLEngineProviderSpec.scala | 13 +++--
.../remote/artery/tcp/ssl/TlsResourcesSpec.scala | 6 +--
.../pekko/remote/classic/ActorsLeakSpec.scala | 6 +--
.../remote/classic/RemoteDeathWatchSpec.scala | 6 +--
.../classic/RemoteDeploymentAllowListSpec.scala | 6 +--
.../pekko/remote/classic/RemoteInitErrorSpec.scala | 9 ++--
.../pekko/remote/classic/RemoteSettingsSpec.scala | 8 ++-
.../pekko/remote/classic/RemoteWatcherSpec.scala | 3 +-
.../apache/pekko/remote/classic/RemotingSpec.scala | 3 +-
.../pekko/remote/classic/UntrustedSpec.scala | 6 +--
.../classic/transport/GenericTransportSpec.scala | 3 +-
.../classic/transport/PekkoProtocolSpec.scala | 8 +--
.../transport/PekkoProtocolStressTest.scala | 4 +-
.../SystemMessageDeliveryStressTest.scala | 6 +--
.../classic/transport/TestTransportSpec.scala | 3 +-
.../transport/ThrottlerTransportAdapterSpec.scala | 6 +--
.../AllowJavaSerializationOffSpec.scala | 4 +-
.../ArteryMessageSerializerSpec.scala | 4 +-
...reateSerializerAllowJavaSerializationSpec.scala | 6 +--
.../serialization/MiscMessageSerializerSpec.scala | 5 +-
.../SerializationTransportInformationSpec.scala | 9 ++--
.../SystemMessageSerializationSpec.scala | 4 +-
.../remote/transport/NettyTransportSpec.scala | 14 +++--
.../jackson/FiniteDurationModule.scala | 2 +-
.../jackson/JacksonObjectMapperProvider.scala | 8 +--
.../jackson/PekkoSerializationModule.scala | 1 -
.../serialization/jackson/JacksonFactorySpec.scala | 11 ++--
.../jackson/JacksonSerializerSpec.scala | 16 +++---
.../org/apache/pekko/event/slf4j/Slf4jLogger.scala | 4 +-
.../apache/pekko/event/slf4j/Slf4jLoggerSpec.scala | 6 +--
.../pekko/event/slf4j/Slf4jLoggingFilterSpec.scala | 4 +-
.../pekko/stream/testkit/StreamTestKit.scala | 2 +-
.../stream/testkit/javadsl/StreamTestKit.scala | 9 ++--
.../pekko/stream/testkit/StreamConfiguration.scala | 5 +-
.../apache/pekko/stream/testkit/StreamSpec.scala | 4 +-
.../pekko/stream/tck/ActorSystemLifecycle.scala | 7 ++-
.../stream/tck/CancelledSinkSubscriberTest.scala | 3 +-
.../org/apache/pekko/stream/tck/ConcatTest.scala | 4 +-
.../pekko/stream/tck/EmptyPublisherTest.scala | 4 +-
.../pekko/stream/tck/FanoutPublisherTest.scala | 4 +-
.../pekko/stream/tck/FilePublisherTest.scala | 3 +-
.../tck/FlatMapConcatDoubleSubscriberTest.scala | 4 +-
.../pekko/stream/tck/FlatMapPrefixTest.scala | 4 +-
.../org/apache/pekko/stream/tck/FlattenTest.scala | 4 +-
.../pekko/stream/tck/FoldSinkSubscriberTest.scala | 4 +-
.../stream/tck/ForeachSinkSubscriberTest.scala | 4 +-
.../pekko/stream/tck/FusableProcessorTest.scala | 4 +-
.../pekko/stream/tck/FuturePublisherTest.scala | 4 +-
.../org/apache/pekko/stream/tck/GroupByTest.scala | 4 +-
.../pekko/stream/tck/InputStreamSourceTest.scala | 4 +-
.../pekko/stream/tck/IterablePublisherTest.scala | 4 +-
.../org/apache/pekko/stream/tck/MapTest.scala | 4 +-
.../apache/pekko/stream/tck/MaybeSourceTest.scala | 4 +-
.../tck/PekkoIdentityProcessorVerification.scala | 7 ++-
.../stream/tck/PekkoPublisherVerification.scala | 10 ++--
.../stream/tck/PekkoSubscriberVerification.scala | 7 ++-
.../pekko/stream/tck/PrefixAndTailTest.scala | 4 +-
.../pekko/stream/tck/SingleElementSourceTest.scala | 4 +-
.../pekko/stream/tck/SinkholeSubscriberTest.scala | 7 ++-
.../apache/pekko/stream/tck/SplitWhenTest.scala | 4 +-
.../pekko/stream/tck/TransformProcessorTest.scala | 4 +-
.../pekko/stream/tck/VirtualPublisherTest.scala | 4 +-
.../pekko/stream/impl/SubInletOutletSpec.scala | 6 +--
.../pekko/stream/impl/TraversalBuilderSpec.scala | 8 +--
.../stream/impl/fusing/AsyncCallbackSpec.scala | 6 +--
.../scala/org/apache/pekko/stream/io/TlsSpec.scala | 15 ++----
.../stream/scaladsl/FlowCollectFirstSpec.scala | 2 +-
.../pekko/stream/scaladsl/FlowDispatcherSpec.scala | 2 +-
.../stream/scaladsl/FlowDropRepeatedSpec.scala | 4 +-
.../FlowFlatMapConcatParallelismSpec.scala | 22 ++++----
.../FlowGroupedAdjacentByWeightedSpec.scala | 2 +-
.../pekko/stream/scaladsl/FlowSwitchSpec.scala | 6 +--
.../stream/scaladsl/FlowWithContextSpec.scala | 5 +-
.../apache/pekko/stream/scaladsl/SinkSpec.scala | 4 +-
.../stream/scaladsl/SourceWithContextSpec.scala | 5 +-
.../stream/scaladsl/StreamConvertersSpec.scala | 2 +-
.../pekko/stream/MapAsyncPartitionedSpec.scala | 21 ++++----
.../pekko/stream/typed/javadsl/ActorFlow.scala | 4 +-
.../pekko/stream/typed/scaladsl/ActorFlow.scala | 7 ++-
.../typed/scaladsl/ActorSourceSinkSpec.scala | 4 +-
.../typed/scaladsl/MaterializerForTypedSpec.scala | 4 +-
.../pekko/stream/typed/scaladsl/PubSubSpec.scala | 1 -
.../scala/org/apache/pekko/stream/Attributes.scala | 2 +-
.../scala/org/apache/pekko/stream/KillSwitch.scala | 2 +-
.../apache/pekko/stream/MapAsyncPartitioned.scala | 4 +-
.../org/apache/pekko/stream/RestartSettings.scala | 4 +-
.../apache/pekko/stream/SystemMaterializer.scala | 2 +-
.../pekko/stream/impl/JavaStreamSource.scala | 6 +--
.../org/apache/pekko/stream/impl/MaybeSource.scala | 4 +-
.../org/apache/pekko/stream/impl/QueueSource.scala | 2 +-
.../scala/org/apache/pekko/stream/impl/Sinks.scala | 6 +--
.../org/apache/pekko/stream/impl/Unfold.scala | 2 +-
.../stream/impl/UnfoldResourceSourceAsync.scala | 2 +-
.../pekko/stream/impl/fusing/DropRepeated.scala | 6 +--
.../pekko/stream/impl/fusing/FlattenConcat.scala | 12 ++---
.../pekko/stream/impl/fusing/FutureFlow.scala | 4 +-
.../pekko/stream/impl/fusing/GraphStages.scala | 6 +--
.../impl/fusing/GroupedAdjacentByWeighted.scala | 6 +--
.../stream/impl/fusing/LazyFutureSource.scala | 4 +-
.../org/apache/pekko/stream/impl/fusing/Ops.scala | 13 +++--
.../apache/pekko/stream/impl/fusing/Switch.scala | 2 +-
.../apache/pekko/stream/impl/io/TcpStages.scala | 6 +--
.../pekko/stream/javadsl/DelayStrategy.scala | 2 +-
.../org/apache/pekko/stream/javadsl/Flow.scala | 11 ++--
.../pekko/stream/javadsl/FlowWithContext.scala | 2 +-
.../org/apache/pekko/stream/javadsl/Hub.scala | 2 +-
.../org/apache/pekko/stream/javadsl/Queue.scala | 4 +-
.../apache/pekko/stream/javadsl/RetryFlow.scala | 3 +-
.../org/apache/pekko/stream/javadsl/Sink.scala | 20 ++++----
.../org/apache/pekko/stream/javadsl/Source.scala | 12 ++---
.../pekko/stream/javadsl/SourceWithContext.scala | 2 +-
.../javadsl/StatefulMapConcatAccumulator.scala | 7 ++-
.../pekko/stream/javadsl/StreamConverters.scala | 3 +-
.../org/apache/pekko/stream/javadsl/SubFlow.scala | 4 +-
.../apache/pekko/stream/javadsl/SubSource.scala | 4 +-
.../org/apache/pekko/stream/javadsl/Tcp.scala | 4 +-
.../org/apache/pekko/stream/scaladsl/Flow.scala | 3 +-
.../pekko/stream/scaladsl/FlowWithContext.scala | 2 +-
.../pekko/stream/scaladsl/FlowWithContextOps.scala | 8 +--
.../org/apache/pekko/stream/scaladsl/Hub.scala | 4 +-
.../org/apache/pekko/stream/scaladsl/Queue.scala | 4 +-
.../org/apache/pekko/stream/scaladsl/Sink.scala | 8 +--
.../org/apache/pekko/stream/scaladsl/SubFlow.scala | 4 +-
.../org/apache/pekko/stream/scaladsl/Tcp.scala | 2 +-
.../org/apache/pekko/stream/stage/GraphStage.scala | 3 +-
.../pekko/testkit/CallingThreadDispatcher.scala | 4 +-
.../testkit/ExplicitlyTriggeredScheduler.scala | 4 +-
.../org/apache/pekko/testkit/TestActorRef.scala | 3 +-
.../scala/org/apache/pekko/testkit/TestKit.scala | 3 +-
.../apache/pekko/testkit/TestKitExtension.scala | 4 +-
.../org/apache/pekko/testkit/javadsl/TestKit.scala | 2 +-
.../apache/pekko/testkit/DefaultTimeoutSpec.scala | 4 +-
.../apache/pekko/testkit/ImplicitSenderSpec.scala | 4 +-
.../scala/org/apache/pekko/testkit/PekkoSpec.scala | 21 ++++----
.../org/apache/pekko/testkit/PekkoSpecSpec.scala | 12 ++---
.../apache/pekko/testkit/TestActorRefSpec.scala | 4 +-
.../org/apache/pekko/testkit/TestProbeSpec.scala | 4 +-
.../apache/pekko/testkit/WithLogCapturing.scala | 4 +-
.../apache/pekko/testkit/metrics/MetricsKit.scala | 6 +--
.../pekko/testkit/metrics/MetricsKitOps.scala | 1 -
.../pekko/testkit/metrics/MetricsKitSpec.scala | 3 +-
1156 files changed, 2697 insertions(+), 3555 deletions(-)
delete mode 100644
actor/src/main/java/org/apache/pekko/japi/function/IntFunction.java
delete mode 100644
actor/src/main/java/org/apache/pekko/japi/function/package-info.java
delete mode 100644
actor/src/main/scala-2.13/org/apache/pekko/dispatch/internal/SameThreadExecutionContext.scala
delete mode 100644
actor/src/main/scala-3/org/apache/pekko/dispatch/internal/SameThreadExecutionContext.scala
delete mode 100644 actor/src/main/scala/org/apache/pekko/compat/Future.scala
delete mode 100644
plugins/serialversion-remover-plugin/src/main/resources/plugin.properties
delete mode 100644
plugins/serialversion-remover-plugin/src/main/scala/org/apache/pekko/Plugin.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
