From cd2066d0fcc4770920eedef4cb27b5d167df5596 Mon Sep 17 00:00:00 2001 From: jwijgerd Date: Sat, 27 Apr 2024 10:55:28 +0200 Subject: [PATCH] update Copyright statements and optimized imports --- bom/pom.xml | 2 +- main/api/pom.xml | 2 +- .../elasticsoftware/elasticactors/Actor.java | 2 +- .../elasticactors/ActorContext.java | 3 +- .../elasticactors/ActorContextHolder.java | 2 +- .../elasticactors/ActorLifecycleListener.java | 2 +- .../elasticactors/ActorNotFoundException.java | 2 +- .../elasticactors/ActorRef.java | 7 +- .../elasticactors/ActorRefGroup.java | 2 +- .../elasticactors/ActorState.java | 6 +- .../elasticactors/ActorSystem.java | 6 +- .../ActorSystemConfiguration.java | 2 +- .../elasticactors/ActorSystems.java | 5 +- .../elasticactors/Asynchronous.java | 8 +-- .../elasticactors/ElasticActor.java | 2 +- .../elasticactors/InitialStateProvider.java | 2 +- .../elasticactors/ManagedActor.java | 8 +-- .../elasticactors/ManagedActorsRegistry.java | 2 +- .../MessageDeliveryException.java | 2 +- .../elasticactors/MessageHandler.java | 8 +-- .../elasticactors/MessageHandlers.java | 2 +- .../MessageHandlersRegistry.java | 2 +- .../elasticactors/MethodActor.java | 13 ++-- .../elasticactors/PersistentSubscription.java | 5 +- .../PluggableMessageHandlers.java | 8 +-- .../PublisherNotFoundException.java | 2 +- .../elasticactors/ServiceActor.java | 8 +-- .../elasticactors/SingletonActor.java | 2 +- .../elasticactors/SubscriberContext.java | 2 +- .../SubscriberContextHolder.java | 2 +- .../elasticactors/TempActor.java | 2 +- .../elasticactors/TypedActor.java | 4 +- .../elasticactors/TypedSubscriber.java | 2 +- .../UnexpectedResponseTypeException.java | 2 +- .../elasticactors/UntypedActor.java | 2 +- .../elasticactors/UntypedSubscriber.java | 2 +- .../cluster/ActorRefFactory.java | 5 +- .../cluster/ActorSystemEvent.java | 2 +- .../ActorSystemEventListenerRegistry.java | 3 +- .../cluster/RebalancingEventListener.java | 2 +- .../scheduler/ScheduledMessageRefFactory.java | 5 +- .../concurrent/ActorCompletableFuture.java | 15 +---- .../elasticactors/concurrent/Expirable.java | 2 +- .../elasticactors/logging/LogLevel.java | 2 +- .../elasticactors/package-info.java | 2 +- .../scheduler/ScheduledMessageRef.java | 2 +- .../elasticactors/scheduler/Scheduler.java | 4 +- .../serialization/Deserializer.java | 2 +- .../elasticactors/serialization/Message.java | 8 +-- .../serialization/MessageDeserializer.java | 2 +- .../serialization/MessageSerializer.java | 2 +- .../MessageToStringConverter.java | 2 +- .../NoopSerializationFramework.java | 2 +- .../serialization/SerializationFramework.java | 2 +- .../serialization/Serializer.java | 2 +- .../state/ActorLifecycleStep.java | 2 +- .../elasticactors/state/NullActorState.java | 2 +- .../state/PersistenceAdvisor.java | 2 +- .../state/PersistenceConfig.java | 2 +- .../state/PersistenceConfigHelper.java | 2 +- .../tracing/CreationContext.java | 3 +- .../tracing/LogContextProcessor.java | 5 +- .../tracing/MessageHandlingContext.java | 4 +- .../tracing/MessagingContextManager.java | 6 +- .../tracing/NoopMessagingScope.java | 2 +- .../elasticactors/tracing/TraceContext.java | 10 +-- .../elasticactors/tracing/Traceable.java | 2 +- .../elasticactors/tracing/TracedMessage.java | 5 +- .../elasticactors/tracing/TracingUtils.java | 3 +- .../elasticactors/AnotherTestMessage.java | 2 +- .../elasticactors/MethodActorTest.java | 2 +- .../elasticactors/TestActorContextHolder.java | 2 +- .../elasticactors/TestActorState.java | 2 +- .../elasticactors/TestMessage.java | 2 +- .../elasticactors/TestMessageHandlers.java | 2 +- .../TestPersistentMethodActor.java | 2 +- .../TestSerializationFramework.java | 9 +-- .../tracing/TracingUtilsTest.java | 2 +- .../test/resources/simplelogger.properties | 2 +- main/backplane-cassandra-common/pom.xml | 2 +- .../serialization/CompressingSerializer.java | 2 +- .../DecompressingDeserializer.java | 2 +- .../state/PersistentActorUpdateEvent.java | 4 +- main/backplane-cassandra2/pom.xml | 2 +- ...draActorSystemEventListenerRepository.java | 2 +- .../CassandraScheduledMessageRepository.java | 2 +- .../health/CassandraHealthCheck.java | 2 +- .../CassandraPersistentActorRepository.java | 2 +- .../PersistentActorUpdateEventProcessor.java | 2 +- .../cassandra2/util/ExecutionUtils.java | 10 +-- .../configuration/BackplaneConfiguration.java | 2 +- .../CassandraSessionManager.java | 2 +- main/backplane-cassandra4/pom.xml | 2 +- ...draActorSystemEventListenerRepository.java | 5 +- .../CassandraScheduledMessageRepository.java | 5 +- .../health/CassandraHealthCheck.java | 2 +- .../CassandraPersistentActorRepository.java | 2 +- .../PersistentActorUpdateEventProcessor.java | 2 +- .../cassandra4/util/ExecutionUtils.java | 8 +-- .../configuration/BackplaneConfiguration.java | 2 +- .../CassandraSessionManager.java | 4 +- main/backplane-redis/pom.xml | 2 +- .../state/RedisPersistentActorRepository.java | 2 +- main/base/pom.xml | 2 +- .../base/actors/ActorDelegate.java | 2 +- .../elasticactors/base/actors/AliasActor.java | 2 +- .../base/actors/JavaScriptActor.java | 9 +-- .../elasticactors/base/actors/ReplyActor.java | 5 +- .../JacksonActorRefDeserializer.java | 2 +- .../JacksonActorRefSerializer.java | 2 +- .../JacksonActorStateDeserializer.java | 2 +- .../JacksonActorStateSerializer.java | 2 +- .../JacksonMessageDeserializer.java | 2 +- .../JacksonMessageSerializer.java | 2 +- .../JacksonMessageToStringConverter.java | 4 +- ...acksonScheduledMessageRefDeserializer.java | 2 +- .../JacksonScheduledMessageRefSerializer.java | 2 +- .../JacksonSerializationFramework.java | 2 +- .../serialization/ObjectMapperBuilder.java | 9 +-- .../base/state/AliasActorState.java | 2 +- .../base/state/JacksonActorState.java | 2 +- .../base/state/JavaScriptActorState.java | 2 +- .../elasticactors/base/state/StringState.java | 2 +- .../META-INF/elasticactors.properties | 2 +- .../elasticactors/TestActorContextHolder.java | 2 +- .../base/actors/JavaScriptActorTest.java | 2 +- .../ObjectMapperBuilderTest.java | 2 +- .../TestObjectWIthJsonSerialize.java | 2 +- .../test/resources/simplelogger.properties | 2 +- main/caching/pom.xml | 2 +- .../service/CachingClassLoadingHelper.java | 4 +- ...ware.elasticactors.util.ClassLoadingHelper | 2 +- main/client-rabbitmq/pom.xml | 2 +- .../spring/RabbitClientConfiguration.java | 2 +- main/client-spring-amqp/pom.xml | 2 +- .../spring/RabbitTemplateMessageQueue.java | 8 +-- .../RabbitTemplateMessageQueueFactory.java | 9 +-- ...bitTemplateMessageQueueFactoryFactory.java | 2 +- .../spring/SpringAMQPClientConfiguration.java | 2 +- main/client/pom.xml | 2 +- .../ActorSystemDelegateConfiguration.java | 2 +- .../cluster/BaseDisconnectedActorRef.java | 5 +- .../DisconnectedRemoteActorNodeRef.java | 2 +- .../DisconnectedRemoteActorShardRef.java | 2 +- .../cluster/DisconnectedServiceActorRef.java | 2 +- .../client/cluster/RemoteActorShard.java | 2 +- .../client/cluster/RemoteActorShardRef.java | 11 +--- .../cluster/RemoteActorShardRefFactory.java | 2 +- .../cluster/RemoteActorSystemInstance.java | 27 ++------ .../client/cluster/RemoteActorSystems.java | 2 +- .../configuration/ClientConfiguration.java | 2 +- .../client/messaging/ActorSystemMessage.java | 2 +- .../ActorSystemMessageSerializer.java | 2 +- .../ClientSerializationFrameworks.java | 9 +-- .../ClientSystemDeserializers.java | 8 +-- .../ClientSystemSerializers.java | 2 +- ...lizedActorStateSerializationFramework.java | 2 +- .../SerializedActorStateSerializer.java | 2 +- .../client/state/SerializedActorState.java | 2 +- main/cluster-kubernetes/pom.xml | 2 +- .../ClusteringConfiguration.java | 2 +- .../cluster/DaemonThreadFactory.java | 2 +- .../cluster/KubernetesClusterService.java | 2 +- main/cluster-shoal/pom.xml | 2 +- .../ClusteringConfiguration.java | 2 +- .../shoal/cluster/ShoalClusterService.java | 35 ++-------- .../elasticactors/ClusteringTest.java | 2 +- .../elasticactors/shoal/GMSTest.java | 20 +----- main/core/pom.xml | 2 +- .../elasticactors/cache/CacheManager.java | 2 +- .../cache/NodeActorCacheManager.java | 2 +- .../cache/ShardActorCacheManager.java | 5 +- .../cluster/AbstractActorContainer.java | 2 +- .../elasticactors/cluster/ActorRefTools.java | 2 +- .../elasticactors/cluster/ActorShardRef.java | 10 +-- .../cluster/ActorSystemEventListenerImpl.java | 3 +- .../cluster/ActorSystemEventRegistryImpl.java | 2 +- .../elasticactors/cluster/BaseActorRef.java | 5 +- .../cluster/BaseDisconnectedActorRef.java | 5 +- .../cluster/DisconnectedActorNodeRef.java | 2 +- .../DisconnectedRemoteActorNodeRef.java | 2 +- .../DisconnectedRemoteActorShardRef.java | 2 +- .../cluster/DisconnectedServiceActorRef.java | 2 +- .../elasticactors/cluster/LocalActorNode.java | 31 ++------- .../cluster/LocalActorRefGroup.java | 2 +- .../cluster/LocalActorShard.java | 2 +- .../cluster/LocalActorSystemInstance.java | 45 ++----------- .../cluster/LocalClusterActorNodeRef.java | 9 +-- .../cluster/NodeSelectorHasher.java | 2 +- .../cluster/RemoteActorNode.java | 2 +- .../cluster/RemoteActorShard.java | 2 +- .../cluster/RemoteActorSystemActorShard.java | 2 +- .../cluster/RemoteActorSystemInstance.java | 18 ++--- .../cluster/RemoteActorSystems.java | 4 +- .../cluster/RemoteClusterActorNodeRef.java | 9 +-- .../cluster/ServiceActorRef.java | 9 +-- .../cluster/logging/LoggingSettings.java | 9 ++- .../cluster/logging/MessageLogger.java | 5 +- .../messaging/ShardReleasedMessage.java | 2 +- .../metrics/MapMicrometerTagCustomizer.java | 4 +- .../cluster/metrics/Measurement.java | 2 +- .../cluster/metrics/MetricsSettings.java | 5 +- .../metrics/MicrometerConfiguration.java | 9 ++- .../metrics/MicrometerTagCustomizer.java | 3 +- .../cluster/protobuf/Clustering.java | 2 +- ...DisconnectedRemoteScheduledMessageRef.java | 2 +- .../scheduler/ScheduledMessageRefTools.java | 2 +- .../scheduler/ScheduledMessageShardRef.java | 8 +-- .../cluster/scheduler/ShardedScheduler.java | 2 +- .../scheduler/SimpleScheduledMessageRef.java | 4 +- .../cluster/scheduler/SimpleScheduler.java | 22 ++----- .../strategies/MultiNodeScaleUpStrategy.java | 2 +- .../RunningNodeScaleDownStrategy.java | 2 +- .../RunningNodeScaleUpStrategy.java | 2 +- .../strategies/SingleNodeScaleUpStrategy.java | 2 +- .../StartingNodeScaleUpStrategy.java | 2 +- .../cluster/tasks/ActivateActorTask.java | 2 +- .../tasks/ActivateServiceActorTask.java | 11 +--- .../cluster/tasks/ActorLifecycleTask.java | 18 ++--- .../cluster/tasks/CreateActorTask.java | 2 +- .../cluster/tasks/DestroyActorTask.java | 2 +- .../tasks/HandleServiceMessageTask.java | 12 +--- ...HandleUndeliverableServiceMessageTask.java | 11 +--- .../cluster/tasks/InternalActorContext.java | 2 +- .../cluster/tasks/PassivateActorTask.java | 2 +- .../cluster/tasks/PersistActorTask.java | 2 +- .../cluster/tasks/ProtocolFactory.java | 2 +- .../cluster/tasks/ProtocolFactoryFactory.java | 2 +- .../tasks/app/ApplicationProtocolFactory.java | 2 +- .../cluster/tasks/app/HandleMessageTask.java | 2 +- .../app/HandleUndeliverableMessageTask.java | 2 +- .../InternalSubscriberContext.java | 2 +- .../ReactiveHandleMessageTask.java | 18 ++--- ...eactiveHandleUndeliverableMessageTask.java | 17 +---- .../ReactiveStreamsProtocolFactory.java | 2 +- .../core/actors/AskReplyActor.java | 2 +- .../actors/CompletableFutureDelegate.java | 2 +- .../core/actors/InternalActorDelegate.java | 6 +- .../core/actors/SubscriberActor.java | 5 +- .../core/actors/SubscriberState.java | 2 +- .../MultiMessageHandlerEventListener.java | 2 +- .../PersistentSubscriptionImpl.java | 2 +- .../ActorSystemEventListenerDeserializer.java | 2 +- .../ActorSystemEventListenerSerializer.java | 2 +- .../internal/PersistentActorDeserializer.java | 2 +- .../internal/PersistentActorSerializer.java | 2 +- .../serialization/protobuf/Elasticactors.java | 2 +- .../state/ActorStateUpdateEvent.java | 4 +- .../state/ActorStateUpdateProcessor.java | 2 +- .../DefaultActorStateUpdateProcessor.java | 10 ++- .../state/NoopActorStateUpdateProcessor.java | 2 +- .../test/TestActorSystemsInstance.java | 2 +- .../elasticactors/util/ArrayUtils.java | 2 +- .../elasticactors/util/EnvironmentUtils.java | 4 +- .../elasticactors/util/ManifestTools.java | 2 +- .../BlockingQueueThreadBoundExecutor.java | 14 ++-- .../util/concurrent/DaemonThreadFactory.java | 2 +- .../MessageHandlingThreadBoundRunnable.java | 2 +- .../util/concurrent/ThreadBoundEvent.java | 2 +- .../concurrent/ThreadBoundEventProcessor.java | 2 +- .../util/concurrent/ThreadBoundExecutor.java | 2 +- .../ThreadBoundExecutorBuilder.java | 7 +- .../util/concurrent/ThreadBoundRunnable.java | 2 +- .../ThreadBoundRunnableEventProcessor.java | 2 +- .../WrapperThreadBoundRunnable.java | 2 +- .../DisruptorThreadBoundExecutor.java | 8 +-- .../disruptor/ThreadBoundEventHandler.java | 2 +- .../disruptor/ThreadBoundEventWrapper.java | 2 +- .../ThreadBoundEventWrapperFactory.java | 2 +- .../CountingTimedThreadBoundExecutor.java | 6 +- .../DelegatingTimedThreadBoundExecutor.java | 2 +- .../metrics/ThreadBoundExecutorMonitor.java | 18 ++--- .../metrics/TimedThreadBoundEvent.java | 4 +- .../metrics/TimedThreadBoundExecutor.java | 9 ++- .../metrics/TimedThreadBoundRunnable.java | 6 +- .../metrics/TraceThreadBoundRunnable.java | 2 +- .../META-INF/elasticactors.properties | 2 +- .../cluster/ActorRefToolsTest.java | 2 +- .../ScheduledMessageRefToolsTest.java | 11 +--- .../messaging/UUIDToolsTest.java | 2 +- .../SerializationContextTest.java | 2 +- .../CreateActorMessageSerializationTest.java | 2 +- .../test/resources/simplelogger.properties | 2 +- main/elasticactors-kafka-testapp/pom.xml | 2 +- .../src/config/simplelogger.properties | 2 +- .../src/config/system.properties | 2 +- .../kafka/testapp/KafkaTestApplication.java | 9 +-- .../actors/VirtualCashAccountActor.java | 16 +---- .../configuration/ContainerConfiguration.java | 12 +--- .../messages/ActivateAccountCommand.java | 2 +- .../kafka/testapp/messages/BalanceQuery.java | 2 +- .../testapp/messages/CreditAccountEvent.java | 2 +- .../testapp/messages/DebitAccountEvent.java | 2 +- .../messages/ScheduleDebitCommand.java | 2 +- .../testapp/messages/TransferCommand.java | 2 +- .../messages/VirtualCashAccountAdapter.java | 2 +- .../state/VirtualCashAccountState.java | 2 +- .../META-INF/elasticactors.properties | 2 +- .../main/resources/simplelogger.properties | 2 +- main/elasticactors-kafka/pom.xml | 2 +- .../kafka/InternalActorContext.java | 2 +- .../elasticactors/kafka/KafkaActorNode.java | 2 +- .../elasticactors/kafka/KafkaActorShard.java | 2 +- .../kafka/KafkaActorSystemInstance.java | 66 +++---------------- .../elasticactors/kafka/KafkaActorThread.java | 2 +- .../kafka/KafkaTransactionContext.java | 2 +- .../kafka/ManagedActorContainer.java | 2 +- .../kafka/ServiceActorContext.java | 10 +-- .../kafka/cluster/ActorLifecycleFunction.java | 2 +- .../kafka/cluster/ApplicationProtocol.java | 2 +- .../DisconnectedPartitionedActorNodeRef.java | 2 +- .../cluster/InternalSubscriberContext.java | 2 +- .../kafka/cluster/KafkaActorRefTools.java | 2 +- .../cluster/KafkaInternalActorSystems.java | 27 ++------ .../LocalClusterPartitionedActorNodeRef.java | 2 +- .../cluster/ReactiveStreamsProtocol.java | 9 +-- .../kafka/cluster/SubscriberContextImpl.java | 8 +-- .../configuration/NodeConfiguration.java | 14 +--- .../kafka/scheduler/KafkaTopicScheduler.java | 2 +- .../serialization/CompressingSerializer.java | 2 +- .../DecompressingDeserializer.java | 2 +- ...aActorSystemEventListenerDeserializer.java | 2 +- .../KafkaInternalMessageDeserializer.java | 2 +- .../KafkaInternalMessageSerializer.java | 2 +- .../KafkaPersistentActorSerializer.java | 2 +- .../KafkaProducerSerializer.java | 2 +- .../KafkaScheduledMessageDeserializer.java | 2 +- .../kafka/serialization/UUIDDeserializer.java | 2 +- .../kafka/serialization/UUIDSerializer.java | 2 +- .../ChronicleMapPersistentActorStore.java | 2 +- ...ronicleMapPersistentActorStoreFactory.java | 2 +- .../InMemoryPeristentActorStoreFactory.java | 2 +- .../state/InMemoryPersistentActorStore.java | 2 +- .../kafka/state/PersistentActorStore.java | 2 +- .../state/PersistentActorStoreFactory.java | 2 +- .../kafka/utils/TopicHelper.java | 2 +- .../kafka/utils/TopicNamesHelper.java | 2 +- .../kafka/KafkaAdminClientTest.java | 2 +- .../elasticactors/kafka/TestApplication.java | 2 +- .../configuration/ContainerConfiguration.java | 12 +--- .../test/resources/simplelogger.properties | 2 +- .../src/test/resources/system.properties | 2 +- main/indexing-elasticsearch/pom.xml | 2 +- .../indexing/elasticsearch/IndexConfig.java | 8 +-- .../elasticsearch/IndexderAppConfig.java | 4 +- .../elasticsearch/indexer/Indexer.java | 2 +- .../elasticsearch/indexer/IndexerTest.java | 2 +- .../test/resources/simplelogger.properties | 2 +- main/messaging-activemq/pom.xml | 2 +- .../ActiveMQArtemisMessagingService.java | 2 +- .../activemq/LocalMessageQueue.java | 2 +- .../activemq/RemoteMessageQueue.java | 2 +- .../configuration/MessagingConfiguration.java | 2 +- main/messaging-rabbitmq/pom.xml | 2 +- .../configuration/MessagingConfiguration.java | 2 +- .../rabbitmq/ChannelListenerRegistry.java | 2 +- .../rabbitmq/LoggingShutdownListener.java | 2 +- .../elasticactors/rabbitmq/MessageAcker.java | 2 +- .../rabbitmq/RabbitMQMessagingService.java | 2 +- .../rabbitmq/ack/AsyncMessageAcker.java | 4 +- .../rabbitmq/ack/BufferingMessageAcker.java | 2 +- .../rabbitmq/ack/DirectMessageAcker.java | 2 +- .../rabbitmq/ack/WriteBehindMessageAcker.java | 2 +- .../rabbitmq/cpt/LocalMessageQueue.java | 10 +-- ...MultiProducerRabbitMQMessagingService.java | 2 +- .../rabbitmq/cpt/RemoteMessageQueue.java | 2 +- .../rabbitmq/health/RabbitMQHealthCheck.java | 2 +- .../rabbitmq/sc/LocalMessageQueue.java | 10 +-- .../rabbitmq/sc/RemoteMessageQueue.java | 2 +- ...ingleProducerRabbitMQMessagingService.java | 19 ++---- .../rabbitmq/BufferingMessageAckerTest.java | 9 +-- .../RabbitMQMessagingServiceTest.java | 12 +--- .../test/resources/simplelogger.properties | 2 +- main/messaging/pom.xml | 2 +- .../messaging/AbstractTracedMessage.java | 2 +- .../messaging/ActorShardHasher.java | 2 +- .../messaging/DefaultInternalMessage.java | 4 +- .../messaging/ImmutableInternalMessage.java | 2 +- .../messaging/InternalMessageFactory.java | 2 +- .../messaging/MessageQueueProxy.java | 2 +- .../messaging/MultiMessageQueueProxy.java | 4 +- .../MultiMessageQueueProxyHasher.java | 2 +- .../messaging/ScheduledMessageImpl.java | 4 +- .../messaging/SingleMessageQueueProxy.java | 2 +- .../elasticactors/messaging/Splittable.java | 2 +- .../messaging/SplittableUtils.java | 2 +- .../messaging/TransientInternalMessage.java | 2 +- .../elasticactors/messaging/UUIDTools.java | 4 +- .../internal/ActivateActorMessage.java | 4 +- .../messaging/internal/ActorNodeMessage.java | 5 +- .../messaging/internal/ActorType.java | 2 +- .../CancelScheduledMessageMessage.java | 2 +- .../internal/CreateActorMessage.java | 2 +- .../internal/DestroyActorMessage.java | 4 +- .../internal/InternalHashKeyUtils.java | 2 +- .../internal/MessageQueueBoundPayload.java | 2 +- .../internal/PersistActorMessage.java | 4 +- .../reactivestreams/CancelMessage.java | 2 +- .../reactivestreams/CompletedMessage.java | 2 +- .../reactivestreams/NextMessage.java | 2 +- .../ReactiveStreamsProtocol.java | 2 +- .../reactivestreams/RequestMessage.java | 2 +- .../reactivestreams/SubscribeMessage.java | 2 +- .../reactivestreams/SubscriptionMessage.java | 2 +- .../MessagingSystemDeserializers.java | 31 ++------- .../MessagingSystemSerializers.java | 2 +- .../serialization/SerializationContext.java | 2 +- .../serialization/SystemDeserializers.java | 2 +- .../SystemSerializationFramework.java | 2 +- .../serialization/SystemSerializers.java | 2 +- .../ActivateActorMessageDeserializer.java | 2 +- .../ActivateActorMessageSerializer.java | 2 +- .../ActorNodeMessageDeserializer.java | 2 +- .../internal/ActorNodeMessageSerializer.java | 2 +- .../internal/ActorRefDeserializer.java | 2 +- .../internal/ActorRefSerializer.java | 2 +- ...ancelScheduleMessageMessageSerializer.java | 2 +- ...elScheduledMessageMessageDeserializer.java | 2 +- .../CreateActorMessageDeserializer.java | 2 +- .../CreateActorMessageSerializer.java | 2 +- .../DestroyActorMessageDeserializer.java | 2 +- .../DestroyActorMessageSerializer.java | 2 +- .../internal/InternalMessageDeserializer.java | 2 +- .../internal/InternalMessageSerializer.java | 2 +- .../PersistActorMessageDeserializer.java | 2 +- .../PersistActorMessageSerializer.java | 2 +- .../ScheduledMessageDeserializer.java | 2 +- .../internal/ScheduledMessageSerializer.java | 2 +- .../tracing/CreationContextDeserializer.java | 5 +- .../tracing/CreationContextSerializer.java | 5 +- .../tracing/TraceContextDeserializer.java | 2 +- .../tracing/TraceContextSerializer.java | 5 +- .../serialization/protobuf/Messaging.java | 2 +- .../protobuf/Reactivestreams.java | 2 +- .../CancelMessageDeserializer.java | 2 +- .../CancelMessageSerializer.java | 2 +- .../CompletedMessageDeserializer.java | 2 +- .../CompletedMessageSerializer.java | 2 +- .../NextMessageDeserializer.java | 2 +- .../NextMessageSerializer.java | 2 +- .../RequestMessageDeserializer.java | 2 +- .../RequestMessageSerializer.java | 2 +- .../SubscribeMessageDeserializer.java | 2 +- .../SubscribeMessageSerializer.java | 2 +- .../SubscriptionMessageDeserializer.java | 2 +- .../SubscriptionMessageSerializer.java | 2 +- .../elasticactors/util/ByteBufferUtils.java | 2 +- .../util/ClassLoadingHelper.java | 4 +- .../util/SerializationTools.java | 9 +-- main/pom.xml | 2 +- main/runtime/pom.xml | 2 +- .../elasticactors/cluster/ConsistentHash.java | 2 +- .../cluster/HashingNodeSelector.java | 2 +- .../cluster/HashingNodeSelectorFactory.java | 2 +- .../configuration/AppConfiguration.java | 2 +- .../configuration/NodeConfiguration.java | 18 +---- .../InternalActorSystemHealthCheck.java | 2 +- .../ActorLifecycleListenerScanner.java | 2 +- .../runtime/DefaultConfiguration.java | 2 +- .../runtime/DefaultRemoteConfiguration.java | 2 +- .../runtime/ElasticActorsBootstrapper.java | 2 +- .../runtime/ElasticActorsNode.java | 44 ++----------- .../runtime/ManagedActorsScanner.java | 11 +--- .../runtime/MessagesScanner.java | 2 +- .../PluggableMessageHandlersRegistry.java | 2 +- .../PluggableMessageHandlersScanner.java | 4 +- .../elasticactors/runtime/ScannerHelper.java | 2 +- .../ActorAnnotationBeanNameGenerator.java | 2 +- ...orSystemApplicationContextInitializer.java | 2 +- .../AnnotationConfigApplicationContext.java | 2 +- ...AnnotationConfigWebApplicationContext.java | 2 +- .../ElasticActorsContextLoaderListener.java | 2 +- .../cluster/HashingNodeSelectorTest.java | 2 +- .../runtime/DefaultConfigurationTest.java | 6 +- .../elasticactors/test/TestActor.java | 2 +- .../elasticactors/test/TestActorFullName.java | 2 +- .../test/resources/simplelogger.properties | 2 +- main/spi/pom.xml | 2 +- .../elasticactors/ActorContainer.java | 2 +- .../elasticactors/ActorContainerRef.java | 2 +- .../ActorLifecycleListenerRegistry.java | 2 +- .../elasticactors/ActorNode.java | 2 +- .../elasticactors/ActorShard.java | 2 +- .../InternalActorSystemConfiguration.java | 2 +- .../elasticactors/NodeKey.java | 2 +- .../elasticactors/PhysicalNode.java | 2 +- .../RemoteActorSystemConfiguration.java | 2 +- .../elasticactors/ShardKey.java | 2 +- .../elasticactors/cache/EvictionListener.java | 2 +- .../cluster/ActorSystemEventListener.java | 3 +- .../ActorSystemEventListenerRepository.java | 2 +- .../ActorSystemEventListenerService.java | 2 +- .../cluster/ClusterEventListener.java | 2 +- .../cluster/ClusterMessageHandler.java | 2 +- .../elasticactors/cluster/ClusterService.java | 2 +- .../cluster/InternalActorSystem.java | 9 +-- ...ernalActorSystemEventListenerRegistry.java | 2 +- .../cluster/InternalActorSystems.java | 8 +-- .../elasticactors/cluster/NodeSelector.java | 2 +- .../cluster/NodeSelectorFactory.java | 2 +- .../elasticactors/cluster/ShardAccessor.java | 2 +- .../cluster/ShardDistributionStrategy.java | 2 +- .../cluster/ShardDistributor.java | 2 +- .../cluster/scheduler/InternalScheduler.java | 2 +- .../cluster/scheduler/ScheduledMessage.java | 4 +- .../scheduler/ScheduledMessageKey.java | 2 +- .../scheduler/ScheduledMessageRepository.java | 2 +- .../cluster/scheduler/SchedulerService.java | 2 +- .../elasticactors/health/HealthCheck.java | 2 +- .../health/HealthCheckResult.java | 2 +- .../elasticactors/messaging/Hasher.java | 2 +- .../messaging/InternalMessage.java | 2 +- .../messaging/MessageHandler.java | 2 +- .../MessageHandlerEventListener.java | 2 +- .../elasticactors/messaging/MessageQueue.java | 2 +- .../messaging/MessageQueueEventListener.java | 2 +- .../messaging/MessageQueueFactory.java | 2 +- .../messaging/MessageQueueFactoryFactory.java | 2 +- .../messaging/MessagingService.java | 2 +- ...ssagingServiceInitializationException.java | 2 +- .../InternalPersistentSubscription.java | 2 +- .../reactivestreams/ProcessorContext.java | 2 +- .../serialization/SerializationAccessor.java | 2 +- .../SerializationFrameworks.java | 2 +- .../elasticactors/state/ActorStateUpdate.java | 4 +- .../state/ActorStateUpdateListener.java | 2 +- .../state/MessageSubscriber.java | 2 +- .../elasticactors/state/PersistentActor.java | 25 ++----- .../state/PersistentActorRepository.java | 2 +- main/test/pom.xml | 2 +- .../elasticactors/test/TestActorSystem.java | 7 +- .../test/TestInternalActorSystems.java | 2 +- .../NoopActorSystemEventRegistryService.java | 2 +- .../cluster/SingleNodeClusterService.java | 2 +- .../UnsupportedThreadBoundExecutor.java | 2 +- .../NoopScheduledMessageRepository.java | 2 +- .../configuration/BackplaneConfiguration.java | 2 +- .../configuration/ClientConfiguration.java | 2 +- .../configuration/MessagingConfiguration.java | 2 +- .../test/configuration/SystemInitializer.java | 2 +- .../test/configuration/TestConfiguration.java | 2 +- .../test/messaging/LocalMessageQueue.java | 2 +- .../test/messaging/TestMessagingService.java | 6 +- .../UnsupportedMessageQueueFactory.java | 2 +- ...UnsupportedMessageQueueFactoryFactory.java | 2 +- .../LoggingActorStateUpdateListener.java | 2 +- .../state/NoopPersistentActorRepository.java | 2 +- .../elasticactors/test/ContextTest.java | 2 +- .../test/ContextTestConfiguration.java | 8 +-- .../elasticactors/test/ManagedActorTest.java | 9 +-- .../elasticactors/test/ManifestToolsTest.java | 2 +- .../test/SingletonActorTest.java | 8 +-- .../test/ask/ActorCompletableFutureTest.java | 2 +- .../elasticactors/test/ask/AfterHandlers.java | 2 +- .../test/ask/AskForGreeting.java | 2 +- .../test/ask/AskForGreetingActor.java | 9 +-- .../elasticactors/test/ask/AskTest.java | 12 +--- .../test/ask/BeforeHandlers.java | 2 +- .../test/common/CacheExpirationTest.java | 6 +- .../test/common/CurrentActorName.java | 2 +- .../test/common/EchoGreetingActor.java | 2 +- .../common/ExclusiveManagedNameActor.java | 8 +-- .../test/common/GetActorName.java | 2 +- .../elasticactors/test/common/Greeting.java | 2 +- .../test/common/GreetingActor.java | 2 +- .../test/common/GreetingTest.java | 9 +-- .../test/common/IScheduledGreeting.java | 2 +- .../test/common/InitialNameStateProvider.java | 2 +- .../test/common/ManagedNameActor.java | 2 +- .../test/common/NameActorState.java | 2 +- .../test/common/ScheduledGreeting.java | 2 +- .../test/common/SetActorName.java | 2 +- .../test/common/SingletonNameActor.java | 8 +-- .../test/common/SpecialGreeting.java | 2 +- .../AnonymousSubscriberTest.java | 2 +- .../reactivestreams/ReactiveStreamsTest.java | 2 +- .../StreamFinishedMessage.java | 2 +- .../test/reactivestreams/StreamedMessage.java | 2 +- .../test/reactivestreams/TestPublisher.java | 2 +- .../test/reactivestreams/TestSubscriber.java | 2 +- .../UnsupportedPublishersTest.java | 2 +- .../META-INF/elasticactors.properties | 2 +- main/test/src/test/resources/log4j2-test.xml | 2 +- .../test/resources/simplelogger.properties | 2 +- .../test/src/test/resources/system.properties | 2 +- main/tracing-slf4j/pom.xml | 2 +- .../service/Slf4jLogContextProcessor.java | 27 ++------ ....elasticactors.tracing.LogContextProcessor | 2 +- main/tracing-spring/pom.xml | 2 +- .../spring/AsyncDefaultConfiguration.java | 2 +- .../spring/ExecutorBeanPostProcessor.java | 2 +- .../spring/LazyTraceAsyncTaskExecutor.java | 2 +- .../tracing/spring/LazyTraceExecutor.java | 2 +- .../LazyTraceScheduledThreadPoolExecutor.java | 2 +- .../LazyTraceThreadPoolTaskExecutor.java | 8 +-- .../LazyTraceThreadPoolTaskScheduler.java | 2 +- .../tracing/spring/TraceCallable.java | 4 +- .../tracing/spring/TraceRunnable.java | 5 +- .../spring/TraceableExecutorService.java | 9 +-- .../TraceableScheduledExecutorService.java | 8 +-- .../tracing/spring/package-info.java | 2 +- main/tracing/pom.xml | 2 +- .../TracingMessagingContextManager.java | 2 +- ...sticactors.tracing.MessagingContextManager | 2 +- pom.xml | 2 +- 605 files changed, 852 insertions(+), 1494 deletions(-) diff --git a/bom/pom.xml b/bom/pom.xml index 6328d9d9..0aaa4612 100644 --- a/bom/pom.xml +++ b/bom/pom.xml @@ -1,6 +1,6 @@