@@ -92,7 +92,8 @@ public async Task TestPublisherAndConsumerActivityTags(bool useRoutingKeyAsOpera
92
92
byte [ ] sendBody = Encoding . UTF8 . GetBytes ( "hi" ) ;
93
93
byte [ ] consumeBody = null ;
94
94
var consumer = new EventingBasicConsumer ( _channel ) ;
95
- var consumerReceivedTcs = new TaskCompletionSource < bool > ( TaskCreationOptions . RunContinuationsAsynchronously ) ;
95
+ var consumerReceivedTcs =
96
+ new TaskCompletionSource < bool > ( TaskCreationOptions . RunContinuationsAsynchronously ) ;
96
97
consumer . Received += ( o , a ) =>
97
98
{
98
99
consumeBody = a . Body . ToArray ( ) ;
@@ -130,7 +131,8 @@ public async Task TestPublisherAndConsumerActivityTagsAsync(bool useRoutingKeyAs
130
131
byte [ ] sendBody = Encoding . UTF8 . GetBytes ( "hi" ) ;
131
132
byte [ ] consumeBody = null ;
132
133
var consumer = new EventingBasicConsumer ( _channel ) ;
133
- var consumerReceivedTcs = new TaskCompletionSource < bool > ( TaskCreationOptions . RunContinuationsAsynchronously ) ;
134
+ var consumerReceivedTcs =
135
+ new TaskCompletionSource < bool > ( TaskCreationOptions . RunContinuationsAsynchronously ) ;
134
136
consumer . Received += ( o , a ) =>
135
137
{
136
138
consumeBody = a . Body . ToArray ( ) ;
@@ -205,14 +207,14 @@ private void AssertActivityData(bool useRoutingKeyAsOperationName, string queueN
205
207
string childName = isDeliver ? "deliver" : "receive" ;
206
208
Activity [ ] activities = activityList . ToArray ( ) ;
207
209
Assert . NotEmpty ( activities ) ;
208
- foreach ( var item in activities )
210
+ foreach ( var item in activities )
209
211
{
210
212
_output . WriteLine (
211
213
$ "{ item . Context . TraceId } : { item . OperationName } ") ;
212
214
_output . WriteLine ( $ " Tags: { string . Join ( ", " , item . Tags . Select ( x => $ "{ x . Key } : { x . Value } ") ) } ") ;
213
215
_output . WriteLine ( $ " Links: { string . Join ( ", " , item . Links . Select ( x => $ "{ x . Context . TraceId } ") ) } ") ;
214
216
}
215
-
217
+
216
218
Activity sendActivity = activities . First ( x =>
217
219
x . OperationName == ( useRoutingKeyAsOperationName ? $ "{ queueName } publish" : "publish" ) &&
218
220
x . GetTagItem ( RabbitMQActivitySource . MessagingDestinationRoutingKey ) is string routingKeyTag &&
0 commit comments