From 133ef01bf9a8ba5a3693dfafbaba0c77a0109dd6 Mon Sep 17 00:00:00 2001
From: Savorboard <yangxiaodong1214@126.com>
Date: Fri, 27 Oct 2017 16:39:48 +0800
Subject: [PATCH] Fixed serialized the message type bug. (#53)

---
 src/DotNetCore.CAP/Abstractions/CapPublisherBase.cs | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/src/DotNetCore.CAP/Abstractions/CapPublisherBase.cs b/src/DotNetCore.CAP/Abstractions/CapPublisherBase.cs
index 70f1d54..8018c37 100644
--- a/src/DotNetCore.CAP/Abstractions/CapPublisherBase.cs
+++ b/src/DotNetCore.CAP/Abstractions/CapPublisherBase.cs
@@ -68,10 +68,18 @@ namespace DotNetCore.CAP.Abstractions
 
         protected virtual string Serialize<T>(T obj, string callbackName = null)
         {
-            var serializer = (IContentSerializer)ServiceProvider.GetService(typeof(IContentSerializer));
             var packer = (IMessagePacker)ServiceProvider.GetService(typeof(IMessagePacker));
 
-            var content = serializer.Serialize(obj);
+            string content = string.Empty;
+            if (Helper.IsComplexType(obj.GetType()))
+            {
+                var serializer = (IContentSerializer)ServiceProvider.GetService(typeof(IContentSerializer));
+                content = serializer.Serialize(obj);
+            }
+            else
+            {
+                content = obj?.ToString();
+            }
 
             var message = new CapMessageDto(content)
             {