Allow ReceiveMessage to auto deserialize Json/Messagepack.

houseofcat · Apr 12, 2024 · 184395d · 184395d
1 parent 8e7a6c1
commit 184395d
Show file tree

Hide file tree

Showing 4 changed files with 21 additions and 0 deletions.
diff --git a/src/HouseofCat.RabbitMQ/Constants.cs b/src/HouseofCat.RabbitMQ/Constants.cs
@@ -10,6 +10,7 @@ public static class Constants
     public const string HeaderValueForContentTypeBinary = "application/octet-stream";
     public const string HeaderValueForContentTypePlainText = "text/plain";
     public const string HeaderValueForContentTypeJson = "application/json";
+    public const string HeaderValueForContentTypeMessagePack = "application/msgpack";
     public static string HeaderForObjectType { get; set; } = "X-RD-OBJECTTYPE";
     public static string HeaderValueForMessageObjectType { get; set; } = "IMESSAGE";
 

diff --git a/src/HouseofCat.RabbitMQ/Messages/ReceivedMessage.cs b/src/HouseofCat.RabbitMQ/Messages/ReceivedMessage.cs
@@ -1,3 +1,4 @@
+using HouseofCat.Serialization;
 using RabbitMQ.Client;
 using RabbitMQ.Client.Events;
 using System;
@@ -122,6 +123,14 @@ private void ReadHeaders()
                         catch
                         { FailedToDeserialize = true; }
                         break;
+                    case Constants.HeaderValueForContentTypeMessagePack:
+                        try
+                        {
+                            Message = MessagePackProvider.GlobalDeserialize<Message>(Body);
+                        }
+                        catch
+                        { FailedToDeserialize = true; }
+                        break;
                     case Constants.HeaderValueForContentTypeBinary:
                     case Constants.HeaderValueForContentTypePlainText:
                     default:

diff --git a/src/HouseofCat.Serialization/MessagePackProvider.cs b/src/HouseofCat.Serialization/MessagePackProvider.cs
@@ -10,11 +10,20 @@ public class MessagePackProvider : ISerializationProvider
 {
     private readonly MessagePackSerializerOptions _options;
 
+    // After nearly a decade, they haven't made their mind up. Tired of waiting.
+    // https://github.com/msgpack/msgpack/issues/194
+    public string ContentType { get; private set; } = "application/msgpack";
+
     public MessagePackProvider(MessagePackSerializerOptions options = null)
     {
         _options = options;
     }
 
+    public static TOut GlobalDeserialize<TOut>(ReadOnlyMemory<byte> input, MessagePackSerializerOptions options = null)
+    {
+        return MessagePackSerializer.Deserialize<TOut>(input, options);
+    }
+
     public ReadOnlyMemory<byte> Serialize<TIn>(TIn input)
     {
         return MessagePackSerializer.Serialize(input, _options);

diff --git a/src/HouseofCat.Serialization/NewtonsoftJsonProvider.cs b/src/HouseofCat.Serialization/NewtonsoftJsonProvider.cs
@@ -11,6 +11,8 @@ public sealed class NewtonsoftJsonProvider : ISerializationProvider
 {
     private readonly JsonSerializer _jsonSerializer = new JsonSerializer();
 
+    public string ContentType { get; private set; } = "application/json";
+
     public TOut Deserialize<TOut>(ReadOnlyMemory<byte> input)
     {
         Guard.AgainstEmpty(input, nameof(input));