Split Cap Message to CapSendMessage and CapReceivedMessage.

src/DotNetCore.CAP/Infrastructure/ConsistencyMessage.cs → src/DotNetCore.CAP/Infrastructure/CapMessage.cs

@@ -5,48 +5,42 @@ namespace DotNetCore.CAP.Infrastructure
     /// <summary>
     /// The default implementation of <see cref="ConsistencyMessage{TKey}"/> which uses a string as a primary key.
     /// </summary>
-    public class ConsistencyMessage
+    public abstract class CapMessage : MessageBase
     {
         /// <summary>
-        /// Initializes a new instance of <see cref="ConsistencyMessage"/>.
+        /// Initializes a new instance of <see cref="CapMessage"/>.
         /// </summary>
         /// <remarks>
         /// The Id property is initialized to from a new GUID string value.
         /// </remarks>
-        public ConsistencyMessage()
+        public CapMessage()
         {
             Id = Guid.NewGuid().ToString();
-            SendTime = DateTime.Now;
-            UpdateTime = SendTime;
-            Status = MessageStatus.WaitForSend;
+            Added = DateTime.Now;
         }
 
-        public string Id { get; set; }
-
-        public DateTime SendTime { get; set; }
+        public CapMessage(MessageBase message)
+        {
+            KeyName = message.KeyName;
+            Content = message.Content;
+        }
 
-        public string Topic { get; set; }
+        public string Id { get; set; }
 
-        public string Payload { get; set; }
+        public DateTime Added { get; set; }
 
-        public MessageStatus Status { get; set; }
+        public DateTime LastRun { get; set; }
 
-        public virtual DateTime? UpdateTime { get; set; }
+        public int Retries { get; set; }
 
-        public byte[] RowVersion { get; set; }
+        public string StateName { get; set; }
     }
 
-    /// <summary>
-    /// ConsistencyMessage consume status
-    /// </summary>
-    public enum MessageStatus
+    public struct StateName
     {
-        Deleted = 0,
-        WaitForSend = 1,
-        Processing = 2,
-        RollbackSuccessed = 3,
-        RollbackFailed = 4,
-        Successed = 5,
-        Received = 6
+        public const string Enqueued = nameof(Enqueued);
+        public const string Processing = nameof(Processing);
+        public const string Succeeded = nameof(Succeeded);
+        public const string Failed = nameof(Failed);
     }
 }
\ No newline at end of file

src/DotNetCore.CAP/Infrastructure/CapReceivedMessage.cs

+namespace DotNetCore.CAP.Infrastructure
+{
+    public class CapReceivedMessage : CapMessage
+    {
+        public CapReceivedMessage(MessageBase baseMessage) : base(baseMessage)
+        {
+        }
+    }
+}
\ No newline at end of file

src/DotNetCore.CAP/Infrastructure/CapSentMessage.cs

+namespace DotNetCore.CAP.Infrastructure
+{
+    public class CapSentMessage : CapMessage
+    {
+    }
+}
\ No newline at end of file

src/DotNetCore.CAP/Infrastructure/DeliverMessage.cs

-namespace DotNetCore.CAP.Infrastructure
-{
-    public class DeliverMessage
-    {
-        /// <summary>
-        /// Kafka 对应 Topic name
-        /// <para>
-        /// RabbitMQ 对应 RoutingKey
-        /// </para>
-        /// </summary>
-        public string MessageKey { get; set; }
-
-        public byte[] Body { get; set; }
-
-        public string Value { get; set; }
-    }
-}
\ No newline at end of file

src/DotNetCore.CAP/Infrastructure/MessageBase.cs

+namespace DotNetCore.CAP.Infrastructure
+{
+    public class MessageBase
+    {
+        public string KeyName { get; set; }
+
+        public string Content { get; set; }
+    }
+}
\ No newline at end of file