[ISSUE #919] Add transaction message retry attempt for C# client Producer (#921)

tsunghanjacktsai · web-flow · commit 214761b52ff7 · 2025-01-22T09:51:22.000+08:00
diff --git a/csharp/rocketmq-client-csharp/Producer.cs b/csharp/rocketmq-client-csharp/Producer.cs
@@ -254,14 +254,6 @@ private async Task<SendReceipt> Send0(PublishingMessage message, List<MessageQue
                         throw;
                     }
 
-                    if (MessageType.Transaction == message.MessageType)
-                    {
-                        Logger.LogError(e, "Failed to send transaction message, run out of attempt times, " +
-                                                  $"topic={message.Topic}, maxAttempt=1, attempt={attempt}, " +
-                                                  $"endpoints={endpoints}, messageId={message.MessageId}, clientId={ClientId}");
-                        throw;
-                    }
-
                     if (!(exception is TooManyRequestsException))
                     {
                         // Retry immediately if the request is not throttled.

Original file line number	Diff line number	Diff line change
`@@ -254,14 +254,6 @@ private async Task<SendReceipt> Send0(PublishingMessage message, List<MessageQue`
`254`	`254`	`throw;`
`255`	`255`	`}`
`256`	`256`
`257`		`- if (MessageType.Transaction == message.MessageType)`
`258`		`- {`
`259`		`- Logger.LogError(e, "Failed to send transaction message, run out of attempt times, " +`
`260`		`- $"topic={message.Topic}, maxAttempt=1, attempt={attempt}, " +`
`261`		`- $"endpoints={endpoints}, messageId={message.MessageId}, clientId={ClientId}");`
`262`		`- throw;`
`263`		`- }`
`264`		`-`
`265`	`257`	`if (!(exception is TooManyRequestsException))`
`266`	`258`	`{`
`267`	`259`	`// Retry immediately if the request is not throttled.`