You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2023/01/11 01:50:56 UTC
[incubator-eventmesh] branch config-manage-improve updated (4c67dcd6b -> e8215b82e)
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: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org