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 09:37:36 UTC
[incubator-eventmesh] branch master updated (8835cb252 -> 728e0c60a)
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
omit 8835cb252 fix issue2384 (#2407)
omit 1ff7ae8fa Update .asf.yaml (#2410)
omit ecadb8851 Merge pull request #2309 from jonyangx/example_pmd_error
omit b3bf128b3 Merge branch 'master' into example_pmd_error
omit eefc93dde Merge branch 'master' into example_pmd_error
omit 160df68fc Merge branch 'master' into example_pmd_error
omit cc324979d fix check dependency error
omit 1ba356554 remove qmq feature
omit 9fbc7f453 fix conflict
omit 1d86538ac Merge branch 'master' into example_pmd_error
omit c33213d81 remove qmq feature
omit 531ae0267 merge conflict
omit bca565a54 fix security issues
omit e97df8b93 [ISSUE #2349] Method encodes String bytes without specifying the character encoding (#2351)
omit 315b83c57 fix issue2238
omit 46ea3bcc7 fix issue 2341
omit 162b3d958 fixed ISSUE #2331 metrics in TCP will not be reset to zero
omit 1b5f93ad1 Simplify CloudEventUtils code (#2323)
omit 541b0f785 Simplify spi usage
omit 1f3fae29e remove deprecated methods (#2328)
omit c4ba34929 [ISSUE #2317] Refactoring tool class JsonUtils (#2318)
omit 37472bc7e Unified Versioning
omit 1e7895a6b fix security issues
omit 30160ef5f [ISSUE #2349] Method encodes String bytes without specifying the character encoding (#2351)
omit 91dc38f46 Merge remote-tracking branch 'upstream/master'
omit 6390a74b8 Merge remote-tracking branch 'upstream/master'
omit 91bfb5479 Merge branch 'master' into example_pmd_error
omit 7a714f2cc merge master
omit e7ac15075 Change to try-with-resources to manage resources
omit 45d8bf04b fix miss spelling
omit ed6844a88 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
omit 43c77aaab upgrade nacos version and remove go-lexer dependency
omit c308a4a95 add encode
omit f90283d31 fix_encoding
omit 0028c1b66 update new-contributor-guidelines
omit 3afc3e0f4 update new-contributor-guidelines
omit e49dc2bef modify comment
omit 4bd9838b0 add file license header
omit e836607a7 add workflow run scripts
omit 1f8575866 remove sync try-with-resources
omit 9ad47ee8c [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
omit 0e0b0e0ec remove sync try-with-resources
omit 3c1f849d2 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
omit e18af2ce6 Change to try-with-resources to manage resources
omit 545f49b4a merge remote
omit 9bb82b0e3 add gradle jvm parameter
omit 5c908b72f merge master
omit 2df2be2df Change to try-with-resources to manage resources
omit 8ca048e19 fix miss spelling
omit a6c760307 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
omit 87fac63be upgrade nacos version and remove go-lexer dependency
omit 0a040f0d2 add encode
omit 276117f35 fix_encoding
omit cdb8f661f add file license header
omit ce7c12da3 add workflow run scripts
omit 90293103f remove sync try-with-resources
omit 101a49bdf [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
omit 3d4c168a9 fix miss spelling
omit cb875939b [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
omit 92057a430 modify checkstytle warn
omit 308cbfdb8 modify checkstytle warn
omit 1e5f91961 add opentracing license
omit aaca4aea5 modify mkdir add -p parameter
omit 41c03c509 add license
omit dc4d0c59f modify license
omit 3d65e36d7 bug fix id_snake_test
omit 35c789346 add qmq connector
omit b2a6d42df Unified Dependency Management
omit 36497a3b4 Enhancement
omit 0f63d9628 add test assert (#2292)
omit 2771bf667 Refactoring tool class NetUtils (#2316)
omit 94e5f82f8 fix build error
omit eb248afc9 fix build error
omit 589d458c2 fix buiild error
omit b5dce6bea fix common module pmd test error
omit 4b7929fb6 [ISSUE #2243] Change Boolean to boolean in NacosWebHookConfigOperation (#2290)
omit 6da877a60 [ISSUE #2297] Unified eventmesh-common dependency versioning (#2298)
omit 25976be16 Refactoring code
omit 3aadefdc3 rename Assert to AssertUtils
omit 2ab93e6c5 add Licensed
omit cb8df8f21 Simplify the code
omit 2a9c4d4f0 fix common module pmd test error
omit 7c3fe49a6 Merge remote-tracking branch 'upstream/master'
omit b523f2698 merge upgrade gradle to 7.6
omit 09722e86e merge upstream/master
omit 9a39dd035 Merge remote-tracking branch 'upstream/master'
omit 7892037df Merge remote-tracking branch 'upstream/master'
omit 77331a779 Merge branch 'master' of https://github.com/jonyangx/incubator-eventmesh
omit b2d87e778 Merge remote-tracking branch 'upstream/master'
omit e290d6993 Merge remote-tracking branch 'upstream/master'
omit a450faf13 Merge remote-tracking branch 'upstream/master'
omit 5bbd4297e Merge remote-tracking branch 'origin/build_error'
omit 3a1a93b9f Merge remote-tracking branch 'upstream/master'
omit e8c449e5f add gradle jvm parameter
omit ef42b48bd merge master
omit 7de980be7 Change to try-with-resources to manage resources
omit 4c0bde82b fix miss spelling
omit 5d786f7e4 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
omit 22c108cd4 Merge remote-tracking branch 'upstream/master'
omit 6c44c57ed Merge branch 'master' into develop
omit 66c720df7 Update EventMeshConsumer.java
omit d979d4499 Method stores return result in local before immediately returning it [EventMeshRecommendImpl]
omit 24d88fc38 upgrade nacos version and remove go-lexer dependency
omit ebbf8e007 upgrade nacos version and remove go-lexer dependency
omit 27a478bed add encode
omit 658f4bdd6 fix_encoding
omit 5abcd4409 fix_encoding
omit 7762aa555 optise list empty check for issue #2169
omit 4d07eb686 update new-contributor-guidelines
omit 873a09f8b update new-contributor-guidelines
omit 274af9e0a return the value assigned by the local variable directly
omit ee2fb51ce Update RedirectClientByPathHandler.java
omit 0ba10ee0d issue 2163
omit e552b4d6a Update ConsumerManager.java
omit 97afcd9e3 Update RedirectClientByIpPortHandler.java
omit 2eed20124 Update RedirectClientByIpPortHandler.java
omit 9f48f05c6 Update RedirectClientByIpPortHandler.java
omit bb8cbf500 modify checkstyle
omit ffc8f65d9 fix webhook NPE
omit 5cd2cfbc1 modify comment
omit 94c1cede3 add file license header
omit 3e2282ab2 add workflow run scripts
omit 6a853ebf6 remove sync try-with-resources
omit ad83e9e65 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
omit e510588d7 Change to try-with-resources to manage resources
omit 9774e0a57 [ISSUE #2145] Update the LICENSE file
omit 6cd790255 remove sync try-with-resources
omit 863a8f3aa remove try-with-resources
omit a7b024bf4 Update ShowClientHandler.java
omit 03570af4e fix miss spelling
omit 64941e801 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
omit a17962f01 [ISSUE #2130] Add third-party licenses
omit e7d99426d Update roadmap.md
omit 0d7d8894a Merge remote-tracking branch 'upstream/master'
omit d50c4b78e Merge remote-tracking branch 'upstream/master'
omit 7874f7450 Change to try-with-resources to manage resources
omit 76e63edd1 [ISSUE #2145] Update the LICENSE file
omit ae2118e7c remove sync try-with-resources
omit 9cc359462 remove try-with-resources
omit b6aa4c62b Update ShowClientHandler.java
omit 245c93062 fix miss spelling
omit a4b2fcd49 [ISSUE #2136] Remove the try-with-resource at [cloudevents/SyncRequest]
omit bfefb473c [ISSUE #2130] Add third-party licenses
omit b56e55f9e Update roadmap.md
omit 081401a3b Merge branch 'master' into master
omit be72652e2 Merge branch 'master' into develop
omit 73215c89f modify checkstytle warn
omit 27f2b95ca modify checkstytle warn
omit edae0333f add opentracing license
omit 8d511f113 modify mkdir add -p parameter
omit cbf0f8e44 add license
omit 5eaba310b modify license
omit 36c401204 Merge remote-tracking branch 'upstream/master'
omit c5eee8947 bug fix id_snake_test
omit 9b9a6db07 Merge remote-tracking branch 'upstream/master'
omit 058e415a3 add qmq connector
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/master (728e0c60a)
\
O -- O -- O (8835cb252)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 2 +-
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 +-
.../http/resolver/HttpRequestProtocolResolver.java | 14 +-
.../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 +
.../trace/api}/TracePluginFactoryTest.java | 4 +-
.../pinpoint/config/PinpointConfiguration.java | 5 +-
.../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 +-
.../licenses/java/LICENSE-opentracing-api.txt | 201 ---------------------
.../licenses/java/LICENSE-opentracing-noop.txt | 201 ---------------------
.../licenses/java/LICENSE-opentracing-util.txt | 201 ---------------------
.../licenses/java/LICENSE-qmq.txt | 201 ---------------------
138 files changed, 1022 insertions(+), 2165 deletions(-)
rename eventmesh-trace-plugin/{eventmesh-trace-zipkin/src/test/java/org/apache/eventmesh/trace/zipkin => eventmesh-trace-api/src/test/java/org/apache/eventmesh/trace/api}/TracePluginFactoryTest.java (92%)
delete mode 100644 tools/third-party-licenses/licenses/java/LICENSE-opentracing-api.txt
delete mode 100644 tools/third-party-licenses/licenses/java/LICENSE-opentracing-noop.txt
delete mode 100644 tools/third-party-licenses/licenses/java/LICENSE-opentracing-util.txt
delete mode 100644 tools/third-party-licenses/licenses/java/LICENSE-qmq.txt
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org