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 2022/12/09 06:59:01 UTC
[incubator-eventmesh] branch master updated (7fb438e35 -> 50fecd43e)
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from 7fb438e35 Merge pull request #2418 from jonyangx/issue2308
new 2180fc877 fix issue 2306
new 75a0f1996 fix build error
new 36080de61 fix build error
new 8d1d3b4b5 Merge branch 'master' into issue2306
new 025af7425 fix build error
new b4c6c25ed fix build error
new 08793f2d8 Merge branch 'master' into issue2306
new 50fecd43e Merge pull request #2422 from jonyangx/issue2306
The 2745 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 | 193 ++++++++++++++++-----
.../common/config/ConfigurationWrapper.java | 38 ++--
.../common/exception/EventMeshException.java | 1 +
.../eventmesh/common/exception/JsonException.java | 2 +
.../eventmesh/common/file/WatchFileManager.java | 13 +-
.../eventmesh/common/file/WatchFileTask.java | 25 +--
.../loadbalance/RandomLoadBalanceSelector.java | 6 +-
.../eventmesh/common/loadbalance/Weight.java | 14 +-
.../WeightRandomLoadBalanceSelector.java | 15 +-
.../WeightRoundRobinLoadBalanceSelector.java | 10 +-
.../common/protocol/SubscriptionItem.java | 2 +
.../protocol/grpc/common/BatchMessageWrapper.java | 1 +
.../protocol/grpc/common/SimpleMessageWrapper.java | 2 +
.../common/protocol/http/HttpCommand.java | 2 +
.../common/protocol/http/HttpEventWrapper.java | 20 ++-
.../http/body/message/PushMessageRequestBody.java | 6 +-
.../http/body/message/ReplyMessageRequestBody.java | 6 +-
.../http/body/message/SendMessageRequestBody.java | 6 +-
.../http/header/client/HeartbeatRequestHeader.java | 2 +-
.../eventmesh/common/protocol/tcp/Command.java | 2 +-
.../eventmesh/common/protocol/tcp/Package.java | 38 +++-
.../eventmesh/common/protocol/tcp/codec/Codec.java | 30 ++--
.../common/utils/ConfigurationContextUtil.java | 2 +-
.../org/apache/eventmesh/common/utils/IPUtils.java | 18 +-
.../apache/eventmesh/common/utils/NetUtils.java | 2 +-
.../eventmesh/common/utils/PropertiesUtils.java | 5 +-
.../common/config/CommonConfigurationTest.java | 6 +-
.../common/utils/PropertiesUtilsTest.java | 4 +-
.../redis/config/ConfigurationWrapper.java | 4 +-
.../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 | 44 +++--
.../nacos/service/NacosRegistryServiceTest.java | 6 +-
.../service/ZookeeperRegistryService.java | 6 +-
.../service/ZookeeperRegistryServiceTest.java | 4 +-
.../handler/QueryRecommendEventMeshHandler.java | 2 +-
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 102 ++++++-----
.../runtime/boot/EventMeshGrpcServer.java | 15 +-
.../runtime/boot/EventMeshHTTPServer.java | 21 +--
.../eventmesh/runtime/boot/EventMeshServer.java | 28 +--
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 17 +-
.../protocol/grpc/consumer/EventMeshConsumer.java | 40 ++---
.../processor/BatchPublishMessageProcessor.java | 2 +-
.../grpc/processor/HeartbeatProcessor.java | 2 +-
.../grpc/processor/ReplyMessageProcessor.java | 2 +-
.../grpc/processor/RequestMessageProcessor.java | 2 +-
.../grpc/processor/SendAsyncMessageProcessor.java | 8 +-
.../grpc/processor/SubscribeProcessor.java | 2 +-
.../grpc/processor/SubscribeStreamProcessor.java | 2 +-
.../protocol/grpc/producer/EventMeshProducer.java | 6 +-
.../core/protocol/grpc/push/StreamPushRequest.java | 4 +-
.../protocol/grpc/push/WebhookPushRequest.java | 8 +-
.../protocol/http/consumer/EventMeshConsumer.java | 24 +--
.../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 | 21 ++-
.../processor/RemoteUnSubscribeEventProcessor.java | 17 +-
.../http/processor/ReplyMessageProcessor.java | 6 +-
.../http/processor/SendAsyncEventProcessor.java | 8 +-
.../http/processor/SendAsyncMessageProcessor.java | 13 +-
.../processor/SendAsyncRemoteEventProcessor.java | 127 +++++++-------
.../http/processor/SendSyncMessageProcessor.java | 11 +-
.../http/processor/SubscribeProcessor.java | 10 +-
.../http/processor/UnSubscribeProcessor.java | 6 +-
.../http/processor/inf/AbstractEventProcessor.java | 19 +-
.../protocol/http/producer/EventMeshProducer.java | 6 +-
.../http/push/AbstractHTTPPushRequest.java | 2 +-
.../protocol/http/push/AsyncHTTPPushRequest.java | 12 +-
.../tcp/client/EventMeshTcpMessageDispatcher.java | 10 +-
.../tcp/client/group/ClientGroupWrapper.java | 38 ++--
.../client/rebalance/EventmeshRebalanceImpl.java | 8 +-
.../client/recommend/EventMeshRecommendImpl.java | 6 +-
.../tcp/client/session/send/SessionSender.java | 75 ++++----
.../protocol/tcp/client/task/HeartBeatTask.java | 7 +-
.../core/protocol/tcp/client/task/HelloTask.java | 7 +-
.../tcp/client/task/MessageTransferTask.java | 119 ++++++-------
.../protocol/tcp/client/task/RecommendTask.java | 5 +-
.../protocol/tcp/client/task/SubscribeTask.java | 9 +-
.../QueryRecommendEventMeshHandlerTest.java | 7 +-
.../pinpoint/config/PinpointConfiguration.java | 3 +-
85 files changed, 833 insertions(+), 595 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org