diff --git a/src/DotNetCore.CAP/Internal/IConsumerRegister.Default.cs b/src/DotNetCore.CAP/Internal/IConsumerRegister.Default.cs
index 4639072..56b4c50 100644
--- a/src/DotNetCore.CAP/Internal/IConsumerRegister.Default.cs
+++ b/src/DotNetCore.CAP/Internal/IConsumerRegister.Default.cs
@@ -299,7 +299,7 @@ namespace DotNetCore.CAP.Internal
             {
                 var now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
 
-                var eventData = new CapEventDataPubSend()
+                var eventData = new CapEventDataSubStore()
                 {
                     OperationTimestamp = now,
                     Operation = message.GetName(),