Skip to content

Instantly share code, notes, and snippets.

@tomkerkhove

tomkerkhove/Arcus Messaging

Created July 13, 2021 07:33
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save tomkerkhove/203094677acad825466635e7437e4aab to your computer and use it in GitHub Desktop.
Save tomkerkhove/203094677acad825466635e7437e4aab to your computer and use it in GitHub Desktop.
Download ZIP
Raw
Arcus Messaging
[07:20:19 WRN] {"MetricName": "Message Queued Duration", "MetricValue": 4.7017036, "Timestamp": "2021-07-13T07:20:19.3774468 +00:00", "Context": {"DeliveryCount": 1, "TelemetryType": "Metrics"}, "$type": "MetricLogEntry"}
[07:20:19 INF] Processing initial firmware set messages for device 352554100004969...
[07:20:19 INF] Configured URL for Device Registry URL is http://hyperion.platform.gateway.deviceregistry.api:99
[07:20:19 INF] Start processing HTTP request POST http://hyperion.platform.gateway.deviceregistry.api:99/api/v1/devices/G3/352554100004969/firmware
[07:20:19 INF] Sending HTTP request POST http://hyperion.platform.gateway.deviceregistry.api:99/api/v1/devices/G3/352554100004969/firmware
[07:20:19 INF] Received HTTP response after 21.9521ms - BadRequest
[07:20:19 INF] End processing HTTP request after 27.3684ms - BadRequest
[07:20:19 WRN] {"MetricName": "Message Processed", "MetricValue": 1, "Timestamp": "2021-07-13T07:20:19.6107110 +00:00", "Context": {"IsSuccessful": false, "MessageHandler": "Initial Firmware Set", "TelemetryType": "Metrics"}, "$type": "MetricLogEntry"}
[07:20:19 WRN] {"MetricName": "Message Processing Duration", "MetricValue": 0.2314115, "Timestamp": "2021-07-13T07:20:19.6133381 +00:00", "Context": {"IsSuccessful": false, "MessageHandler": "Initial Firmware Set", "TelemetryType": "Metrics"}, "$type": "MetricLogEntry"}
[07:20:19 ERR] Message handler 'InitialFirmwareSetNotificationMessageHandler' failed to process 'InitialFirmwareSetNotificationV1Message' due to a thrown exception
Hyperion.Platform.Gateway.Core.Http.Exceptions.ServiceCommunicationException: The API returned a Bad request for the endpoint api/v1/devices/G3/352554100004969/firmware with response {"errors":{"TransactionId":["The TransactionId field is required."]},"type":"https://tools.ietf.org/html/rfc7231#section-6.5.1","title":"One or more validation errors occurred.","status":400,"traceId":"00-4102bbf1ddf29944b147f7361049c1fc-70873d75a0b87548-00"}
at Hyperion.Platform.Gateway.Integrations.DeviceRegistry.DeviceRegistryApiClient.SendHttpRequestAsync(Url uri, Func`1 interaction) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.Integrations.DeviceRegistry\DeviceRegistryApiClient.cs:line 483
at Hyperion.Platform.Gateway.Integrations.DeviceRegistry.DeviceRegistryApiClient.SendFireAndForgetPostRequestAsync(Url resourceUri, Object requestPayload, String operationName, Dictionary`2 telemetryContext) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.Integrations.DeviceRegistry\DeviceRegistryApiClient.cs:line 466
at Hyperion.Platform.Gateway.Integrations.DeviceRegistry.DeviceRegistryApiClient.InitialFirmwareWasSetAsync(SupportedDeviceTypes deviceType, String deviceId, InitialFirmwareSetNotification notification) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.Integrations.DeviceRegistry\DeviceRegistryApiClient.cs:line 103
at Hyperion.Platform.Gateway.DeviceGateway.MessageHandlers.InitialFirmwareSetNotificationMessageHandler.ProcessReceivedMessageAsync(InitialFirmwareSetNotificationV1Message message, AzureServiceBusMessageContext messageContext) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.DeviceGateway\MessageHandlers\InitialFirmwareSetNotificationMessageHandler.cs:line 51
at Hyperion.Platform.Gateway.DeviceGateway.MessageHandlers.Foundation.ExtendedAzureServiceBusMessageHandler`1.ProcessMessageAsync(TMessage message, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.DeviceGateway\MessageHandlers\Foundation\ExtendedAzureServiceBusMessageHandler.cs:line 62
at Arcus.Messaging.Pumps.Abstractions.MessageHandling.MessageHandlerRegistration`2.ProcessMessageAsync(TMessage message, TMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken)
at Arcus.Messaging.Pumps.Abstractions.MessageHandling.MessageHandler.ProcessMessageAsync[TMessageContext](Object message, TMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken)
[07:20:22 WRN] {"MetricName": "Message Queued Duration", "MetricValue": 7.3929992, "Timestamp": "2021-07-13T07:20:22.2675869 +00:00", "Context": {"DeliveryCount": 1, "TelemetryType": "Metrics"}, "$type": "MetricLogEntry"}
[07:20:22 WRN] No matching message handler for message d5a7889d-9e70-4f91-8446-6dd1c8ec8395
[07:20:22 WRN] {"MetricName": "Message Routing Failure", "MetricValue": 1, "Timestamp": "2021-07-13T07:20:22.3131554 +00:00", "Context": {"TelemetryType": "Metrics"}, "$type": "MetricLogEntry"}
[07:20:22 INF] Message deadlettered due to message routing failure
[07:20:22 FTL] Unable to process message with ID 'd5a7889d-9e70-4f91-8446-6dd1c8ec8395'
System.Exception: No matching message handler for message d5a7889d-9e70-4f91-8446-6dd1c8ec8395
at Hyperion.Platform.Gateway.DeviceGateway.MessageHandlers.Foundation.FallbackMessageHandler.ProcessMessageAsync(Message message, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.DeviceGateway\MessageHandlers\Foundation\FallbackMessageHandler.cs:line 55
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithPotentialFallbackAsync(Message message, String messageBody, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken)
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithFallbackAsync(Message message, CancellationToken cancellationToken, MessageCorrelationInfo correlationInfo)
[07:20:22 FTL] Unable to process message from toms-queue with client MessageReceiver1toms-queue
System.Exception: No matching message handler for message d5a7889d-9e70-4f91-8446-6dd1c8ec8395
at Hyperion.Platform.Gateway.DeviceGateway.MessageHandlers.Foundation.FallbackMessageHandler.ProcessMessageAsync(Message message, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.DeviceGateway\MessageHandlers\Foundation\FallbackMessageHandler.cs:line 55
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithPotentialFallbackAsync(Message message, String messageBody, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken)
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithFallbackAsync(Message message, CancellationToken cancellationToken, MessageCorrelationInfo correlationInfo)
[07:20:22 FTL] Unable to process message from toms-queue with client MessageReceiver1toms-queue
System.Exception: No matching message handler for message d5a7889d-9e70-4f91-8446-6dd1c8ec8395
at Hyperion.Platform.Gateway.DeviceGateway.MessageHandlers.Foundation.FallbackMessageHandler.ProcessMessageAsync(Message message, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.DeviceGateway\MessageHandlers\Foundation\FallbackMessageHandler.cs:line 55
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithPotentialFallbackAsync(Message message, String messageBody, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken)
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithFallbackAsync(Message message, CancellationToken cancellationToken, MessageCorrelationInfo correlationInfo)
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithFallbackAsync(Message message, CancellationToken cancellationToken, MessageCorrelationInfo correlationInfo)
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.HandleMessageAsync(Message message, CancellationToken cancellationToken)
at Microsoft.Azure.ServiceBus.MessageReceivePump.MessageDispatchTask(Message message)
[07:20:22 FTL] Unable to process message from toms-queue with client MessageReceiver1toms-queue
Microsoft.Azure.ServiceBus.MessageLockLostException: The lock supplied is invalid. Either the lock expired, or the message has already been removed from the queue, or was received by a different receiver instance.
at Microsoft.Azure.ServiceBus.Core.MessageReceiver.DisposeMessagesAsync(IEnumerable`1 lockTokens, Outcome outcome)
at Microsoft.Azure.ServiceBus.RetryPolicy.RunOperation(Func`1 operation, TimeSpan operationTimeout)
at Microsoft.Azure.ServiceBus.RetryPolicy.RunOperation(Func`1 operation, TimeSpan operationTimeout)
at Microsoft.Azure.ServiceBus.Core.MessageReceiver.AbandonAsync(String lockToken, IDictionary`2 propertiesToModify)
at Microsoft.Azure.ServiceBus.MessageReceivePump.AbandonMessageIfNeededAsync(Message message)
[07:21:06 WRN] {"MetricName": "Message Queued Duration", "MetricValue": 12.0544633, "Timestamp": "2021-07-13T07:21:06.5138123 +00:00", "Context": {"DeliveryCount": 1, "TelemetryType": "Metrics"}, "$type": "MetricLogEntry"}
[07:21:06 INF] Processing initial firmware set messages for device 352554100004969...
[07:21:06 INF] Configured URL for Device Registry URL is http://hyperion.platform.gateway.deviceregistry.api:99
[07:21:06 INF] Start processing HTTP request POST http://hyperion.platform.gateway.deviceregistry.api:99/api/v1/devices/G3/352554100004969/firmware
[07:21:06 INF] Sending HTTP request POST http://hyperion.platform.gateway.deviceregistry.api:99/api/v1/devices/G3/352554100004969/firmware
[07:21:06 INF] Received HTTP response after 11.6902ms - BadRequest
[07:21:06 INF] End processing HTTP request after 20.7085ms - BadRequest
[07:21:06 WRN] {"MetricName": "Message Processed", "MetricValue": 1, "Timestamp": "2021-07-13T07:21:06.7375149 +00:00", "Context": {"IsSuccessful": false, "MessageHandler": "Initial Firmware Set", "TelemetryType": "Metrics"}, "$type": "MetricLogEntry"}
[07:21:06 WRN] {"MetricName": "Message Processing Duration", "MetricValue": 0.2187486, "Timestamp": "2021-07-13T07:21:06.7396752 +00:00", "Context": {"IsSuccessful": false, "MessageHandler": "Initial Firmware Set", "TelemetryType": "Metrics"}, "$type": "MetricLogEntry"}
[07:21:06 ERR] Message handler 'InitialFirmwareSetNotificationMessageHandler' failed to process 'InitialFirmwareSetNotificationV1Message' due to a thrown exception
Hyperion.Platform.Gateway.Core.Http.Exceptions.ServiceCommunicationException: The API returned a Bad request for the endpoint api/v1/devices/G3/352554100004969/firmware with response {"errors":{"TransactionId":["The TransactionId field is required."]},"type":"https://tools.ietf.org/html/rfc7231#section-6.5.1","title":"One or more validation errors occurred.","status":400,"traceId":"00-3e1d212a2dfb3d45b7ffd23564f37d86-bed90b07809abd45-00"}
at Hyperion.Platform.Gateway.Integrations.DeviceRegistry.DeviceRegistryApiClient.SendHttpRequestAsync(Url uri, Func`1 interaction) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.Integrations.DeviceRegistry\DeviceRegistryApiClient.cs:line 483
at Hyperion.Platform.Gateway.Integrations.DeviceRegistry.DeviceRegistryApiClient.SendFireAndForgetPostRequestAsync(Url resourceUri, Object requestPayload, String operationName, Dictionary`2 telemetryContext) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.Integrations.DeviceRegistry\DeviceRegistryApiClient.cs:line 466
at Hyperion.Platform.Gateway.Integrations.DeviceRegistry.DeviceRegistryApiClient.InitialFirmwareWasSetAsync(SupportedDeviceTypes deviceType, String deviceId, InitialFirmwareSetNotification notification) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.Integrations.DeviceRegistry\DeviceRegistryApiClient.cs:line 103
at Hyperion.Platform.Gateway.DeviceGateway.MessageHandlers.InitialFirmwareSetNotificationMessageHandler.ProcessReceivedMessageAsync(InitialFirmwareSetNotificationV1Message message, AzureServiceBusMessageContext messageContext) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.DeviceGateway\MessageHandlers\InitialFirmwareSetNotificationMessageHandler.cs:line 51
at Hyperion.Platform.Gateway.DeviceGateway.MessageHandlers.Foundation.ExtendedAzureServiceBusMessageHandler`1.ProcessMessageAsync(TMessage message, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.DeviceGateway\MessageHandlers\Foundation\ExtendedAzureServiceBusMessageHandler.cs:line 62
at Arcus.Messaging.Pumps.Abstractions.MessageHandling.MessageHandlerRegistration`2.ProcessMessageAsync(TMessage message, TMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken)
at Arcus.Messaging.Pumps.Abstractions.MessageHandling.MessageHandler.ProcessMessageAsync[TMessageContext](Object message, TMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken)
[07:21:17 WRN] {"MetricName": "Message Queued Duration", "MetricValue": 23.293894, "Timestamp": "2021-07-13T07:21:17.5110535 +00:00", "Context": {"DeliveryCount": 1, "TelemetryType": "Metrics"}, "$type": "MetricLogEntry"}
[07:21:17 WRN] No matching message handler for message d7888b3d-394b-4835-9b17-af8298d1c648
[07:21:17 WRN] {"MetricName": "Message Routing Failure", "MetricValue": 1, "Timestamp": "2021-07-13T07:21:17.5543040 +00:00", "Context": {"TelemetryType": "Metrics"}, "$type": "MetricLogEntry"}
[07:21:17 INF] Message deadlettered due to message routing failure
[07:21:17 FTL] Unable to process message with ID 'd7888b3d-394b-4835-9b17-af8298d1c648'
System.Exception: No matching message handler for message d7888b3d-394b-4835-9b17-af8298d1c648
at Hyperion.Platform.Gateway.DeviceGateway.MessageHandlers.Foundation.FallbackMessageHandler.ProcessMessageAsync(Message message, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.DeviceGateway\MessageHandlers\Foundation\FallbackMessageHandler.cs:line 55
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithPotentialFallbackAsync(Message message, String messageBody, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken)
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithFallbackAsync(Message message, CancellationToken cancellationToken, MessageCorrelationInfo correlationInfo)
[07:21:17 FTL] Unable to process message from toms-queue with client MessageReceiver1toms-queue
System.Exception: No matching message handler for message d7888b3d-394b-4835-9b17-af8298d1c648
at Hyperion.Platform.Gateway.DeviceGateway.MessageHandlers.Foundation.FallbackMessageHandler.ProcessMessageAsync(Message message, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.DeviceGateway\MessageHandlers\Foundation\FallbackMessageHandler.cs:line 55
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithPotentialFallbackAsync(Message message, String messageBody, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken)
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithFallbackAsync(Message message, CancellationToken cancellationToken, MessageCorrelationInfo correlationInfo)
[07:21:17 FTL] Unable to process message from toms-queue with client MessageReceiver1toms-queue
System.Exception: No matching message handler for message d7888b3d-394b-4835-9b17-af8298d1c648
at Hyperion.Platform.Gateway.DeviceGateway.MessageHandlers.Foundation.FallbackMessageHandler.ProcessMessageAsync(Message message, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken) in C:\Code\Customers\hyperion\exedra-gateways-g3\src\Hyperion.Platform.Gateway.DeviceGateway\MessageHandlers\Foundation\FallbackMessageHandler.cs:line 55
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithPotentialFallbackAsync(Message message, String messageBody, AzureServiceBusMessageContext messageContext, MessageCorrelationInfo correlationInfo, CancellationToken cancellationToken)
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithFallbackAsync(Message message, CancellationToken cancellationToken, MessageCorrelationInfo correlationInfo)
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.ProcessMessageWithFallbackAsync(Message message, CancellationToken cancellationToken, MessageCorrelationInfo correlationInfo)
at Arcus.Messaging.Pumps.ServiceBus.AzureServiceBusMessagePump.HandleMessageAsync(Message message, CancellationToken cancellationToken)
at Microsoft.Azure.ServiceBus.MessageReceivePump.MessageDispatchTask(Message message)
[07:21:17 FTL] Unable to process message from toms-queue with client MessageReceiver1toms-queue
Microsoft.Azure.ServiceBus.MessageLockLostException: The lock supplied is invalid. Either the lock expired, or the message has already been removed from the queue, or was received by a different receiver instance.
at Microsoft.Azure.ServiceBus.Core.MessageReceiver.DisposeMessagesAsync(IEnumerable`1 lockTokens, Outcome outcome)
at Microsoft.Azure.ServiceBus.RetryPolicy.RunOperation(Func`1 operation, TimeSpan operationTimeout)
at Microsoft.Azure.ServiceBus.RetryPolicy.RunOperation(Func`1 operation, TimeSpan operationTimeout)
at Microsoft.Azure.ServiceBus.Core.MessageReceiver.AbandonAsync(String lockToken, IDictionary`2 propertiesToModify)
at Microsoft.Azure.ServiceBus.MessageReceivePump.AbandonMessageIfNeededAsync(Message message)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment