Fix processed message priority for metrics (#3330)

Azure · Jul 31, 2020 · 14aaee0 · 14aaee0
1 parent eed9c06
commit 14aaee0
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/edge-hub/src/Microsoft.Azure.Devices.Routing.Core/endpoints/StoringAsyncEndpointExecutor.cs b/edge-hub/src/Microsoft.Azure.Devices.Routing.Core/endpoints/StoringAsyncEndpointExecutor.cs
@@ -263,7 +263,10 @@ async Task SendMessagesPump()
                             {
                                 // Tag the message with the priority that we're currently
                                 // processing, so it can be used by metrics later
-                                messages.Select(m => m.ProcessedPriority = priority);
+                                foreach (IMessage msg in messages)
+                                {
+                                    msg.ProcessedPriority = priority;
+                                }
 
                                 Events.ProcessingMessages(this, messages, priority);
                                 await this.ProcessMessages(messages, fsm);