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/02 08:35:45 UTC
[incubator-eventmesh] branch master updated (728e0c60a -> ecadb8851)
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 728e0c60a Merge pull request #2400 from MajorHe1/MajorHe1-patch-9
new 2a9c4d4f0 fix common module pmd test error
new cb8df8f21 Simplify the code
new 2ab93e6c5 add Licensed
new 3aadefdc3 rename Assert to AssertUtils
new 25976be16 Refactoring code
new 6da877a60 [ISSUE #2297] Unified eventmesh-common dependency versioning (#2298)
new 4b7929fb6 [ISSUE #2243] Change Boolean to boolean in NacosWebHookConfigOperation (#2290)
new b5dce6bea fix common module pmd test error
new 589d458c2 fix buiild error
new eb248afc9 fix build error
new 94e5f82f8 fix build error
new 2771bf667 Refactoring tool class NetUtils (#2316)
new 0f63d9628 add test assert (#2292)
new 36497a3b4 Enhancement
new b2a6d42df Unified Dependency Management
new 35c789346 add qmq connector
new 3d65e36d7 bug fix id_snake_test
new dc4d0c59f modify license
new 41c03c509 add license
new aaca4aea5 modify mkdir add -p parameter
new 1e5f91961 add opentracing license
new 308cbfdb8 modify checkstytle warn
new 92057a430 modify checkstytle warn
new cb875939b [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
new 3d4c168a9 fix miss spelling
new 101a49bdf [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
new 90293103f remove sync try-with-resources
new ce7c12da3 add workflow run scripts
new cdb8f661f add file license header
new 276117f35 fix_encoding
new 0a040f0d2 add encode
new 87fac63be upgrade nacos version and remove go-lexer dependency
new a6c760307 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
new 8ca048e19 fix miss spelling
new 2df2be2df Change to try-with-resources to manage resources
new 5c908b72f merge master
new 9bb82b0e3 add gradle jvm parameter
new 545f49b4a merge remote
new e18af2ce6 Change to try-with-resources to manage resources
new 3c1f849d2 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
new 0e0b0e0ec remove sync try-with-resources
new 9ad47ee8c [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
new 1f8575866 remove sync try-with-resources
new e836607a7 add workflow run scripts
new 4bd9838b0 add file license header
new e49dc2bef modify comment
new 3afc3e0f4 update new-contributor-guidelines
new 0028c1b66 update new-contributor-guidelines
new f90283d31 fix_encoding
new c308a4a95 add encode
new 43c77aaab upgrade nacos version and remove go-lexer dependency
new ed6844a88 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
new 45d8bf04b fix miss spelling
new e7ac15075 Change to try-with-resources to manage resources
new 7a714f2cc merge master
new 91bfb5479 Merge branch 'master' into example_pmd_error
new 37472bc7e Unified Versioning
new c4ba34929 [ISSUE #2317] Refactoring tool class JsonUtils (#2318)
new 1f3fae29e remove deprecated methods (#2328)
new 541b0f785 Simplify spi usage
new 1b5f93ad1 Simplify CloudEventUtils code (#2323)
new 162b3d958 fixed ISSUE #2331 metrics in TCP will not be reset to zero
new 46ea3bcc7 fix issue 2341
new 315b83c57 fix issue2238
new e97df8b93 [ISSUE #2349] Method encodes String bytes without specifying the character encoding (#2351)
new bca565a54 fix security issues
new 531ae0267 merge conflict
new c33213d81 remove qmq feature
new 1d86538ac Merge branch 'master' into example_pmd_error
new 058e415a3 add qmq connector
new 9b9a6db07 Merge remote-tracking branch 'upstream/master'
new c5eee8947 bug fix id_snake_test
new 36c401204 Merge remote-tracking branch 'upstream/master'
new 5eaba310b modify license
new cbf0f8e44 add license
new 8d511f113 modify mkdir add -p parameter
new edae0333f add opentracing license
new 27f2b95ca modify checkstytle warn
new 73215c89f modify checkstytle warn
new 081401a3b Merge branch 'master' into master
new b56e55f9e Update roadmap.md
new bfefb473c [ISSUE #2130] Add third-party licenses
new a4b2fcd49 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
new 245c93062 fix miss spelling
new b6aa4c62b Update ShowClientHandler.java
new 9cc359462 remove try-with-resources
new ae2118e7c remove sync try-with-resources
new 76e63edd1 [ISSUE #2145] Update the LICENSE file
new 7874f7450 Change to try-with-resources to manage resources
new d50c4b78e Merge remote-tracking branch 'upstream/master'
new 0d7d8894a Merge remote-tracking branch 'upstream/master'
new 22c108cd4 Merge remote-tracking branch 'upstream/master'
new 3a1a93b9f Merge remote-tracking branch 'upstream/master'
new be72652e2 Merge branch 'master' into develop
new e7d99426d Update roadmap.md
new a17962f01 [ISSUE #2130] Add third-party licenses
new 64941e801 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
new 03570af4e fix miss spelling
new a7b024bf4 Update ShowClientHandler.java
new 863a8f3aa remove try-with-resources
new 6cd790255 remove sync try-with-resources
new 9774e0a57 [ISSUE #2145] Update the LICENSE file
new e510588d7 Change to try-with-resources to manage resources
new ad83e9e65 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
new 6a853ebf6 remove sync try-with-resources
new 3e2282ab2 add workflow run scripts
new 94c1cede3 add file license header
new 5cd2cfbc1 modify comment
new ffc8f65d9 fix webhook NPE
new bb8cbf500 modify checkstyle
new 9f48f05c6 Update RedirectClientByIpPortHandler.java
new 2eed20124 Update RedirectClientByIpPortHandler.java
new 97afcd9e3 Update RedirectClientByIpPortHandler.java
new e552b4d6a Update ConsumerManager.java
new 0ba10ee0d issue 2163
new ee2fb51ce Update RedirectClientByPathHandler.java
new 274af9e0a return the value assigned by the local variable directly
new 873a09f8b update new-contributor-guidelines
new 4d07eb686 update new-contributor-guidelines
new 7762aa555 optise list empty check for issue #2169
new 5abcd4409 fix_encoding
new 658f4bdd6 fix_encoding
new 27a478bed add encode
new ebbf8e007 upgrade nacos version and remove go-lexer dependency
new 24d88fc38 upgrade nacos version and remove go-lexer dependency
new d979d4499 Method stores return result in local before immediately returning it [EventMeshRecommendImpl]
new 66c720df7 Update EventMeshConsumer.java
new 6c44c57ed Merge branch 'master' into develop
new 5d786f7e4 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
new 4c0bde82b fix miss spelling
new 7de980be7 Change to try-with-resources to manage resources
new ef42b48bd merge master
new e8c449e5f add gradle jvm parameter
new 5bbd4297e Merge remote-tracking branch 'origin/build_error'
new b2d87e778 Merge remote-tracking branch 'upstream/master'
new a450faf13 Merge remote-tracking branch 'upstream/master'
new e290d6993 Merge remote-tracking branch 'upstream/master'
new 77331a779 Merge branch 'master' of https://github.com/jonyangx/incubator-eventmesh
new 7892037df Merge remote-tracking branch 'upstream/master'
new 9a39dd035 Merge remote-tracking branch 'upstream/master'
new 09722e86e merge upstream/master
new b523f2698 merge upgrade gradle to 7.6
new 7c3fe49a6 Merge remote-tracking branch 'upstream/master'
new 6390a74b8 Merge remote-tracking branch 'upstream/master'
new 91dc38f46 Merge remote-tracking branch 'upstream/master'
new 30160ef5f [ISSUE #2349] Method encodes String bytes without specifying the character encoding (#2351)
new 1e7895a6b fix security issues
new 9fbc7f453 fix conflict
new 1ba356554 remove qmq feature
new cc324979d fix check dependency error
new 160df68fc Merge branch 'master' into example_pmd_error
new eefc93dde Merge branch 'master' into example_pmd_error
new b3bf128b3 Merge branch 'master' into example_pmd_error
new ecadb8851 Merge pull request #2309 from jonyangx/example_pmd_error
The 2649 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:
build.gradle | 2 +-
.../zh/contribute/03-new-contributor-guidelines.md | 14 ++
.../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 | 3 +-
.../eventmesh/common/utils/PropertiesUtils.java | 5 +-
.../common/config/CommonConfigurationTest.java | 6 +-
.../common/utils/PropertiesUtilsTest.java | 4 +-
.../redis/config/ConfigurationWrapper.java | 5 +-
.../CloudEventsBatchPublishInstance.java | 53 +++---
.../cloudevents/CloudEventsPublishInstance.java | 51 +++---
.../cloudevents/CloudEventsRequestInstance.java | 51 +++---
.../eventmeshmessage/AsyncPublishBroadcast.java | 47 ++---
.../pub/eventmeshmessage/AsyncPublishInstance.java | 47 ++---
.../pub/eventmeshmessage/BatchPublishInstance.java | 49 +++---
.../pub/eventmeshmessage/RequestReplyInstance.java | 47 ++---
.../WorkflowAsyncPublishInstance.java | 58 ++++---
.../grpc/sub/CloudEventsAsyncSubscribe.java | 23 +--
.../grpc/sub/CloudEventsSubscribeReply.java | 23 +--
.../grpc/sub/EventmeshAsyncSubscribe.java | 23 +--
.../grpc/sub/EventmeshSubscribeBroadcast.java | 23 +--
.../grpc/sub/EventmeshSubscribeReply.java | 23 +--
.../grpc/sub/WorkflowExpressAsyncSubscribe.java | 56 +++---
.../grpc/sub/WorkflowOrderAsyncSubscribe.java | 56 +++---
.../grpc/sub/WorkflowPaymentAsyncSubscribe.java | 56 +++---
.../eventmeshmessage/AsyncSyncRequestInstance.java | 20 ++-
.../http/demo/sub/controller/SubController.java | 3 +-
.../http/demo/sub/service/SubService.java | 54 +++---
.../apache/eventmesh/selector/NacosSelector.java | 15 +-
.../eventmesh/tcp/common/EventMeshTestUtils.java | 14 +-
.../tcp/demo/pub/cloudevents/SyncRequest.java | 1 +
.../main/java/org/apache/eventmesh/util/Utils.java | 16 +-
.../metrics/api/model/TcpSummaryMetrics.java | 21 ++-
.../prometheus/PrometheusMetricsRegistry.java | 8 +-
.../prometheus/config/PrometheusConfiguration.java | 11 +-
.../prometheus/metrics/PrometheusGrpcExporter.java | 5 +-
.../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 | 53 +++---
.../service/ZookeeperRegistryServiceTest.java | 6 +-
.../admin/controller/ClientManageController.java | 19 +-
.../handler/QueryRecommendEventMeshHandler.java | 2 +-
.../handler/ShowListenClientByTopicHandler.java | 1 +
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 2 +-
.../runtime/boot/EventMeshGrpcServer.java | 15 +-
.../runtime/boot/EventMeshHTTPServer.java | 85 ++++-----
.../eventmesh/runtime/boot/EventMeshServer.java | 28 +--
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 16 +-
.../apache/eventmesh/runtime/boot/HTTPTrace.java | 16 +-
.../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 | 72 ++++----
.../processor/RemoteUnSubscribeEventProcessor.java | 64 +++----
.../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 +-
.../protocol/http/processor/WebHookProcessor.java | 7 +-
.../http/processor/inf/AbstractEventProcessor.java | 14 +-
.../protocol/http/producer/EventMeshProducer.java | 6 +-
.../http/push/AbstractHTTPPushRequest.java | 2 +-
.../protocol/http/push/AsyncHTTPPushRequest.java | 100 +++++------
.../tcp/client/EventMeshTcpMessageDispatcher.java | 4 +-
.../tcp/client/group/ClientGroupWrapper.java | 24 +--
.../group/dispatch/DownstreamDispatchStrategy.java | 2 +-
.../client/rebalance/EventmeshRebalanceImpl.java | 8 +-
.../client/recommend/EventMeshRecommendImpl.java | 6 +-
.../core/protocol/tcp/client/session/Session.java | 74 ++++----
.../tcp/client/session/send/SessionSender.java | 7 +-
.../protocol/tcp/client/task/HeartBeatTask.java | 4 +-
.../core/protocol/tcp/client/task/HelloTask.java | 4 +-
.../tcp/client/task/MessageTransferTask.java | 11 +-
.../protocol/tcp/client/task/RecommendTask.java | 2 +-
.../protocol/tcp/client/task/SubscribeTask.java | 5 +-
.../eventmesh/runtime/util/EventMeshUtil.java | 4 +-
.../QueryRecommendEventMeshHandlerTest.java | 11 +-
eventmesh-sdk-go/common/id/id_snake_test.go | 10 +-
.../eventmesh/api/common/ConfigurationWrapper.java | 6 +-
.../eventmesh-trace-api/build.gradle | 1 -
.../pinpoint/config/PinpointConfiguration.java | 5 +-
.../trace/zipkin}/TracePluginFactoryTest.java | 4 +-
.../webhook/receive/WebHookController.java | 7 +-
.../eventmesh/webhook/receive/WebHookRequest.java | 53 +++++-
.../webhook/receive/protocol/GithubProtocol.java | 5 +-
eventmesh-workflow-go/go.sum | 11 ++
gradle.properties | 3 +-
settings.gradle | 7 +
tools/dependency-check/check-dependencies.sh | 2 +-
.../LICENSE-opentracing-api.txt} | 0
.../LICENSE-opentracing-noop.txt} | 0
.../LICENSE-opentracing-util.txt} | 0
.../LICENSE-qmq.txt} | 2 +-
136 files changed, 1354 insertions(+), 1015 deletions(-)
rename eventmesh-trace-plugin/{eventmesh-trace-api/src/test/java/org/apache/eventmesh/trace/api => eventmesh-trace-zipkin/src/test/java/org/apache/eventmesh/trace/zipkin}/TracePluginFactoryTest.java (92%)
copy tools/third-party-licenses/licenses/{go/LICENSE-github.com-envoyproxy-go-control-plane.txt => java/LICENSE-opentracing-api.txt} (100%)
copy tools/third-party-licenses/licenses/{go/LICENSE-github.com-envoyproxy-go-control-plane.txt => java/LICENSE-opentracing-noop.txt} (100%)
copy tools/third-party-licenses/licenses/{go/LICENSE-github.com-envoyproxy-go-control-plane.txt => java/LICENSE-opentracing-util.txt} (100%)
copy tools/third-party-licenses/licenses/{go/LICENSE-go.opentelemetry.io-proto-otlp.txt => java/LICENSE-qmq.txt} (99%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org