This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a change to branch java_release
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
omit de7fc401 [maven-release-plugin] prepare for next development iteration
omit 1cda3319 [maven-release-plugin] prepare release java-5.0.2
omit 52213494 Revert "[maven-release-plugin] prepare release java-5.0.2"
omit 744cec14 Revert "[maven-release-plugin] prepare for next development
iteration"
omit 6c05c83e [maven-release-plugin] prepare for next development iteration
omit 5d93933c [maven-release-plugin] prepare release java-5.0.2
add 4ee642b6 Release java client 5.0.2 (#252)
add a2fe0b24 Release java client 5.0.2 (#253)
add 2cf911c7 Fix the time zone to generate message id (#254)
add 5c720229 remove redundant configuration
add 9542c7dd format code
add 76466e4e Add more comments for ProducerImpl#send0 (#259)
add 0b338107 Bump logback to 1.2.9 (#261)
add b856ca7d Update asf.yaml to modify the notifications (#260)
add 3ffaf858 Bump rocketmq proto to 2.0.1 (#263)
add df2654a7 Shutdown the ClientMeterManager during the closing of
producer/consumer (#266)
add 735a2ebb Add extraProperties for PublishingMessageImpl
add 82a7eff4 Add unit test for PublishingMessageImpl#getExtraProperties
add 37e9712a Add more ut (#267)
add 800fc2ce Bump grpc/protobuf to 1.50.0/3.21.7 (#268)
add 2c9b67dd Revert "Add extraProperties for PublishingMessageImpl" (#271)
add 10564085 Define index of LoadBalancer as static (#272)
add d429372e Revert "Define index of LoadBalancer as static (#272)"
add cfb9daa7 Reserve index of load balancer when topic route is updated
add b3d7d6c0 Polish ProcessIdConverter
add c3fdf482 Remove MessageBuilder#setTraceContext and
MessageView#getTraceContext
add c596822e Add PHP git ignore file (#280)
add 74c56378 Implement native php client #255 (#278)
add f2638878 Setup PHP CI pipeline (#282)
add d67cd441 fix options bug
add 1191f5be Rename LOGGER to log
add 7365df56 Add PHP build badge
add fbb1d0cf Delay setting wait time
add ba5c8a71 [maven-release-plugin] prepare release java-5.0.3
add acba52ce [maven-release-plugin] prepare for next development iteration
add 28085013 golang: fix longpolling timeout (#290)
add 5ba0ba13 golang: add more log for debug mode (#292)
add 5d9e8c57 Bump version to 5.0.1
add 8aa0ee1c Remove redundant clientSession
add 984687c9 Divide example by the message & producer/consumer type
add 71d58d90 Bugfix: producer does not override BuildClientSetting
add c3cb6620 Bugfix: ClientSessionImpl#syncSettings should not block
asynchronous worker thread
add db17579c Polish java example
add 71042f47 Fix typo
add ba3c5c8e Disable keep alive for gRPC channel
add 8f5f33be Remove redundant code
add 129f63e6 Add client type into HeartbeatRequest
add a26cb1a2 Adjust default thread pool core size
add 6843571f Remove shutdown hook
add 33dfa2ce [maven-release-plugin] prepare release java-5.0.4
add db1e7aee [maven-release-plugin] prepare for next development iteration
add 850848d5 fix isolated endpoints in LoadBalancer (#316)
add d821b203 golang: fast to the ok state (#295)
add b8aed221 improve ReceiveMessage performance
add 6010d65e Bump OT to 1.3.1
add 334df3ff Align ClientId generation in dotnet driver with others
add e1bf271f Align dotnet driver with other drivers regarding FIFO message
handling
add 422a5709 Add missing periodic heartbeat in dotnet driver
add 2e64474c C# SimpleConsumer should take request timeout into
consideration when polling for messages
add 6d3cd0b6 Update observability.md (#320)
add 5a6a16c6 Bump golang version to 5.0.1-rc1
add 8f4c0c4d Add missing unsubscribe in dotnet SimpleConsumer
add a80ef58a Minor optimization
add a44608e2 dotnet use project versioning
add 423c8248 Update
csharp/rocketmq-client-csharp/rocketmq-client-csharp.csproj
add d957e524 Fix SimpleConsumer with multiple topics
add cd456333 Align dotnet Producer on BornTimestamp/QueueId with other
languages
add 12ef8269 dotnet: allow changing SimpleConsumer polling time
add 0464fe95 Polish docs (#327)
add 933c7bfa Polish docs (#328)
add 65155e92 Fix typo (#329)
add 577469b4 Typo fix (#330)
add a52ffa40 golang: add error handling in simple consumer (#336)
add 087479a0 Polish docs (#338)
add bbcbcac1 feat: Make each 'Client' have an independent 'ClientManager'
(#235)
add 1184903c Polish the docs (#340)
add 96729a83 Polish java example (#347)
add aa3e9fdd feat: fixed subscriptionExpressionsLock use (#343)
add 83493eae fix Subscribe bug (#346)
add 70d43828 fix telemeter logic (#348)
add bc32cbd4 Polish example of simple consumer (#351)
add bf3ce7d5 fix ErrRpcStatus.GetCode() stack overflow (#352)
add 2ff904e9 Fix typo (#353)
add 67ea9d64 Allow user to disable TLS (#356)
add c377e946 Bump maven-enforcer-plugin to 3.2.1 (#361)
add d4e28689 Add AsyncAppender support (#363)
add 57c5935b Bump rocketmq-proto to 2.0.2 (#364)
add b3f7ba6d WIP: refactor producer
add 1cc2e59c Format log output
add 57531fab Modify log level temporarily
add 8417c0a9 Add more logs
add 9c5d8858 Polish code
add 2e2b23a8 Add PublishingLoadBalancer#TakeMessageQueueByMessageGroup
add 26bb67c5 Implement simple consumer
add 8f7418ed Bugfix: ICollection is read-only
add 44943d58 Polish logs
add 70282e85 Add Client#GetTopics
add 85ae3d54 Add more logs
add 7ce29d7d Notify remote endpoints that current client is terminated
add 6cde562e Add error log for scheduled task
add 30c1832b Implement Client#OnVerrifyMessageCommand and
Client#OnPrintThreadStackTraceCommand
add 7de5b395 Implement transaction message
add c9e3d21f Implement Producer#send with transaction
add 7be8d6da Add more stats info
add d7a0a5c6 Add more method for IClientConfig
add d7072119 Polish code
add 2f734d63 Polish code
add ebd236ad Make simpleconsumer works
add b2ee3b31 Polish code
add e272ee3d Add nonce for TelemetryCommand
add f5c2878a Add state machine for rocketmq producer/simpleConsumer
add 15007046 Apply state machine in transactional message
add f4e4647c Add more response code cases
add e3fbe1db Implement ExponentialBackoffRetryPolicy
add 520bd4f2 Add license header
add e219eebf WIP: implement client metrics by OpenTelemetry
add c66db15e Add lock for ClientMeterManager#Reset
add 7cd8cf63 Bugfix: Add constructor to copy message
add 9f0ba427 Make it adapt with the newest IDL
add dd411737 Apply builder pattern
add c6eb6528 Hide unnecessary method
add 690ff181 Polish example
add bec16145 Fetch topic firstly before add scheduled task
add d8961eb7 Remove useless code
add 6e9fd521 Add more limitation for Producer/Message/SimpleConsumer setter
add 6c1dd65a Fix naming issue
add c21ccbfe Remove useless code
add 0002cc5a Apply flow-control when TooManyRequestsException is raised
add 8dd33e79 Allow to adjust logger level
add 8e985636 Make it possible to publish to NuGet
add 9bac6db6 Bump to 0.0.3-SNAPSHOT
add 1d85ba07 Rephrase README.md of .NET
add a905eba6 Add request-id support
add a376ca5a Allow to adjust log configuration
add 4c135bb2 Override message ToString method
add 0a02f18a Allow user to disable TLS
add c8af7a4c Adjust settings sync frequency
add 00492cc7 Bugfix: wrong message type judgement
add 912b3752 Add more tests
add cd4302c5 Support to use DateTime.Now to send message
add 03fa9c20 Add more docs to publish the artifact to NuGet Gallery
add 738133d3 Add nuget badge
add 885efc9a Polish code
add e7710060 Log ClientVersion and .NET version
add 0cdffebe Polish the example of ProducerBenchmark
add 9f98c85d Delete useless code
add 84ba2251 Apply dotnet-format
add 196ac25d Fix metrics label
add 8a6aef83 Polish the readme
add 72657ee5 Remove redundant constructor
add d3d74ac2 Apply try-with-resource in ObservableDoubleGauge
add 7849cbce Increase metric exporter RPC timeout to 5 seconds
add a5aa817c Bugfix: ConcurrentDictionary#TryAdd will not replace the
existed element
add 6766a8ff Fix code style
add 8550102f Add more tests
add dc01d5e6 Add the logging part of C# README.md
add 513de8f3 Log TooManyRequest
add 5fa06815 Set exception for producer ahead of throwing it
add bbc8fc98 Make it compatible with .NET standard 2.1
add e4b88580 Add 3.1.x into dotnet-version of CI pipeline
add 8efac866 Add more docs
add 2752a445 Update TargetFrameworks to 'net5.0;netcoreapp3.1'
add e554ddb9 Add more comments
add 14c609de Disable auto retry of gRPC
add 205882c8 Polish readme
add b85b9b11 Pack the pdb file into nupkg
add a9e0c0ac Enable ssl by default
add 9c4e934d Add more comments about disable TLS/SSL on .NET Core 3.1
add fdbe255f Enable ServerGarbageCollection for example
add 2234f70f Add more stats info
add 18ff64d9 Polish the example
add c4d4ce6d Bump to 5.0.1-rc1
add 514056c2 Print more info for client stats
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 (de7fc401)
\
N -- N -- N refs/heads/java_release (514056c2)
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.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 6 +
.github/workflows/build.yml | 11 +-
.github/workflows/csharp_build.yml | 11 +-
.github/workflows/php_build.yml | 24 +
.gitignore | 5 +
.licenserc.yaml | 2 +
README.md => README-CN.md | 39 +-
README.md | 10 +-
csharp/README-CN.md | 66 ++
csharp/README.md | 73 +-
csharp/examples/ProducerBenchmark.cs | 122 +++
csharp/examples/ProducerDelayMessageExample.cs | 74 ++
csharp/examples/ProducerFifoMessageExample.cs | 76 ++
csharp/examples/ProducerNormalMessageExample.cs | 72 ++
.../examples/ProducerTransactionMessageExample.cs | 87 +++
csharp/examples/Program.cs | 164 ----
.../MessageException.cs => examples/QuickStart.cs} | 59 +-
csharp/examples/SimpleConsumerExample.cs | 75 ++
csharp/examples/examples.csproj | 17 +-
csharp/rocketmq-client-csharp/AccessPoint.cs | 74 --
.../{Topic.cs => Address.cs} | 55 +-
.../AddressListEqualityComparer.cs} | 44 +-
...aticCredentialsProvider.cs => AddressScheme.cs} | 33 +-
.../{ProcessQueue.cs => Broker.cs} | 34 +-
csharp/rocketmq-client-csharp/Client.cs | 715 ++++++++---------
csharp/rocketmq-client-csharp/ClientConfig.cs | 177 +----
.../ClientLoggerInterceptor.cs | 17 +-
csharp/rocketmq-client-csharp/ClientManager.cs | 315 ++------
csharp/rocketmq-client-csharp/ClientMeter.cs | 76 ++
.../rocketmq-client-csharp/ClientMeterManager.cs | 117 +++
...{StaticCredentialsProvider.cs => ClientType.cs} | 30 +-
.../ConfigFileCredentialsProvider.cs | 88 ---
csharp/rocketmq-client-csharp/Consumer.cs | 107 +++
csharp/rocketmq-client-csharp/Credentials.cs | 75 --
csharp/rocketmq-client-csharp/Endpoints.cs | 196 +++++
.../BadRequestException.cs} | 20 +-
.../Error/ClientException.cs} | 33 +-
.../ForbiddenException.cs} | 20 +-
.../InternalErrorException.cs} | 26 +-
.../NotFoundException.cs} | 25 +-
.../PayloadTooLargeException.cs} | 20 +-
.../PaymentRequiredException.cs} | 14 +-
.../ProxyTimeoutException.cs} | 14 +-
.../RequestHeaderFieldsTooLargeException.cs} | 22 +-
.../TooManyRequestsException.cs} | 20 +-
.../UnauthorizedException.cs} | 21 +-
.../UnsupportedException.cs} | 20 +-
.../ExponentialBackoffRetryPolicy.cs | 92 +++
csharp/rocketmq-client-csharp/ExpressionType.cs | 7 +-
csharp/rocketmq-client-csharp/FilterExpression.cs | 2 +-
csharp/rocketmq-client-csharp/IClientManager.cs | 102 ++-
csharp/rocketmq-client-csharp/IRetryPolicy.cs | 55 ++
csharp/rocketmq-client-csharp/IRpcClient.cs | 7 +-
.../{ICredentialsProvider.cs => ISendReceipt.cs} | 5 +-
...Exception.cs => ISessionCredentialsProvider.cs} | 9 +-
.../{IConsumer.cs => ITransaction.cs} | 7 +-
.../{IClientConfig.cs => ITransactionChecker.cs} | 23 +-
csharp/rocketmq-client-csharp/Message.cs | 186 +++--
.../rocketmq-client-csharp/MessageIdGenerator.cs | 28 +-
csharp/rocketmq-client-csharp/MessageQueue.cs | 69 ++
csharp/rocketmq-client-csharp/MessageType.cs | 38 +-
csharp/rocketmq-client-csharp/MessageView.cs | 189 +++++
csharp/rocketmq-client-csharp/MetadataConstants.cs | 62 +-
.../{IProducer.cs => Metric.cs} | 15 +-
csharp/rocketmq-client-csharp/MetricConstant.cs | 70 ++
.../{IClient.cs => MetricHttpDelegatingHandler.cs} | 31 +-
.../MqEncoding.cs} | 27 +-
csharp/rocketmq-client-csharp/MqLogManager.cs | 79 +-
csharp/rocketmq-client-csharp/Permission.cs | 93 +++
.../{MessageException.cs => Preconditions.cs} | 9 +-
csharp/rocketmq-client-csharp/Producer.cs | 456 +++++++----
.../Protos/apache/rocketmq/v2/definition.proto | 10 +
.../Protos/apache/rocketmq/v2/service.proto | 1 +
.../rocketmq-client-csharp/PublishLoadBalancer.cs | 120 ---
csharp/rocketmq-client-csharp/Publishing.cs | 31 -
.../PublishingLoadBalancer.cs | 105 +++
csharp/rocketmq-client-csharp/PublishingMessage.cs | 119 +++
.../rocketmq-client-csharp/PublishingSettings.cs | 85 ++
...IMessageListener.cs => ReceiveMessageResult.cs} | 14 +-
.../{SendReceipt.cs => Resource.cs} | 34 +-
csharp/rocketmq-client-csharp/RpcClient.cs | 86 +--
...aticCredentialsProvider.cs => RpcInvocation.cs} | 25 +-
csharp/rocketmq-client-csharp/SendReceipt.cs | 49 +-
csharp/rocketmq-client-csharp/SendStatus.cs | 27 -
csharp/rocketmq-client-csharp/SequenceGenerator.cs | 131 ----
csharp/rocketmq-client-csharp/Session.cs | 136 ++--
.../rocketmq-client-csharp/SessionCredentials.cs | 46 ++
csharp/rocketmq-client-csharp/Settings.cs | 59 ++
csharp/rocketmq-client-csharp/Signature.cs | 73 +-
csharp/rocketmq-client-csharp/SimpleConsumer.cs | 459 +++++------
.../SimpleSubscriptionSettings.cs | 99 +++
.../{IConsumer.cs => State.cs} | 12 +-
...tion.cs => StaticSessionCredentialsProvider.cs} | 10 +-
csharp/rocketmq-client-csharp/StatusChecker.cs | 109 +++
.../SubscriptionLoadBalancer.cs | 59 ++
csharp/rocketmq-client-csharp/TopicRouteData.cs | 45 +-
csharp/rocketmq-client-csharp/Transaction.cs | 131 ++++
...{ExpressionType.cs => TransactionResolution.cs} | 10 +-
.../UserAgent.cs} | 37 +-
csharp/rocketmq-client-csharp/Utilities.cs | 104 ++-
csharp/rocketmq-client-csharp/logo.png | Bin 0 -> 85598 bytes
.../rocketmq-client-csharp.csproj | 81 +-
.../rocketmq-client-csharp.nlog | 8 +-
csharp/tests/ClientManagerTest.cs | 58 --
csharp/tests/ConfigFileCredentialsProviderTest.cs | 58 --
csharp/tests/DateTimeTest.cs | 14 +-
.../{ClientConfigTest.cs => EndpointsTest.cs} | 24 +-
csharp/tests/MessageIdGeneratorTest.cs | 4 +-
csharp/tests/MessageTest.cs | 208 +++--
csharp/tests/MqLogManagerTest.cs | 1 +
csharp/tests/ProducerTest.cs | 189 -----
csharp/tests/PublishingLoadBalancerTest.cs | 100 +++
csharp/tests/PublishingMessageTest.cs | 103 +++
csharp/tests/RpcClientTest.cs | 146 ----
csharp/tests/SimpleConsumerTest.cs | 97 ---
csharp/tests/StaticCredentialsProviderTest.cs | 40 -
csharp/tests/UnitTest1.cs | 91 ---
.../tests/{SignatureTest.cs => UtilitiesTest.cs} | 39 +-
csharp/tests/tests.csproj | 6 +-
docs/observability.md | 11 +-
golang/README.md | 2 +-
golang/client.go | 61 +-
golang/client_manager.go | 49 --
golang/client_manager_mock.go | 51 --
golang/client_manager_test.go | 140 +++-
golang/client_test.go | 36 +-
golang/config.go | 9 +-
golang/error.go | 2 +-
golang/example/consumer/simple_consumer/main.go | 32 +-
golang/example/producer/async/main.go | 18 +-
golang/example/producer/delay/main.go | 16 +-
golang/example/producer/fifo/main.go | 16 +-
golang/example/producer/normal/main.go | 16 +-
golang/example/producer/transaction/main.go | 22 +-
golang/loadBalancer.go | 2 +-
golang/metadata/metadata.go | 2 +-
golang/producer.go | 3 +-
golang/producer_test.go | 105 +--
golang/rpc_client.go | 32 +-
golang/simple_consumer.go | 25 +-
golang/user_agent.go | 2 +-
java/README-CN.md | 72 ++
java/README.md | 54 +-
java/client-apis/pom.xml | 2 +-
.../rocketmq/client/apis/ClientConfiguration.java | 8 +-
.../client/apis/ClientConfigurationBuilder.java | 14 +-
.../rocketmq/client/apis/message/Message.java | 8 -
.../client/apis/message/MessageBuilder.java | 8 -
.../rocketmq/client/apis/message/MessageView.java | 8 -
java/client-shade/pom.xml | 2 +-
.../src/main/resources/rocketmq.logback.xml | 5 +-
java/client/pom.xml | 2 +-
.../client/java/example/AsyncProducerExample.java | 24 +-
.../java/example/AsyncSimpleConsumerExample.java | 64 +-
.../java/example/ProducerDelayMessageExample.java | 13 +-
.../java/example/ProducerFifoMessageExample.java | 11 +-
.../java/example/ProducerNormalMessageExample.java | 11 +-
.../example/ProducerTransactionMessageExample.java | 13 +-
.../client/java/example/PushConsumerExample.java | 4 +-
.../client/java/example/SimpleConsumerExample.java | 31 +-
.../client/java/exception/StatusChecker.java | 5 +-
.../java/hook/CompositedMessageInterceptor.java | 6 +-
.../apache/rocketmq/client/java/impl/Client.java | 38 +-
.../rocketmq/client/java/impl/ClientImpl.java | 127 +--
.../client/java/impl/ClientManagerImpl.java | 56 +-
.../client/java/impl/ClientSessionImpl.java | 61 +-
.../client/java/impl/consumer/ConsumeService.java | 4 +-
.../client/java/impl/consumer/ConsumeTask.java | 4 +-
.../client/java/impl/consumer/ConsumerImpl.java | 22 +-
.../java/impl/consumer/FifoConsumeService.java | 4 +-
.../java/impl/consumer/ProcessQueueImpl.java | 74 +-
.../java/impl/consumer/PushConsumerImpl.java | 52 +-
.../impl/consumer/PushSubscriptionSettings.java | 6 +-
.../java/impl/consumer/SimpleConsumerImpl.java | 71 +-
.../impl/consumer/SimpleSubscriptionSettings.java | 6 +-
.../java/impl/consumer/StandardConsumeService.java | 6 +-
.../impl/consumer/SubscriptionLoadBalancer.java | 10 +-
.../java/impl/producer/ClientSessionHandler.java | 6 +
.../client/java/impl/producer/ProducerImpl.java | 76 +-
.../java/impl/producer/PublishingLoadBalancer.java | 10 +-
.../java/impl/producer/PublishingSettings.java | 4 +-
.../client/java/logging/ProcessIdConverter.java | 32 +-
.../client/java/message/GeneralMessage.java | 16 -
.../client/java/message/GeneralMessageImpl.java | 19 -
.../client/java/message/MessageBuilderImpl.java | 13 +-
.../client/java/message/MessageIdCodec.java | 3 +-
.../rocketmq/client/java/message/MessageImpl.java | 15 +-
.../client/java/message/MessageViewImpl.java | 24 +-
.../client/java/message/PublishingMessageImpl.java | 13 -
.../rocketmq/client/java/metrics/ClientMeter.java | 7 +-
.../client/java/metrics/ClientMeterManager.java | 41 +-
.../java/metrics/MessageMeterInterceptor.java | 10 +-
.../rocketmq/client/java/misc/Utilities.java | 6 +
.../rocketmq/client/java/rpc/AuthInterceptor.java | 4 +-
.../client/java/rpc/LoggingInterceptor.java | 10 +-
.../rocketmq/client/java/rpc/RpcClientImpl.java | 21 +-
java/client/src/main/resources/logback.xml | 5 +-
.../client/java/exception/StatusCheckerTest.java | 11 +
.../client/java/impl/ClientSessionImplTest.java | 42 +-
.../java/impl/consumer/ProcessQueueImplTest.java | 2 +-
.../impl/producer/PublishingLoadBalancerTest.java | 73 ++
.../java/message/GeneralMessageImplTest.java | 14 +-
.../client/java/message/MessageImplTest.java | 1 -
.../rocketmq/client/java/misc/UtilitiesTest.java | 6 +
.../apache/rocketmq/client/java/tool/TestBase.java | 2 +-
java/pom.xml | 12 +-
php/.gitignore | 4 +
php/Consumer.php | 48 ++
php/Producer.php | 73 ++
php/composer.json | 16 +
php/grpc/Apache/Rocketmq/V2/AckMessageEntry.php | 85 ++
php/grpc/Apache/Rocketmq/V2/AckMessageRequest.php | 132 ++++
php/grpc/Apache/Rocketmq/V2/AckMessageResponse.php | 106 +++
.../Apache/Rocketmq/V2/AckMessageResultEntry.php | 137 ++++
php/grpc/Apache/Rocketmq/V2/Address.php | 85 ++
php/grpc/Apache/Rocketmq/V2/AddressScheme.php | 58 ++
php/grpc/Apache/Rocketmq/V2/AdminClient.php | 49 ++
php/grpc/Apache/Rocketmq/V2/Assignment.php | 68 ++
php/grpc/Apache/Rocketmq/V2/Broker.php | 159 ++++
.../Rocketmq/V2/ChangeInvisibleDurationRequest.php | 217 ++++++
.../V2/ChangeInvisibleDurationResponse.php | 102 +++
.../Apache/Rocketmq/V2/ChangeLogLevelRequest.php | 58 ++
.../Rocketmq/V2/ChangeLogLevelRequest/Level.php | 66 ++
.../Rocketmq/V2/ChangeLogLevelRequest_Level.php | 16 +
.../Apache/Rocketmq/V2/ChangeLogLevelResponse.php | 58 ++
php/grpc/Apache/Rocketmq/V2/ClientType.php | 58 ++
php/grpc/Apache/Rocketmq/V2/Code.php | 375 +++++++++
php/grpc/Apache/Rocketmq/V2/CustomizedBackoff.php | 69 ++
php/grpc/Apache/Rocketmq/V2/Digest.php | 98 +++
php/grpc/Apache/Rocketmq/V2/DigestType.php | 67 ++
php/grpc/Apache/Rocketmq/V2/Encoding.php | 53 ++
.../Apache/Rocketmq/V2/EndTransactionRequest.php | 203 +++++
.../Apache/Rocketmq/V2/EndTransactionResponse.php | 68 ++
php/grpc/Apache/Rocketmq/V2/Endpoints.php | 85 ++
php/grpc/Apache/Rocketmq/V2/ExponentialBackoff.php | 134 ++++
php/grpc/Apache/Rocketmq/V2/FilterExpression.php | 85 ++
php/grpc/Apache/Rocketmq/V2/FilterType.php | 53 ++
.../V2/ForwardMessageToDeadLetterQueueRequest.php | 213 +++++
.../V2/ForwardMessageToDeadLetterQueueResponse.php | 68 ++
php/grpc/Apache/Rocketmq/V2/HeartbeatRequest.php | 95 +++
php/grpc/Apache/Rocketmq/V2/HeartbeatResponse.php | 68 ++
php/grpc/Apache/Rocketmq/V2/Language.php | 68 ++
php/grpc/Apache/Rocketmq/V2/Message.php | 182 +++++
php/grpc/Apache/Rocketmq/V2/MessageQueue.php | 186 +++++
php/grpc/Apache/Rocketmq/V2/MessageType.php | 70 ++
.../Apache/Rocketmq/V2/MessagingServiceClient.php | 266 +++++++
php/grpc/Apache/Rocketmq/V2/Metric.php | 109 +++
.../Rocketmq/V2/NotifyClientTerminationRequest.php | 75 ++
.../V2/NotifyClientTerminationResponse.php | 68 ++
php/grpc/Apache/Rocketmq/V2/Permission.php | 63 ++
.../Rocketmq/V2/PrintThreadStackTraceCommand.php | 58 ++
php/grpc/Apache/Rocketmq/V2/Publishing.php | 153 ++++
.../Apache/Rocketmq/V2/QueryAssignmentRequest.php | 142 ++++
.../Apache/Rocketmq/V2/QueryAssignmentResponse.php | 95 +++
php/grpc/Apache/Rocketmq/V2/QueryRouteRequest.php | 120 +++
php/grpc/Apache/Rocketmq/V2/QueryRouteResponse.php | 95 +++
.../Apache/Rocketmq/V2/ReceiveMessageRequest.php | 247 ++++++
.../Apache/Rocketmq/V2/ReceiveMessageResponse.php | 129 ++++
.../V2/RecoverOrphanedTransactionCommand.php | 95 +++
php/grpc/Apache/Rocketmq/V2/Resource.php | 96 +++
php/grpc/Apache/Rocketmq/V2/RetryPolicy.php | 123 +++
php/grpc/Apache/Rocketmq/V2/SendMessageRequest.php | 58 ++
.../Apache/Rocketmq/V2/SendMessageResponse.php | 106 +++
php/grpc/Apache/Rocketmq/V2/SendResultEntry.php | 149 ++++
php/grpc/Apache/Rocketmq/V2/Settings.php | 374 +++++++++
php/grpc/Apache/Rocketmq/V2/Status.php | 85 ++
php/grpc/Apache/Rocketmq/V2/Subscription.php | 273 +++++++
php/grpc/Apache/Rocketmq/V2/SubscriptionEntry.php | 105 +++
php/grpc/Apache/Rocketmq/V2/SystemProperties.php | 853 +++++++++++++++++++++
php/grpc/Apache/Rocketmq/V2/TelemetryCommand.php | 281 +++++++
php/grpc/Apache/Rocketmq/V2/ThreadStackTrace.php | 95 +++
.../Apache/Rocketmq/V2/TransactionResolution.php | 53 ++
php/grpc/Apache/Rocketmq/V2/TransactionSource.php | 53 ++
php/grpc/Apache/Rocketmq/V2/UA.php | 169 ++++
.../Apache/Rocketmq/V2/VerifyMessageCommand.php | 95 +++
.../Apache/Rocketmq/V2/VerifyMessageResult.php | 58 ++
php/grpc/GPBMetadata/Apache/Rocketmq/V2/Admin.php | Bin 0 -> 961 bytes
.../GPBMetadata/Apache/Rocketmq/V2/Definition.php | Bin 0 -> 5552 bytes
.../GPBMetadata/Apache/Rocketmq/V2/Service.php | Bin 0 -> 7300 bytes
.../protocol}/apache/rocketmq/v2/admin.proto | 0
.../protocol}/apache/rocketmq/v2/definition.proto | 0
.../protocol}/apache/rocketmq/v2/service.proto | 0
282 files changed, 14839 insertions(+), 4348 deletions(-)
create mode 100644 .github/workflows/php_build.yml
copy README.md => README-CN.md (66%)
create mode 100644 csharp/README-CN.md
create mode 100644 csharp/examples/ProducerBenchmark.cs
create mode 100644 csharp/examples/ProducerDelayMessageExample.cs
create mode 100644 csharp/examples/ProducerFifoMessageExample.cs
create mode 100644 csharp/examples/ProducerNormalMessageExample.cs
create mode 100644 csharp/examples/ProducerTransactionMessageExample.cs
delete mode 100644 csharp/examples/Program.cs
copy csharp/{rocketmq-client-csharp/MessageException.cs =>
examples/QuickStart.cs} (62%)
create mode 100644 csharp/examples/SimpleConsumerExample.cs
delete mode 100644 csharp/rocketmq-client-csharp/AccessPoint.cs
rename csharp/rocketmq-client-csharp/{Topic.cs => Address.cs} (59%)
rename csharp/{tests/TopicTest.cs =>
rocketmq-client-csharp/AddressListEqualityComparer.cs} (55%)
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
AddressScheme.cs} (58%)
copy csharp/rocketmq-client-csharp/{ProcessQueue.cs => Broker.cs} (62%)
create mode 100644 csharp/rocketmq-client-csharp/ClientMeter.cs
create mode 100644 csharp/rocketmq-client-csharp/ClientMeterManager.cs
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
ClientType.cs} (59%)
delete mode 100644
csharp/rocketmq-client-csharp/ConfigFileCredentialsProvider.cs
create mode 100644 csharp/rocketmq-client-csharp/Consumer.cs
delete mode 100644 csharp/rocketmq-client-csharp/Credentials.cs
create mode 100644 csharp/rocketmq-client-csharp/Endpoints.cs
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
Error/BadRequestException.cs} (64%)
rename csharp/{tests/SendResultTest.cs =>
rocketmq-client-csharp/Error/ClientException.cs} (53%)
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
Error/ForbiddenException.cs} (64%)
copy csharp/rocketmq-client-csharp/{ProcessQueue.cs =>
Error/InternalErrorException.cs} (59%)
rename csharp/rocketmq-client-csharp/{ProcessQueue.cs =>
Error/NotFoundException.cs} (63%)
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
Error/PayloadTooLargeException.cs} (63%)
copy csharp/rocketmq-client-csharp/{MessageException.cs =>
Error/PaymentRequiredException.cs} (69%)
copy csharp/rocketmq-client-csharp/{MessageException.cs =>
Error/ProxyTimeoutException.cs} (70%)
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
Error/RequestHeaderFieldsTooLargeException.cs} (56%)
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
Error/TooManyRequestsException.cs} (64%)
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
Error/UnauthorizedException.cs} (62%)
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
Error/UnsupportedException.cs} (66%)
create mode 100644
csharp/rocketmq-client-csharp/ExponentialBackoffRetryPolicy.cs
create mode 100644 csharp/rocketmq-client-csharp/IRetryPolicy.cs
rename csharp/rocketmq-client-csharp/{ICredentialsProvider.cs =>
ISendReceipt.cs} (91%)
rename csharp/rocketmq-client-csharp/{TopicRouteException.cs =>
ISessionCredentialsProvider.cs} (86%)
copy csharp/rocketmq-client-csharp/{IConsumer.cs => ITransaction.cs} (88%)
rename csharp/rocketmq-client-csharp/{IClientConfig.cs =>
ITransactionChecker.cs} (67%)
create mode 100644 csharp/rocketmq-client-csharp/MessageQueue.cs
create mode 100644 csharp/rocketmq-client-csharp/MessageView.cs
rename csharp/rocketmq-client-csharp/{IProducer.cs => Metric.cs} (71%)
create mode 100644 csharp/rocketmq-client-csharp/MetricConstant.cs
rename csharp/rocketmq-client-csharp/{IClient.cs =>
MetricHttpDelegatingHandler.cs} (53%)
copy csharp/{tests/DateTimeTest.cs => rocketmq-client-csharp/MqEncoding.cs}
(65%)
create mode 100644 csharp/rocketmq-client-csharp/Permission.cs
copy csharp/rocketmq-client-csharp/{MessageException.cs => Preconditions.cs}
(79%)
delete mode 100644 csharp/rocketmq-client-csharp/PublishLoadBalancer.cs
delete mode 100644 csharp/rocketmq-client-csharp/Publishing.cs
create mode 100644 csharp/rocketmq-client-csharp/PublishingLoadBalancer.cs
create mode 100644 csharp/rocketmq-client-csharp/PublishingMessage.cs
create mode 100644 csharp/rocketmq-client-csharp/PublishingSettings.cs
rename csharp/rocketmq-client-csharp/{IMessageListener.cs =>
ReceiveMessageResult.cs} (74%)
copy csharp/rocketmq-client-csharp/{SendReceipt.cs => Resource.cs} (58%)
rename csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
RpcInvocation.cs} (66%)
delete mode 100644 csharp/rocketmq-client-csharp/SendStatus.cs
delete mode 100644 csharp/rocketmq-client-csharp/SequenceGenerator.cs
create mode 100644 csharp/rocketmq-client-csharp/SessionCredentials.cs
create mode 100644 csharp/rocketmq-client-csharp/Settings.cs
create mode 100644 csharp/rocketmq-client-csharp/SimpleSubscriptionSettings.cs
rename csharp/rocketmq-client-csharp/{IConsumer.cs => State.cs} (87%)
rename csharp/rocketmq-client-csharp/{MessageException.cs =>
StaticSessionCredentialsProvider.cs} (73%)
create mode 100644 csharp/rocketmq-client-csharp/StatusChecker.cs
create mode 100644 csharp/rocketmq-client-csharp/SubscriptionLoadBalancer.cs
create mode 100644 csharp/rocketmq-client-csharp/Transaction.cs
copy csharp/rocketmq-client-csharp/{ExpressionType.cs =>
TransactionResolution.cs} (90%)
rename csharp/{tests/SequenceGeneratorTest.cs =>
rocketmq-client-csharp/UserAgent.cs} (58%)
create mode 100644 csharp/rocketmq-client-csharp/logo.png
delete mode 100644 csharp/tests/ClientManagerTest.cs
delete mode 100644 csharp/tests/ConfigFileCredentialsProviderTest.cs
rename csharp/tests/{ClientConfigTest.cs => EndpointsTest.cs} (61%)
delete mode 100644 csharp/tests/ProducerTest.cs
create mode 100644 csharp/tests/PublishingLoadBalancerTest.cs
create mode 100644 csharp/tests/PublishingMessageTest.cs
delete mode 100644 csharp/tests/RpcClientTest.cs
delete mode 100644 csharp/tests/SimpleConsumerTest.cs
delete mode 100644 csharp/tests/StaticCredentialsProviderTest.cs
delete mode 100644 csharp/tests/UnitTest1.cs
rename csharp/tests/{SignatureTest.cs => UtilitiesTest.cs} (52%)
create mode 100644 java/README-CN.md
create mode 100644
java/client/src/test/java/org/apache/rocketmq/client/java/impl/producer/PublishingLoadBalancerTest.java
create mode 100644 php/.gitignore
create mode 100644 php/Consumer.php
create mode 100644 php/Producer.php
create mode 100644 php/composer.json
create mode 100644 php/grpc/Apache/Rocketmq/V2/AckMessageEntry.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/AckMessageRequest.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/AckMessageResponse.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/AckMessageResultEntry.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Address.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/AddressScheme.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/AdminClient.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Assignment.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Broker.php
create mode 100644
php/grpc/Apache/Rocketmq/V2/ChangeInvisibleDurationRequest.php
create mode 100644
php/grpc/Apache/Rocketmq/V2/ChangeInvisibleDurationResponse.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/ChangeLogLevelRequest.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/ChangeLogLevelRequest/Level.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/ChangeLogLevelRequest_Level.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/ChangeLogLevelResponse.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/ClientType.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Code.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/CustomizedBackoff.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Digest.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/DigestType.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Encoding.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/EndTransactionRequest.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/EndTransactionResponse.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Endpoints.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/ExponentialBackoff.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/FilterExpression.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/FilterType.php
create mode 100644
php/grpc/Apache/Rocketmq/V2/ForwardMessageToDeadLetterQueueRequest.php
create mode 100644
php/grpc/Apache/Rocketmq/V2/ForwardMessageToDeadLetterQueueResponse.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/HeartbeatRequest.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/HeartbeatResponse.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Language.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Message.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/MessageQueue.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/MessageType.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/MessagingServiceClient.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Metric.php
create mode 100644
php/grpc/Apache/Rocketmq/V2/NotifyClientTerminationRequest.php
create mode 100644
php/grpc/Apache/Rocketmq/V2/NotifyClientTerminationResponse.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Permission.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/PrintThreadStackTraceCommand.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Publishing.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/QueryAssignmentRequest.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/QueryAssignmentResponse.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/QueryRouteRequest.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/QueryRouteResponse.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/ReceiveMessageRequest.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/ReceiveMessageResponse.php
create mode 100644
php/grpc/Apache/Rocketmq/V2/RecoverOrphanedTransactionCommand.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Resource.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/RetryPolicy.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/SendMessageRequest.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/SendMessageResponse.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/SendResultEntry.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Settings.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Status.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/Subscription.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/SubscriptionEntry.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/SystemProperties.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/TelemetryCommand.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/ThreadStackTrace.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/TransactionResolution.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/TransactionSource.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/UA.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/VerifyMessageCommand.php
create mode 100644 php/grpc/Apache/Rocketmq/V2/VerifyMessageResult.php
create mode 100644 php/grpc/GPBMetadata/Apache/Rocketmq/V2/Admin.php
create mode 100644 php/grpc/GPBMetadata/Apache/Rocketmq/V2/Definition.php
create mode 100644 php/grpc/GPBMetadata/Apache/Rocketmq/V2/Service.php
copy {cpp/proto => php/protocol}/apache/rocketmq/v2/admin.proto (100%)
copy {cpp/proto => php/protocol}/apache/rocketmq/v2/definition.proto (100%)
copy {cpp/proto => php/protocol}/apache/rocketmq/v2/service.proto (100%)
