This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
from 57c5935b Bump rocketmq-proto to 2.0.2 (#364)
new b3f7ba6d WIP: refactor producer
new 1cc2e59c Format log output
new 57531fab Modify log level temporarily
new 8417c0a9 Add more logs
new 9c5d8858 Polish code
new 2e2b23a8 Add PublishingLoadBalancer#TakeMessageQueueByMessageGroup
new 26bb67c5 Implement simple consumer
new 8f7418ed Bugfix: ICollection is read-only
new 44943d58 Polish logs
new 70282e85 Add Client#GetTopics
new 85ae3d54 Add more logs
new 7ce29d7d Notify remote endpoints that current client is terminated
new 6cde562e Add error log for scheduled task
new 30c1832b Implement Client#OnVerrifyMessageCommand and
Client#OnPrintThreadStackTraceCommand
new 7de5b395 Implement transaction message
new c9e3d21f Implement Producer#send with transaction
new 7be8d6da Add more stats info
new d7a0a5c6 Add more method for IClientConfig
new d7072119 Polish code
new 2f734d63 Polish code
new ebd236ad Make simpleconsumer works
new b2ee3b31 Polish code
new e272ee3d Add nonce for TelemetryCommand
new f5c2878a Add state machine for rocketmq producer/simpleConsumer
new 15007046 Apply state machine in transactional message
new f4e4647c Add more response code cases
new e3fbe1db Implement ExponentialBackoffRetryPolicy
new 520bd4f2 Add license header
The 28 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:
csharp/examples/ProducerBenchmark.cs | 103 +++
csharp/examples/ProducerDelayMessageExample.cs | 30 +-
csharp/examples/ProducerFifoMessageExample.cs | 40 +-
csharp/examples/ProducerNormalMessageExample.cs | 35 +-
...ple.cs => ProducerTransactionMessageExample.cs} | 45 +-
csharp/examples/QuickStart.cs | 15 +-
csharp/examples/SimpleConsumerExample.cs | 47 +-
csharp/rocketmq-client-csharp/AccessPoint.cs | 74 ---
.../{Topic.cs => Address.cs} | 55 +-
.../AddressListEqualityComparer.cs} | 40 +-
...aticCredentialsProvider.cs => AddressScheme.cs} | 33 +-
.../{ProcessQueue.cs => Broker.cs} | 34 +-
csharp/rocketmq-client-csharp/Client.cs | 700 ++++++++++-----------
csharp/rocketmq-client-csharp/ClientConfig.cs | 151 +----
.../ClientLoggerInterceptor.cs | 17 +-
csharp/rocketmq-client-csharp/ClientManager.cs | 285 ++-------
...{StaticCredentialsProvider.cs => ClientType.cs} | 30 +-
.../ConfigFileCredentialsProvider.cs | 5 +-
csharp/rocketmq-client-csharp/Consumer.cs | 104 +++
csharp/rocketmq-client-csharp/Endpoints.cs | 185 ++++++
.../BadRequestException.cs} | 20 +-
.../{SendReceipt.cs => Error/ClientException.cs} | 29 +-
.../ForbiddenException.cs} | 20 +-
.../InternalErrorException.cs} | 30 +-
.../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 | 6 +
csharp/rocketmq-client-csharp/IClient.cs | 47 +-
csharp/rocketmq-client-csharp/IClientConfig.cs | 15 +-
csharp/rocketmq-client-csharp/IClientManager.cs | 64 +-
.../rocketmq-client-csharp/ICredentialsProvider.cs | 6 +-
csharp/rocketmq-client-csharp/IProducer.cs | 30 -
.../{IClientConfig.cs => IRetryPolicy.cs} | 35 +-
.../{ExpressionType.cs => ITransaction.cs} | 10 +-
.../{IClientConfig.cs => ITransactionChecker.cs} | 23 +-
csharp/rocketmq-client-csharp/Message.cs | 85 +--
.../rocketmq-client-csharp/MessageIdGenerator.cs | 26 +-
csharp/rocketmq-client-csharp/MessageQueue.cs | 72 +++
csharp/rocketmq-client-csharp/MessageType.cs | 38 +-
csharp/rocketmq-client-csharp/MessageView.cs | 194 ++++++
csharp/rocketmq-client-csharp/MetadataConstants.cs | 66 +-
.../MqEncoding.cs} | 27 +-
csharp/rocketmq-client-csharp/MqLogManager.cs | 14 +-
csharp/rocketmq-client-csharp/Permission.cs | 93 +++
csharp/rocketmq-client-csharp/Producer.cs | 382 ++++++-----
.../rocketmq-client-csharp/PublishLoadBalancer.cs | 127 ----
csharp/rocketmq-client-csharp/Publishing.cs | 4 +-
.../PublishingLoadBalancer.cs | 97 +++
csharp/rocketmq-client-csharp/PublishingMessage.cs | 116 ++++
.../rocketmq-client-csharp/PublishingSettings.cs | 85 +++
...IMessageListener.cs => ReceiveMessageResult.cs} | 14 +-
.../{SendReceipt.cs => Resource.cs} | 35 +-
csharp/rocketmq-client-csharp/RpcClient.cs | 54 +-
csharp/rocketmq-client-csharp/SendReceipt.cs | 46 +-
csharp/rocketmq-client-csharp/SendStatus.cs | 27 -
csharp/rocketmq-client-csharp/SequenceGenerator.cs | 131 ----
csharp/rocketmq-client-csharp/Session.cs | 167 ++---
csharp/rocketmq-client-csharp/Settings.cs | 59 ++
csharp/rocketmq-client-csharp/Signature.cs | 62 +-
csharp/rocketmq-client-csharp/SimpleConsumer.cs | 384 +++++------
.../SimpleSubscriptionSettings.cs | 99 +++
.../{MessageType.cs => State.cs} | 12 +-
.../StaticCredentialsProvider.cs | 13 +-
csharp/rocketmq-client-csharp/StatusChecker.cs | 110 ++++
.../SubscriptionLoadBalancer.cs | 37 +-
csharp/rocketmq-client-csharp/TopicRouteData.cs | 45 +-
.../rocketmq-client-csharp/TopicRouteException.cs | 1 +
csharp/rocketmq-client-csharp/Transaction.cs | 131 ++++
...{ExpressionType.cs => TransactionResolution.cs} | 10 +-
.../UserAgent.cs} | 37 +-
csharp/rocketmq-client-csharp/Utilities.cs | 77 ++-
.../rocketmq-client-csharp.nlog | 4 +-
csharp/tests/ClientManagerTest.cs | 58 --
csharp/tests/ConfigFileCredentialsProviderTest.cs | 2 +-
csharp/tests/DateTimeTest.cs | 2 +-
.../{ClientConfigTest.cs => EndpointsTest.cs} | 17 +-
csharp/tests/MessageIdGeneratorTest.cs | 4 +-
csharp/tests/MessageTest.cs | 2 -
csharp/tests/ProducerTest.cs | 189 ------
csharp/tests/RpcClientTest.cs | 146 -----
csharp/tests/SendResultTest.cs | 21 +-
csharp/tests/SignatureTest.cs | 23 +-
csharp/tests/SimpleConsumerTest.cs | 97 ---
csharp/tests/StaticCredentialsProviderTest.cs | 40 --
csharp/tests/UnitTest1.cs | 57 +-
93 files changed, 3346 insertions(+), 2911 deletions(-)
create mode 100644 csharp/examples/ProducerBenchmark.cs
copy csharp/examples/{ProducerNormalMessageExample.cs =>
ProducerTransactionMessageExample.cs} (54%)
delete mode 100644 csharp/rocketmq-client-csharp/AccessPoint.cs
copy csharp/rocketmq-client-csharp/{Topic.cs => Address.cs} (59%)
copy csharp/{tests/SequenceGeneratorTest.cs =>
rocketmq-client-csharp/AddressListEqualityComparer.cs} (58%)
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
AddressScheme.cs} (58%)
copy csharp/rocketmq-client-csharp/{ProcessQueue.cs => Broker.cs} (62%)
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
ClientType.cs} (59%)
create mode 100644 csharp/rocketmq-client-csharp/Consumer.cs
create mode 100644 csharp/rocketmq-client-csharp/Endpoints.cs
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
Error/BadRequestException.cs} (64%)
copy csharp/rocketmq-client-csharp/{SendReceipt.cs =>
Error/ClientException.cs} (57%)
copy csharp/rocketmq-client-csharp/{StaticCredentialsProvider.cs =>
Error/ForbiddenException.cs} (64%)
copy csharp/rocketmq-client-csharp/{SendReceipt.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%)
rename 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
delete mode 100644 csharp/rocketmq-client-csharp/IProducer.cs
copy csharp/rocketmq-client-csharp/{IClientConfig.cs => IRetryPolicy.cs} (50%)
copy csharp/rocketmq-client-csharp/{ExpressionType.cs => ITransaction.cs} (91%)
copy 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
copy csharp/{tests/DateTimeTest.cs => rocketmq-client-csharp/MqEncoding.cs}
(65%)
create mode 100644 csharp/rocketmq-client-csharp/Permission.cs
delete mode 100644 csharp/rocketmq-client-csharp/PublishLoadBalancer.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} (57%)
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/Settings.cs
create mode 100644 csharp/rocketmq-client-csharp/SimpleSubscriptionSettings.cs
copy csharp/rocketmq-client-csharp/{MessageType.cs => State.cs} (87%)
create mode 100644 csharp/rocketmq-client-csharp/StatusChecker.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} (59%)
delete mode 100644 csharp/tests/ClientManagerTest.cs
rename csharp/tests/{ClientConfigTest.cs => EndpointsTest.cs} (73%)
delete mode 100644 csharp/tests/ProducerTest.cs
delete mode 100644 csharp/tests/RpcClientTest.cs
delete mode 100644 csharp/tests/SimpleConsumerTest.cs
delete mode 100644 csharp/tests/StaticCredentialsProviderTest.cs
