This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch config-manage-improve
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from 4c67dcd6b Merge pull request #2861 from eight-nines/MR2
new 68a727c6f Change the configuration management class
CommonConfiguration to a new framework
new 1cb1c1d0f Change CommonConfiguration subclass to new framework
new e8215b82e Merge pull request #2896 from eight-nines/MR2
The 2517 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../common/config/CommonConfiguration.java | 219 ++++----------
.../eventmesh/common/config/ConfigService.java | 10 +-
.../common/config/ConfigurationWrapper.java | 49 ----
.../config/convert/converter/ObjectConverter.java | 2 +-
.../common/config/CommonConfigurationTest.java | 56 +++-
.../eventmesh/common/config/ConfigServiceTest.java | 70 -----
.../common/config/ConfigurationWrapperTest.java | 48 ----
.../common/utils/PropertiesUtilsTest.java | 13 +-
.../src/test/resources/configuration.properties | 35 ++-
.../resources/newConfiguration-common.properties | 37 ---
.../consul/service/ConsulRegistryService.java | 2 +-
.../src/test/java/ConsulRegistryServiceTest.java | 2 +-
.../registry/etcd/service/EtcdRegistryService.java | 8 +-
.../etcd/service/EtcdRegistryServiceTest.java | 2 +-
.../nacos/service/NacosRegistryService.java | 21 +-
.../nacos/service/NacosRegistryServiceTest.java | 6 +-
.../service/ZookeeperRegistryService.java | 6 +-
.../service/ZookeeperRegistryServiceTest.java | 4 +-
.../handler/QueryRecommendEventMeshHandler.java | 2 +-
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 2 +-
.../runtime/boot/EventMeshGrpcServer.java | 14 +-
.../runtime/boot/EventMeshHTTPServer.java | 22 +-
.../eventmesh/runtime/boot/EventMeshServer.java | 28 +-
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 16 +-
.../configuration/EventMeshGrpcConfiguration.java | 193 +------------
.../configuration/EventMeshHTTPConfiguration.java | 314 +--------------------
.../configuration/EventMeshTCPConfiguration.java | 179 +-----------
.../protocol/grpc/consumer/EventMeshConsumer.java | 12 +-
.../processor/BatchPublishMessageProcessor.java | 2 +-
.../grpc/processor/HeartbeatProcessor.java | 2 +-
.../grpc/processor/ReplyMessageProcessor.java | 2 +-
.../grpc/processor/RequestMessageProcessor.java | 2 +-
.../grpc/processor/SendAsyncMessageProcessor.java | 2 +-
.../grpc/processor/SubscribeProcessor.java | 2 +-
.../grpc/processor/SubscribeStreamProcessor.java | 2 +-
.../protocol/grpc/producer/EventMeshProducer.java | 6 +-
.../core/protocol/grpc/push/StreamPushRequest.java | 2 +-
.../protocol/grpc/push/WebhookPushRequest.java | 8 +-
.../protocol/http/consumer/EventMeshConsumer.java | 16 +-
.../http/processor/BatchSendMessageProcessor.java | 8 +-
.../processor/BatchSendMessageV2Processor.java | 8 +-
.../http/processor/HeartBeatProcessor.java | 8 +-
.../processor/LocalSubscribeEventProcessor.java | 10 +-
.../processor/LocalUnSubscribeEventProcessor.java | 6 +-
.../processor/RemoteSubscribeEventProcessor.java | 18 +-
.../processor/RemoteUnSubscribeEventProcessor.java | 14 +-
.../http/processor/ReplyMessageProcessor.java | 6 +-
.../http/processor/SendAsyncEventProcessor.java | 8 +-
.../http/processor/SendAsyncMessageProcessor.java | 10 +-
.../processor/SendAsyncRemoteEventProcessor.java | 22 +-
.../http/processor/SendSyncMessageProcessor.java | 8 +-
.../http/processor/SubscribeProcessor.java | 10 +-
.../http/processor/UnSubscribeProcessor.java | 6 +-
.../http/processor/inf/AbstractEventProcessor.java | 10 +-
.../protocol/http/producer/EventMeshProducer.java | 6 +-
.../http/push/AbstractHTTPPushRequest.java | 2 +-
.../protocol/http/push/AsyncHTTPPushRequest.java | 10 +-
.../tcp/client/EventMeshTcpMessageDispatcher.java | 4 +-
.../tcp/client/group/ClientGroupWrapper.java | 27 +-
.../client/rebalance/EventmeshRebalanceImpl.java | 8 +-
.../client/recommend/EventMeshRecommendImpl.java | 6 +-
.../tcp/client/session/send/SessionSender.java | 2 +-
.../protocol/tcp/client/task/HeartBeatTask.java | 2 +-
.../core/protocol/tcp/client/task/HelloTask.java | 2 +-
.../tcp/client/task/MessageTransferTask.java | 9 +-
.../protocol/tcp/client/task/RecommendTask.java | 2 +-
.../protocol/tcp/client/task/SubscribeTask.java | 2 +-
.../QueryRecommendEventMeshHandlerTest.java | 12 +-
.../runtime/boot/EventMeshServerTest.java | 39 ++-
...runtime.properties => configuration.properties} | 1 +
70 files changed, 399 insertions(+), 1305 deletions(-)
delete mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/config/ConfigServiceTest.java
delete mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/config/ConfigurationWrapperTest.java
delete mode 100644
eventmesh-common/src/test/resources/newConfiguration-common.properties
rename
eventmesh-runtime/src/test/resources/{newConfiguration-runtime.properties =>
configuration.properties} (98%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
