This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a change to branch cpp_dev
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
discard f2fb51f BuildBuddy for Windows
add 14956ec Add misspell check action (#126)
add 6395d04 Fix typos (#128)
add e2a2fb5 Support codecov (#129)
add 9e6ca28 Remove coverage from readme (#130)
add 8bcec39 Add coverage GitHub Action (#134)
add 2f7be8a Using pull_request_target rather than pull_request to trigger
CI
add e7161e7 Trigger codecov on pull request (#138)
add d736334 Bump codecov-action to v3
add eb0d8f6 Enable carryforward for codecov
add 7d172d6 Add apache header for codecov.yml
add d9c544c Set path for codecov flag
add 68edd95 Bump codecov action to v3
add 693ddef Update path in codecov flag
add e9fea9a Update path in codecov config
add b049007 Delete redundant path in codecov (#143)
add da6eb7b Extract RPC status checker (#145)
add 7830691 Add more unit test (#146)
add 1a25089 Add more unit tests (#148)
add f5f56fc fix const SPAN_ATTRIBUTE_VALUE_MESSAGING_PROTOCOL_VERSION
(#149)
new fb4215b Add scheduler test
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (f2fb51f)
\
N -- N -- N refs/heads/cpp_dev (fb4215b)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 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:
cpp/tools/use_clang.sh => .codecov.yml | 11 +-
.github/workflows/cpp_build.yml | 6 +-
.github/workflows/cpp_coverage.yml | 21 +
.github/workflows/java_coverage.yml | 33 ++
.../{license-checker.yaml => license_checker.yaml} | 3 +-
.github/workflows/misspell_check.yaml | 18 +
cpp/proto/apache/rocketmq/v2/definition.proto | 2 +-
cpp/source/base/MixAll.cpp | 2 +-
cpp/source/rocketmq/ProducerImpl.cpp | 2 +-
.../{concurrent => scheduler}/tests/BUILD.bazel | 12 +-
cpp/source/scheduler/tests/SchedulerTest.cpp | 149 ++++++
.../Protos/apache/rocketmq/v2/definition.proto | 2 +-
docs/design.md | 4 +-
docs/workflow.md | 2 +-
golang/protocol/v2/definition.pb.go | 2 +-
...xception.java => PaymentRequiredException.java} | 7 +-
.../StatusChecker.java} | 84 +--
.../rocketmq/client/java/impl/ClientImpl.java | 89 +---
.../client/java/impl/ClientManagerImpl.java | 47 +-
.../client/java/impl/ClientSessionImpl.java | 27 +-
.../impl/{ClientSettings.java => Settings.java} | 20 +-
.../client/java/impl/consumer/ConsumerImpl.java | 35 +-
.../java/impl/consumer/ProcessQueueImpl.java | 2 +-
.../java/impl/consumer/PushConsumerImpl.java | 66 +--
...Settings.java => PushSubscriptionSettings.java} | 29 +-
.../java/impl/consumer/ReceiveMessageResult.java | 46 +-
.../java/impl/consumer/SimpleConsumerImpl.java | 85 +---
...ttings.java => SimpleSubscriptionSettings.java} | 34 +-
.../java/impl/producer/ClientSessionHandler.java | 6 -
.../client/java/impl/producer/ProducerImpl.java | 88 ++--
...oducerSettings.java => PublishingSettings.java} | 23 +-
.../client/java/impl/producer/SendReceiptImpl.java | 73 +--
.../client/java/impl/producer/TransactionImpl.java | 10 +-
.../client/java/message/PublishingMessageImpl.java | 11 +-
.../client/java/message/protocol/Resource.java | 12 +-
.../rocketmq/client/java/misc/Utilities.java | 14 +-
.../java/retry/CustomizedBackoffRetryPolicy.java | 10 +-
.../java/retry/ExponentialBackoffRetryPolicy.java | 18 +-
.../rocketmq/client/java/retry/RetryPolicy.java | 5 +-
.../client/java/exception/StatusCheckerTest.java | 564 +++++++++++++++++++++
.../client/java/impl/ClientManagerImplTest.java | 5 +-
.../java/impl/consumer/ConsumeServiceTest.java | 114 +++++
.../client/java/impl/consumer/ConsumeTaskTest.java | 55 ++
.../java/impl/consumer/ConsumerImplTest.java | 123 +++++
...erviceTest.java => FifoConsumeServiceTest.java} | 36 +-
.../java/impl/consumer/ProcessQueueImplTest.java | 25 +-
.../impl/consumer/PushConsumerBuilderImplTest.java | 4 +-
.../java/impl/consumer/PushConsumerImplTest.java | 4 +-
.../consumer/PushSubscriptionSettingsTest.java | 120 +++++
.../impl/consumer/SimpleConsumerBuilderTest.java | 4 +-
.../java/impl/consumer/SimpleConsumerImplTest.java | 20 +-
.../consumer/SimpleSubscriptionSettingsTest.java | 94 ++++
.../impl/consumer/StandardConsumeServiceTest.java | 10 +-
.../impl/producer/ProducerBuilderImplTest.java | 35 ++
.../java/impl/producer/ProducerImplTest.java | 184 ++-----
.../java/impl/producer/TransactionImplTest.java | 93 ++++
.../protocol/EncodingTest.java} | 34 +-
.../client/java/message/protocol/ResourceTest.java | 54 ++
.../rocketmq/client/java/misc/UtilitiesTest.java | 64 +++
.../retry/CustomizedBackoffRetryPolicyTest.java | 101 +++-
.../retry/ExponentialBackoffRetryPolicyTest.java | 152 ++++++
.../apache/rocketmq/client/java/tool/TestBase.java | 16 +-
java/pom.xml | 45 ++
java/style/spotbugs-suppressions.xml | 8 +-
rust/proto/apache/rocketmq/v2/definition.proto | 2 +-
65 files changed, 2317 insertions(+), 759 deletions(-)
copy cpp/tools/use_clang.sh => .codecov.yml (86%)
mode change 100755 => 100644
create mode 100644 .github/workflows/cpp_coverage.yml
create mode 100644 .github/workflows/java_coverage.yml
rename .github/workflows/{license-checker.yaml => license_checker.yaml} (93%)
create mode 100644 .github/workflows/misspell_check.yaml
copy cpp/source/{concurrent => scheduler}/tests/BUILD.bazel (80%)
create mode 100644 cpp/source/scheduler/tests/SchedulerTest.cpp
copy
java/client/src/main/java/org/apache/rocketmq/client/java/exception/{UnsupportedException.java
=> PaymentRequiredException.java} (82%)
copy
java/client/src/main/java/org/apache/rocketmq/client/java/{impl/consumer/ReceiveMessageResult.java
=> exception/StatusChecker.java} (50%)
rename
java/client/src/main/java/org/apache/rocketmq/client/java/impl/{ClientSettings.java
=> Settings.java} (73%)
rename
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/{PushConsumerSettings.java
=> PushSubscriptionSettings.java} (83%)
rename
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/{SimpleConsumerSettings.java
=> SimpleSubscriptionSettings.java} (76%)
rename
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/{ProducerSettings.java
=> PublishingSettings.java} (83%)
create mode 100644
java/client/src/test/java/org/apache/rocketmq/client/java/exception/StatusCheckerTest.java
create mode 100644
java/client/src/test/java/org/apache/rocketmq/client/java/impl/consumer/ConsumeServiceTest.java
create mode 100644
java/client/src/test/java/org/apache/rocketmq/client/java/impl/consumer/ConsumeTaskTest.java
create mode 100644
java/client/src/test/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImplTest.java
copy
java/client/src/test/java/org/apache/rocketmq/client/java/impl/consumer/{StandardConsumeServiceTest.java
=> FifoConsumeServiceTest.java} (68%)
create mode 100644
java/client/src/test/java/org/apache/rocketmq/client/java/impl/consumer/PushSubscriptionSettingsTest.java
create mode 100644
java/client/src/test/java/org/apache/rocketmq/client/java/impl/consumer/SimpleSubscriptionSettingsTest.java
copy
java/client/src/test/java/org/apache/rocketmq/client/java/{impl/producer/TransactionImplTest.java
=> message/protocol/EncodingTest.java} (50%)
create mode 100644
java/client/src/test/java/org/apache/rocketmq/client/java/message/protocol/ResourceTest.java
create mode 100644
java/client/src/test/java/org/apache/rocketmq/client/java/misc/UtilitiesTest.java
create mode 100644
java/client/src/test/java/org/apache/rocketmq/client/java/retry/ExponentialBackoffRetryPolicyTest.java
