This is an automated email from the ASF dual-hosted git repository. aaronai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit f4e4647c78b427acb3215eb2a6ff7a23ea4eeb07 Author: Aaron Ai <[email protected]> AuthorDate: Wed Feb 22 19:07:02 2023 +0800 Add more response code cases --- csharp/rocketmq-client-csharp/MessageView.cs | 2 +- csharp/rocketmq-client-csharp/StatusChecker.cs | 8 +++++++- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/csharp/rocketmq-client-csharp/MessageView.cs b/csharp/rocketmq-client-csharp/MessageView.cs index b88c40b4..21cd3677 100644 --- a/csharp/rocketmq-client-csharp/MessageView.cs +++ b/csharp/rocketmq-client-csharp/MessageView.cs @@ -36,7 +36,7 @@ namespace Org.Apache.Rocketmq private readonly long _offset; private readonly bool _corrupted; - internal MessageView(string messageId, string topic, byte[] body, string tag, string messageGroup, + private MessageView(string messageId, string topic, byte[] body, string tag, string messageGroup, DateTime? deliveryTimestamp, List<string> keys, Dictionary<string, string> properties, string bornHost, DateTime bornTime, int deliveryAttempt, MessageQueue messageQueue, string receiptHandle, long offset, bool corrupted) diff --git a/csharp/rocketmq-client-csharp/StatusChecker.cs b/csharp/rocketmq-client-csharp/StatusChecker.cs index 2802fd78..abc0b160 100644 --- a/csharp/rocketmq-client-csharp/StatusChecker.cs +++ b/csharp/rocketmq-client-csharp/StatusChecker.cs @@ -31,7 +31,7 @@ namespace Org.Apache.Rocketmq var statusCode = status.Code; var statusMessage = status.Message; - // TODO + // TODO: add request-id. switch (statusCode) { case Proto.Code.Ok: @@ -95,6 +95,12 @@ namespace Org.Apache.Rocketmq case Proto.Code.VersionUnsupported: case Proto.Code.VerifyFifoMessageUnsupported: throw new UnsupportedException((int)statusCode, statusMessage); + // Not used code. + case Proto.Code.RequestTimeout: + case Proto.Code.PreconditionFailed: + case Proto.Code.NotImplemented: + case Proto.Code.FailedToConsumeMessage: + case Proto.Code.Unspecified: default: Logger.Warn($"Unrecognized status code={statusCode}, statusMessage={statusMessage}"); throw new UnsupportedException((int)statusCode, statusMessage);
