Add support for using different registered Content Types in Rabbit MQ

mythz · mythz · commit 58326713413b · 2017-07-25T16:36:58.000-04:00
diff --git a/src/ServiceStack.RabbitMq/RabbitMqExtensions.cs b/src/ServiceStack.RabbitMq/RabbitMqExtensions.cs
@@ -214,8 +214,13 @@ public static IMessage<T> ToMessage<T>(this BasicGetResult msgResult)
                 return null;
 
             var props = msgResult.BasicProperties;
-            var json = msgResult.Body.FromUtf8Bytes();
-            var body = json.FromJson<T>();
+            var deserializer = HostContext.ContentTypes.GetStreamDeserializer(props.ContentType ?? MimeTypes.Json);
+            if (deserializer == null)
+                throw new NotSupportedException("Unknown Content-Type: " + props.ContentType);
+            
+            var ms = MemoryStreamFactory.GetStream(msgResult.Body);
+            var body = (T)deserializer(typeof(T), ms);
+            ms.Dispose();
 
             var message = new Message<T>(body)
             {
