This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a change to branch java_dev
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
discard fcaca09 WiP
omit 3c510bf Bugfix: forget to start clientManager
add 4afbcb5 Bugfix: forget to start clientManager (#56)
add 2e179a2 Bump rocketmq-proto to 2.0.0 (#57)
add ad90d2f Polish code
add 4d059b3 Fix unit test in java (#60)
add f6fdbbd Sync client settings every 5 minutes (#59)
add ab9353d Bump jacoco to 0.8.8 (#62)
add aaad80d Merge changes from upstream (#61)
add 3cb7fbe Add new label(consumerGroup) for the metrics of consumer (#63)
add 8202ef8 Do not check body size in MessageBuilderImpl#setBody (#64)
add 8d873be Using default aggregationTemporalitySelector (#67)
add 739f754 Prepare to sync examples (#66)
add d0fa7a3 Support license checker (#65)
add d1b3518 Sync consumer examples (#68)
add 5c519ab Polish README.md (#69)
add f7c4302 Update README.md
add b6c4641 Update README.md
add b8145d5 Revert "Support license checker (#65)"
add 8c21cbb Collect stats for local cache (#70)
add b5c9033 Cpp dev (#72)
add 033cdaf Add .licenserc.yaml
add 099706b Add a workflow to check the license
add 065f704 Update license-checker.yaml
add cbdc08c Remove ClientException#getResponseCode (#74)
add 014fa57 1. Enable message type validate 2. Remove
ReceiveMessageResult#ok
new af6500d Polish code
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 (fcaca09)
\
N -- N -- N refs/heads/java_dev (af6500d)
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:
.github/workflows/license-checker.yaml | 20 +
.gitignore | 3 +
.licenserc.yaml | 31 ++
cpp/README.md | 64 ++-
cpp/bazel/rocketmq_deps.bzl | 189 ++++----
cpp/examples/BUILD.bazel | 107 ++---
cpp/examples/BenchmarkPushConsumer.cpp | 83 ----
cpp/examples/ExampleFifoPushConsumer.cpp | 67 ---
cpp/examples/ExampleProducer.cpp | 56 ++-
...ncProducer.cpp => ExampleProducerWithAsync.cpp} | 46 +-
...ucer.cpp => ExampleProducerWithFifoMessage.cpp} | 39 +-
...cer.cpp => ExampleProducerWithTimedMessage.cpp} | 48 +-
...=> ExampleProducerWithTransactionalMessage.cpp} | 75 +--
cpp/examples/ExamplePushConsumer.cpp | 35 +-
cpp/examples/ExampleSimpleConsumer.cpp | 32 +-
cpp/examples/ExampleTransactionProducer.cpp | 52 --
cpp/examples/PushConsumerWithCustomExecutor.cpp | 147 ------
cpp/examples/PushConsumerWithThrottle.cpp | 88 ----
cpp/examples/SqlConsumer.cpp | 61 ---
cpp/examples/SqlProducer.cpp | 60 ---
cpp/include/rocketmq/Message.h | 9 +
cpp/include/rocketmq/Producer.h | 5 +
cpp/include/rocketmq/SendReceipt.h | 2 +
cpp/include/rocketmq/Transaction.h | 10 -
cpp/source/base/Message.cpp | 5 +
cpp/source/base/ThreadPoolImpl.cpp | 2 +-
cpp/source/client/ClientManagerImpl.cpp | 17 +-
cpp/source/client/SessionImpl.cpp | 2 +-
cpp/source/client/TelemetryBidiReactor.cpp | 9 +-
cpp/source/client/include/Session.h | 2 +
cpp/source/client/include/SessionImpl.h | 2 +-
.../rocketmq/AsyncReceiveMessageCallback.cpp | 3 +-
cpp/source/rocketmq/ClientImpl.cpp | 67 ++-
cpp/source/rocketmq/ConsumeTask.cpp | 8 +-
cpp/source/rocketmq/ProcessQueueImpl.cpp | 59 +--
cpp/source/rocketmq/Producer.cpp | 9 +
cpp/source/rocketmq/ProducerImpl.cpp | 79 ++--
cpp/source/rocketmq/PushConsumerImpl.cpp | 59 +++
cpp/source/rocketmq/SendContext.cpp | 4 +-
cpp/source/rocketmq/TransactionImpl.cpp | 25 +-
cpp/source/rocketmq/include/ClientImpl.h | 7 +
cpp/source/rocketmq/include/ProcessQueue.h | 15 +-
cpp/source/rocketmq/include/ProcessQueueImpl.h | 48 +-
cpp/source/rocketmq/include/ProducerImpl.h | 17 +-
cpp/source/rocketmq/include/PushConsumerImpl.h | 4 +
cpp/source/rocketmq/include/TransactionImpl.h | 47 +-
cpp/source/scheduler/SchedulerImpl.cpp | 2 +-
cpp/source/stats/Tag.cpp | 7 +-
cpp/source/stats/include/Tag.h | 4 +-
csharp/examples/Program.cs | 17 +-
...{StaticNameServerResolver.cs => AccessPoint.cs} | 28 +-
csharp/rocketmq-client-csharp/Address.cs | 35 --
csharp/rocketmq-client-csharp/Broker.cs | 77 ---
csharp/rocketmq-client-csharp/Client.cs | 429 +++++++++++++----
csharp/rocketmq-client-csharp/ClientConfig.cs | 164 +++++--
.../ClientLoggerInterceptor.cs | 22 +-
csharp/rocketmq-client-csharp/ClientManager.cs | 362 +++++++++-----
.../rocketmq-client-csharp/ClientManagerFactory.cs | 2 +-
.../ConfigFileCredentialsProvider.cs | 30 +-
csharp/rocketmq-client-csharp/Credentials.cs | 32 +-
.../{Permission.cs => ExpressionType.cs} | 13 +-
...{TopicRouteException.cs => FilterExpression.cs} | 13 +-
csharp/rocketmq-client-csharp/IClient.cs | 15 +-
csharp/rocketmq-client-csharp/IClientConfig.cs | 8 +-
csharp/rocketmq-client-csharp/IClientManager.cs | 31 +-
.../{AddressScheme.cs => IConsumer.cs} | 14 +-
.../rocketmq-client-csharp/ICredentialsProvider.cs | 6 +-
...{INameServerResolver.cs => IMessageListener.cs} | 11 +-
csharp/rocketmq-client-csharp/IProducer.cs | 15 +-
csharp/rocketmq-client-csharp/IRpcClient.cs | 38 +-
csharp/rocketmq-client-csharp/Message.cs | 122 +++--
...{TopicRouteException.cs => MessageException.cs} | 11 +-
.../rocketmq-client-csharp/MessageIdGenerator.cs | 2 +-
csharp/rocketmq-client-csharp/MessageType.cs | 7 +-
csharp/rocketmq-client-csharp/MetadataConstants.cs | 8 +-
csharp/rocketmq-client-csharp/MqLogManager.cs | 2 +-
csharp/rocketmq-client-csharp/Partition.cs | 85 ----
.../{ServiceAddress.cs => ProcessQueue.cs} | 32 +-
csharp/rocketmq-client-csharp/Producer.cs | 154 ++++--
.../Protos/apache/rocketmq/v1/admin.proto | 45 --
.../Protos/apache/rocketmq/v1/definition.proto | 351 --------------
.../Protos/apache/rocketmq/v1/service.proto | 522 ---------------------
.../Protos}/apache/rocketmq/v2/admin.proto | 0
.../Protos}/apache/rocketmq/v2/definition.proto | 187 ++++----
.../Protos}/apache/rocketmq/v2/service.proto | 66 ++-
.../rocketmq-client-csharp/PublishLoadBalancer.cs | 47 +-
.../{INameServerResolver.cs => Publishing.cs} | 14 +-
csharp/rocketmq-client-csharp/PushConsumer.cs | 261 +++++++++++
csharp/rocketmq-client-csharp/RpcClient.cs | 177 ++++++-
.../{SendResult.cs => SendReceipt.cs} | 20 +-
csharp/rocketmq-client-csharp/SendStatus.cs | 6 +-
csharp/rocketmq-client-csharp/SequenceGenerator.cs | 7 +-
csharp/rocketmq-client-csharp/Session.cs | 122 +++++
csharp/rocketmq-client-csharp/Signature.cs | 27 +-
csharp/rocketmq-client-csharp/SimpleConsumer.cs | 275 +++++++++++
.../StaticCredentialsProvider.cs | 12 +-
csharp/rocketmq-client-csharp/Topic.cs | 74 +--
csharp/rocketmq-client-csharp/TopicRouteData.cs | 46 +-
.../rocketmq-client-csharp/TopicRouteException.cs | 2 +-
csharp/rocketmq-client-csharp/Utilities.cs | 28 +-
.../rocketmq-client-csharp.csproj | 14 +-
csharp/tests/BrokerTest.cs | 38 --
csharp/tests/ClientConfigTest.cs | 9 +-
csharp/tests/ClientManagerTest.cs | 21 +-
csharp/tests/ConfigFileCredentialsProviderTest.cs | 9 +-
csharp/tests/DateTimeTest.cs | 17 +-
csharp/tests/MessageIdGeneratorTest.cs | 2 +-
csharp/tests/MessageTest.cs | 21 +-
csharp/tests/MqLogManagerTest.cs | 2 +-
csharp/tests/ProducerTest.cs | 157 ++++++-
csharp/tests/PushConsumerTest.cs | 119 +++++
csharp/tests/RpcClientTest.cs | 211 ++++-----
csharp/tests/SendResultTest.cs | 18 +-
csharp/tests/SequenceGeneratorTest.cs | 2 +-
csharp/tests/SignatureTest.cs | 8 +-
csharp/tests/SimpleConsumerTest.cs | 108 +++++
csharp/tests/StaticCredentialsProviderTest.cs | 9 +-
csharp/tests/StaticNameServerResolverTest.cs | 35 --
csharp/tests/TopicTest.cs | 23 +-
csharp/tests/UnitTest1.cs | 87 ++--
.../rocketmq/client/apis/ClientException.java | 42 +-
.../rocketmq/client/java/impl/ClientImpl.java | 346 +++++++-------
.../client/java/impl/ClientManagerImpl.java | 10 +-
.../client/java/impl/ClientSessionImpl.java | 137 +++---
.../rocketmq/client/java/impl/ClientSettings.java | 2 +-
.../client/java/impl/consumer/ConsumerImpl.java | 6 +-
.../java/impl/consumer/ProcessQueueImpl.java | 26 +-
.../java/impl/consumer/PushConsumerImpl.java | 15 +-
.../java/impl/consumer/ReceiveMessageResult.java | 51 +-
.../java/impl/consumer/SimpleConsumerImpl.java | 15 +-
.../impl/consumer/SubscriptionLoadBalancer.java | 37 +-
...ionProcessor.java => ClientSessionHandler.java} | 14 +-
.../client/java/impl/producer/ProducerImpl.java | 58 ++-
.../java/impl/producer/ProducerSettings.java | 8 +-
.../java/impl/producer/PublishingLoadBalancer.java | 42 +-
.../client/java/impl/producer/SendReceiptImpl.java | 113 ++---
.../client/java/message/MessageBuilderImpl.java | 3 -
.../client/java/metrics/ClientMeterProvider.java | 2 -
.../java/retry/CustomizedBackoffRetryPolicy.java | 15 +
.../java/retry/ExponentialBackoffRetryPolicy.java | 45 +-
.../rocketmq/client/java/retry/RetryPolicy.java | 8 +
.../client/java/route/MessageQueueImpl.java | 4 +-
.../client/java/route/TopicRouteDataResult.java | 125 -----
.../client/java/impl/ClientManagerImplTest.java | 54 ++-
.../java/impl/consumer/ProcessQueueImplTest.java | 3 +-
.../java/impl/consumer/SimpleConsumerImplTest.java | 61 +--
.../apache/rocketmq/client/java/tool/TestBase.java | 2 +-
java/pom.xml | 23 +-
148 files changed, 4146 insertions(+), 3937 deletions(-)
create mode 100644 .github/workflows/license-checker.yaml
create mode 100644 .licenserc.yaml
delete mode 100644 cpp/examples/BenchmarkPushConsumer.cpp
delete mode 100644 cpp/examples/ExampleFifoPushConsumer.cpp
copy cpp/examples/{ExampleAsyncProducer.cpp => ExampleProducerWithAsync.cpp}
(63%)
copy cpp/examples/{ExampleFifoProducer.cpp =>
ExampleProducerWithFifoMessage.cpp} (64%)
rename cpp/examples/{ExampleFifoProducer.cpp =>
ExampleProducerWithTimedMessage.cpp} (59%)
rename cpp/examples/{ExampleAsyncProducer.cpp =>
ExampleProducerWithTransactionalMessage.cpp} (52%)
delete mode 100644 cpp/examples/ExampleTransactionProducer.cpp
delete mode 100644 cpp/examples/PushConsumerWithCustomExecutor.cpp
delete mode 100644 cpp/examples/PushConsumerWithThrottle.cpp
delete mode 100644 cpp/examples/SqlConsumer.cpp
delete mode 100644 cpp/examples/SqlProducer.cpp
rename csharp/rocketmq-client-csharp/{StaticNameServerResolver.cs =>
AccessPoint.cs} (66%)
delete mode 100644 csharp/rocketmq-client-csharp/Address.cs
delete mode 100644 csharp/rocketmq-client-csharp/Broker.cs
rename csharp/rocketmq-client-csharp/{Permission.cs => ExpressionType.cs} (88%)
copy csharp/rocketmq-client-csharp/{TopicRouteException.cs =>
FilterExpression.cs} (74%)
rename csharp/rocketmq-client-csharp/{AddressScheme.cs => IConsumer.cs} (84%)
copy csharp/rocketmq-client-csharp/{INameServerResolver.cs =>
IMessageListener.cs} (86%)
copy csharp/rocketmq-client-csharp/{TopicRouteException.cs =>
MessageException.cs} (84%)
delete mode 100644 csharp/rocketmq-client-csharp/Partition.cs
rename csharp/rocketmq-client-csharp/{ServiceAddress.cs => ProcessQueue.cs}
(61%)
delete mode 100644
csharp/rocketmq-client-csharp/Protos/apache/rocketmq/v1/admin.proto
delete mode 100644
csharp/rocketmq-client-csharp/Protos/apache/rocketmq/v1/definition.proto
delete mode 100644
csharp/rocketmq-client-csharp/Protos/apache/rocketmq/v1/service.proto
copy {cpp/proto =>
csharp/rocketmq-client-csharp/Protos}/apache/rocketmq/v2/admin.proto (100%)
copy {cpp/proto =>
csharp/rocketmq-client-csharp/Protos}/apache/rocketmq/v2/definition.proto (75%)
copy {cpp/proto =>
csharp/rocketmq-client-csharp/Protos}/apache/rocketmq/v2/service.proto (94%)
rename csharp/rocketmq-client-csharp/{INameServerResolver.cs => Publishing.cs}
(75%)
create mode 100644 csharp/rocketmq-client-csharp/PushConsumer.cs
rename csharp/rocketmq-client-csharp/{SendResult.cs => SendReceipt.cs} (79%)
create mode 100644 csharp/rocketmq-client-csharp/Session.cs
create mode 100644 csharp/rocketmq-client-csharp/SimpleConsumer.cs
delete mode 100644 csharp/tests/BrokerTest.cs
create mode 100644 csharp/tests/PushConsumerTest.cs
create mode 100644 csharp/tests/SimpleConsumerTest.cs
delete mode 100644 csharp/tests/StaticNameServerResolverTest.cs
rename
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/{ClientSessionProcessor.java
=> ClientSessionHandler.java} (83%)
delete mode 100644
java/client/src/main/java/org/apache/rocketmq/client/java/route/TopicRouteDataResult.java
