Azure IoT Edge demo PipeMessage.cs

PipeMessage.cs

// This method is called whenever the module is sent a message from the EdgeHub. It just pipe the messages without any change.It prints all the incoming messages.
static async Task<MessageResponse> PipeMessage(Message message, object userContext) {
    
    int counterValue=Interlocked.Increment(ref _counter);
    var moduleClient=userContext as ModuleClient;
    byte[] messageBytes=message.GetBytes();
    string messageString=Encoding.UTF8.GetString(messageBytes);
    
    if (!string.IsNullOrEmpty(messageString)) {
        try {
            Log.Information($"Receiving Message: {messageString.TrimStart('"').TrimEnd('"').Replace('\\', ' ')}");
            Payload payload=JsonConvert.DeserializeObject<Payload>(messageString.TrimStart('"').TrimEnd('"').Replace("\\", String.Empty));
            await SaveData(payload); // save in database
        }
        catch (Exception ex) {
            Log.Error($"Error processing message: {ex}");
        }
    }
    return await Task.FromResult(MessageResponse.Completed);
}