Fixing formatting.

rabbitmq · Mar 14, 2023 · dd8db20 · dd8db20
1 parent c007da0
commit dd8db20
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 9 deletions.
diff --git a/projects/RabbitMQ.Client/client/impl/Connection.cs b/projects/RabbitMQ.Client/client/impl/Connection.cs
@@ -415,7 +415,7 @@ internal void Write(ReadOnlyMemory<byte> memory)
                     {
                         activity.SetTag("net.sock.family", "inet6");
                     }
-                    
+
                     activity
                         .SetTag("net.sock.peer.addr", ipEndpoint.Address.ToString())
                         .SetTag("net.peer.port", ipEndpoint.Port.ToString());
@@ -427,7 +427,7 @@ internal void Write(ReadOnlyMemory<byte> memory)
                     {
                         activity.SetTag("net.sock.family", "inet6");
                     }
-                    
+
                     activity
                         .SetTag("net.sock.host.addr", localEndpoint.Address.ToString())
                         .SetTag("net.host.port", localEndpoint.Port.ToString());

diff --git a/projects/RabbitMQ.Client/client/impl/RabbitMQActivitySource.cs b/projects/RabbitMQ.Client/client/impl/RabbitMQActivitySource.cs
@@ -1,12 +1,9 @@
 using System;
 using System.Collections.Generic;
 using System.Diagnostics;
-using System.Linq;
 using System.Reflection;
 using System.Text;
 using System.Threading;
-using System.Threading.Tasks;
-
 using RabbitMQ.Client.Events;
 using RabbitMQ.Client.Framing.Impl;
 
@@ -95,7 +92,7 @@ internal static Activity Process(BasicDeliverEventArgs deliverEventArgs)
                             Activity.Current?.SetBaggage(item.Key, item.Value);
                         }
                     }
-                    
+
                     PopulateMessagingTags("process", deliverEventArgs.RoutingKey, deliverEventArgs.Exchange, deliverEventArgs.DeliveryTag, deliverEventArgs.BasicProperties, deliverEventArgs.Body.Length, activity);
                 }
 
@@ -128,7 +125,7 @@ private static Activity StartRabbitMQActivity(string name, ActivityKind kind, Ac
 
         private static void PopulateMessagingTags(string operation, string routingKey, string exchange, ulong deliveryTag, IReadOnlyBasicProperties readOnlyBasicProperties, int bodySize, Activity activity)
         {
-            
+
             activity
             .SetTag(MessagingOperation, operation)
             .SetTag(MessagingDestination, string.IsNullOrEmpty(exchange) ? "amq.default" : exchange)
@@ -149,7 +146,7 @@ private static void PopulateMessagingTags(string operation, string routingKey, s
                 }
             }
         }
-        
+
         private static void ExtractTraceIdAndState(object carrier, string name, out string value, out IEnumerable<string> values)
         {
             if (carrier is IReadOnlyBasicProperties props && props.Headers is not null && props.Headers.TryGetValue(name, out object propsVal) && propsVal is byte[] bytes)

diff --git a/projects/Unit/ActivitySource/TestActivitySource.cs b/projects/Unit/ActivitySource/TestActivitySource.cs
@@ -103,7 +103,7 @@ void AssertIntTagGreaterThanZero(Activity activity, string name)
                 AssertStringTagNotNullOrEmpty(sendActivity, "net.sock.host.addr");
                 AssertIntTagGreaterThanZero(sendActivity, "net.host.port");
                 AssertStringTagEquals(sendActivity, "net.transport", "ip_tcp");
-                AssertStringTagEquals(sendActivity,  RabbitMQActivitySource.MessagingSystem, "rabbitmq");
+                AssertStringTagEquals(sendActivity, RabbitMQActivitySource.MessagingSystem, "rabbitmq");
                 AssertStringTagEquals(sendActivity, RabbitMQActivitySource.ProtocolName, "amqp");
                 AssertStringTagEquals(sendActivity, RabbitMQActivitySource.ProtocolVersion, "0.9.1");
                 AssertStringTagEquals(sendActivity, RabbitMQActivitySource.MessagingDestination, "amq.default");