-
Notifications
You must be signed in to change notification settings - Fork 1
Desialize Message
Mostafa Biomee edited this page Oct 12, 2020
·
1 revision
public async Task<bool> HandleMessageAsync(string messageType, string message)
{
JObject messageObject = MessageSerializer.Deserialize(message);
try
{
switch (messageType)
{
case "CustomerRegistered":
await HandleAsync(messageObject.ToObject<CustomerRegistered>());
break;
}
}
catch(Exception ex)
{
string messageId = messageObject.Property("MessageId") != null ? messageObject.Property("MessageId").Value<string>() : "[unknown]";
Log.Error(ex, "Error while handling {MessageType} message with id {MessageId}.", messageType, messageId);
}
// always akcnowledge message - any errors need to be dealt with locally.
return true;
}