You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/06/28 08:22:59 UTC
[rocketmq-client-csharp] branch observability updated: Fix minor issue
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch observability
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-csharp.git
The following commit(s) were added to refs/heads/observability by this push:
new dc687e6 Fix minor issue
dc687e6 is described below
commit dc687e6b27e0ca01d297913482de62f363211ac6
Author: Li Zhanhui <li...@gmail.com>
AuthorDate: Tue Jun 28 16:22:51 2022 +0800
Fix minor issue
---
rocketmq-client-csharp/Producer.cs | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/rocketmq-client-csharp/Producer.cs b/rocketmq-client-csharp/Producer.cs
index 8d2da7d..93938cd 100644
--- a/rocketmq-client-csharp/Producer.cs
+++ b/rocketmq-client-csharp/Producer.cs
@@ -34,7 +34,7 @@ namespace Org.Apache.Rocketmq
public Producer(AccessPoint accessPoint, string resourceNamespace) : base(accessPoint, resourceNamespace)
{
_loadBalancer = new ConcurrentDictionary<string, PublishLoadBalancer>();
- _sendFailureTotal = MetricMeter.CreateCounter<UInt64>("rocketmq_send_failure_total");
+ _sendFailureTotal = MetricMeter.CreateCounter<long>("rocketmq_send_failure_total");
_sendLatency = MetricMeter.CreateHistogram<double>("rocketmq_send_success_cost_time",
description: "Measure the duration of publishing messages to brokers",
unit: "milliseconds");
@@ -174,7 +174,7 @@ namespace Org.Apache.Rocketmq
private readonly ConcurrentDictionary<string, PublishLoadBalancer> _loadBalancer;
- private readonly Counter<UInt64> _sendFailureTotal;
+ private readonly Counter<long> _sendFailureTotal;
private readonly Histogram<double> _sendLatency;
}
}
\ No newline at end of file