diff --git a/src/ServiceAnt/Handler/TransportTray.cs b/src/ServiceAnt/Handler/TransportTray.cs
index dd9d9be..b031c80 100644
--- a/src/ServiceAnt/Handler/TransportTray.cs
+++ b/src/ServiceAnt/Handler/TransportTray.cs
@@ -6,26 +6,31 @@
 
 namespace ServiceAnt.Handler
 {
-    public abstract class TransportTray
+    /// <summary>
+    /// It is used to trigger event or request
+    /// </summary>
+    public interface ITrigger
     {
-        public TransportTray()
-        {
-            Id = Guid.NewGuid();
-            CreationDate = DateTime.UtcNow;
-        }
-
-        public Guid Id { get; }
-        public DateTime CreationDate { get; }
     }
-
-    public abstract class TransportTray<TEntity> : TransportTray
+    
+    /// <summary>
+    /// It is used to trigger event or request
+    /// </summary>
+    /// <typeparam name="TDto"></typeparam>
+    public abstract class Trigger<TDto> : ITrigger
     {
-        public TEntity TransportEntity { get; set; }
+        /// <summary>
+        /// Dto
+        /// </summary>
+        public TDto Dto { get; set; }
 
-        public TransportTray(TEntity entity) : base()
+        /// <summary>
+        /// ctor
+        /// </summary>
+        /// <param name="inputDto"></param>
+        public Trigger(TDto inputDto)
         {
-            TransportEntity = entity;
+            Dto = inputDto;
         }
     }
-
 }
diff --git a/src/ServiceAnt/IServiceBus.cs b/src/ServiceAnt/IServiceBus.cs
index 4a58729..deaea87 100644
--- a/src/ServiceAnt/IServiceBus.cs
+++ b/src/ServiceAnt/IServiceBus.cs
@@ -48,7 +48,7 @@ public interface IServiceBus : IAddSubscription, IAddRequestHandler
         /// </summary>
         /// <param name="event"></param>
         /// <returns></returns>
-        Task Publish(TransportTray @event);
+        Task Publish(ITrigger @event);
 
         /// <summary>
         /// Send a request sync
@@ -56,7 +56,7 @@ public interface IServiceBus : IAddSubscription, IAddRequestHandler
         /// <typeparam name="T"></typeparam>
         /// <param name="event"></param>
         /// <returns></returns>
-        T Send<T>(TransportTray @event);
+        T Send<T>(ITrigger @event);
 
         /// <summary>
         /// Send a request async
@@ -64,6 +64,6 @@ public interface IServiceBus : IAddSubscription, IAddRequestHandler
         /// <typeparam name="T"></typeparam>
         /// <param name="event"></param>
         /// <returns></returns>
-        Task<T> SendAsync<T>(TransportTray @event);
+        Task<T> SendAsync<T>(ITrigger @event);
     }
 }
diff --git a/src/ServiceAnt/InProcessServiceBus.cs b/src/ServiceAnt/InProcessServiceBus.cs
index eb15d39..77bce4c 100644
--- a/src/ServiceAnt/InProcessServiceBus.cs
+++ b/src/ServiceAnt/InProcessServiceBus.cs
@@ -5,6 +5,7 @@
 using ServiceAnt.Handler.Subscription.Handler;
 using ServiceAnt.Request.Handler;
 using ServiceAnt.Subscription;
+using ServiceAnt.Subscription.Handler;
 using System;
 using System.Linq;
 using System.Threading.Tasks;
@@ -78,7 +79,7 @@ public void AddSubscription(Type eventType, IHandlerFactory factory)
         /// </summary>
         /// <typeparam name="TEvent">The event must inherit TransportTray</typeparam>
         /// <param name="action">Handler delegate</param>
-        public void AddSubscription<TEvent>(Func<TEvent, Task> action) where TEvent : TransportTray
+        public void AddSubscription<TEvent>(Func<TEvent, Task> action) where TEvent : ITrigger
         {
             _subcriptionManager.AddSubscription<TEvent>(action);
         }
@@ -88,7 +89,7 @@ public void AddSubscription(Type eventType, IHandlerFactory factory)
         /// </summary>
         /// <typeparam name="TEvent">The event must inherit TransportTray </typeparam>
         /// <param name="factory"></param>s
-        public void AddSubscription<TEvent>(IHandlerFactory factory) where TEvent : TransportTray
+        public void AddSubscription<TEvent>(IHandlerFactory factory) where TEvent : ITrigger
         {
             _subcriptionManager.AddSubscription<TEvent>(factory);
         }
@@ -109,7 +110,7 @@ public void RemoveDynamicSubscription(string eventName, Func<dynamic, Task> acti
         /// </summary>
         /// <typeparam name="TEvent">The event must inherit TransportTray</typeparam>
         /// <param name="action">Handler delegate</param>
-        public void RemoveSubscription<TEvent>(Func<TEvent, Task> action) where TEvent : TransportTray
+        public void RemoveSubscription<TEvent>(Func<TEvent, Task> action) where TEvent : ITrigger
         {
             _subcriptionManager.RemoveSubscription<TEvent>(action);
         }
@@ -119,7 +120,7 @@ public void RemoveDynamicSubscription(string eventName, Func<dynamic, Task> acti
         /// </summary>
         /// <param name="event"></param>
         /// <returns></returns>
-        public Task Publish(TransportTray @event)
+        public Task Publish(ITrigger @event)
         {
             var asyncTask = ProcessEvent(_subcriptionManager.GetEventName(@event.GetType()), JsonConvert.SerializeObject(@event));
             return asyncTask;
@@ -129,7 +130,7 @@ public Task Publish(TransportTray @event)
         /// Publish a event sync
         /// </summary>
         /// <param name="event"></param>
-        public void PublishSync(TransportTray @event)
+        public void PublishSync(ITrigger @event)
         {
             var asyncTask = ProcessEvent(_subcriptionManager.GetEventName(@event.GetType()), JsonConvert.SerializeObject(@event));
             asyncTask.Wait();
@@ -188,7 +189,7 @@ public void AddRequestHandler(Type eventType, IHandlerFactory factory)
         /// <typeparam name="TEvent"></typeparam>
         /// <param name="factory"></param>
         public void AddRequestHandler<TEvent>(IHandlerFactory factory)
-            where TEvent : TransportTray
+            where TEvent : ITrigger
         {
             _requestHandlerManager.AddRequestHandler<TEvent>(factory);
         }
@@ -199,7 +200,7 @@ public void AddRequestHandler<TEvent>(IHandlerFactory factory)
         /// <typeparam name="TEvent"></typeparam>
         /// <param name="action"></param>
         public void AddRequestHandler<TEvent>(Func<TEvent, IRequestHandlerContext, Task> action)
-            where TEvent : TransportTray
+            where TEvent : ITrigger
         {
             _requestHandlerManager.AddRequestHandler<TEvent>(action);
         }
@@ -220,7 +221,7 @@ public void AddDynamicRequestHandler(string eventName, Func<dynamic, IRequestHan
         /// <typeparam name="TEvent"></typeparam>
         /// <param name="action"></param>
         public void RemoveRequestHandler<TEvent>(Func<TEvent, IRequestHandlerContext, Task> action)
-            where TEvent : TransportTray
+            where TEvent : ITrigger
         {
             _requestHandlerManager.RemoveRequestHandler(action);
         }
@@ -241,7 +242,7 @@ public void RemoveDynamicRequestHandler(string eventName, Func<dynamic, IRequest
         /// <typeparam name="T"></typeparam>
         /// <param name="event"></param>
         /// <returns></returns>
-        public T Send<T>(TransportTray @event)
+        public T Send<T>(ITrigger @event)
         {
             var asyncTask = ProcessRequest<T>(_requestHandlerManager.GetRequestName(@event.GetType()), JsonConvert.SerializeObject(@event));
             asyncTask.ConfigureAwait(false);
@@ -254,7 +255,7 @@ public T Send<T>(TransportTray @event)
         /// <typeparam name="T"></typeparam>
         /// <param name="event"></param>
         /// <returns></returns>
-        public async Task<T> SendAsync<T>(TransportTray @event)
+        public async Task<T> SendAsync<T>(ITrigger @event)
         {
             return await ProcessRequest<T>(_requestHandlerManager.GetRequestName(@event.GetType()), JsonConvert.SerializeObject(@event));
         }
@@ -298,7 +299,7 @@ private async Task<T> ProcessRequest<T>(string eventName, string message)
                 }
             }
 
-            return (T)requestContext.Response;
+            return JsonConvert.DeserializeObject<T>(JsonConvert.SerializeObject(requestContext.Response));
         }
 
 #endregion
diff --git a/src/ServiceAnt/Request/Handler/ActionRequestHandler.cs b/src/ServiceAnt/Request/Handler/ActionRequestHandler.cs
index 3c13036..eb4315b 100644
--- a/src/ServiceAnt/Request/Handler/ActionRequestHandler.cs
+++ b/src/ServiceAnt/Request/Handler/ActionRequestHandler.cs
@@ -11,7 +11,7 @@ namespace ServiceAnt.Request.Handler
     /// The container of request handler registing with delegate
     /// </summary>
     /// <typeparam name="TRequest"></typeparam>
-    public class ActionRequestHandler<TRequest> : IRequestHandler<TRequest> where TRequest : TransportTray
+    public class ActionRequestHandler<TRequest> : IRequestHandler<TRequest> where TRequest : ITrigger
     {
         private Func<TRequest, IRequestHandlerContext, Task> _action;
 
diff --git a/src/ServiceAnt/Request/Handler/IRequestHandler.cs b/src/ServiceAnt/Request/Handler/IRequestHandler.cs
index 2abaa01..5891746 100644
--- a/src/ServiceAnt/Request/Handler/IRequestHandler.cs
+++ b/src/ServiceAnt/Request/Handler/IRequestHandler.cs
@@ -18,7 +18,7 @@ public interface IRequestHandler : IHandler
     /// The interface of handling request
     /// </summary>
     /// <typeparam name="TRequest">request parameter</typeparam>
-    public interface IRequestHandler<TRequest> : IRequestHandler where TRequest : TransportTray
+    public interface IRequestHandler<TRequest> : IRequestHandler where TRequest : ITrigger
     {
         /// <summary>
         /// Handle request async
diff --git a/src/ServiceAnt/Request/IAddRequestHandler.cs b/src/ServiceAnt/Request/IAddRequestHandler.cs
index f73186a..323c6d9 100644
--- a/src/ServiceAnt/Request/IAddRequestHandler.cs
+++ b/src/ServiceAnt/Request/IAddRequestHandler.cs
@@ -25,7 +25,7 @@ public interface IAddRequestHandler
         /// <typeparam name="TEvent"></typeparam>
         /// <param name="factory"></param>
         void AddRequestHandler<TEvent>(IHandlerFactory factory)
-            where TEvent : TransportTray;
+            where TEvent : ITrigger;
 
         /// <summary>
         /// Register handler with delegate
@@ -33,7 +33,7 @@ void AddRequestHandler<TEvent>(IHandlerFactory factory)
         /// <typeparam name="TEvent"></typeparam>
         /// <param name="action"></param>
         void AddRequestHandler<TEvent>(Func<TEvent, IRequestHandlerContext, Task> action)
-            where TEvent : TransportTray;
+            where TEvent : ITrigger;
 
         /// <summary>
         /// Register dynamic handler with delegate
@@ -48,7 +48,7 @@ void AddRequestHandler<TEvent>(Func<TEvent, IRequestHandlerContext, Task> action
         /// <typeparam name="TEvent"></typeparam>
         /// <param name="action"></param>
         void RemoveRequestHandler<TEvent>(Func<TEvent, IRequestHandlerContext, Task> action)
-            where TEvent : TransportTray;
+            where TEvent : ITrigger;
 
         /// <summary>
         /// Remove dynamic handler by eventName
diff --git a/src/ServiceAnt/Request/IRequestHandlerManager.cs b/src/ServiceAnt/Request/IRequestHandlerManager.cs
index 7d9d5b7..a3d076c 100644
--- a/src/ServiceAnt/Request/IRequestHandlerManager.cs
+++ b/src/ServiceAnt/Request/IRequestHandlerManager.cs
@@ -23,7 +23,7 @@ public interface IRequestHandlerManager : IAddRequestHandler
         /// </summary>
         /// <param name="request">request object</param>
         /// <returns></returns>
-        List<IHandlerFactory> GetHandlerFactoriesForRequest(TransportTray @request);
+        List<IHandlerFactory> GetHandlerFactoriesForRequest(ITrigger @request);
 
         /// <summary>
         /// Get the request name by TransportTray type
diff --git a/src/ServiceAnt/Request/InMemoryRequestHandlerManager.cs b/src/ServiceAnt/Request/InMemoryRequestHandlerManager.cs
index bcb874f..6c82656 100644
--- a/src/ServiceAnt/Request/InMemoryRequestHandlerManager.cs
+++ b/src/ServiceAnt/Request/InMemoryRequestHandlerManager.cs
@@ -50,7 +50,7 @@ public void AddRequestHandler(Type eventType, IHandlerFactory factory)
         /// </summary>
         /// <typeparam name="TEvent"></typeparam>
         /// <param name="action"></param>
-        public void AddRequestHandler<TEvent>(Func<TEvent, IRequestHandlerContext, Task> action) where TEvent : TransportTray
+        public void AddRequestHandler<TEvent>(Func<TEvent, IRequestHandlerContext, Task> action) where TEvent : ITrigger
         {
             var eventHandler = new ActionRequestHandler<TEvent>(action);
 
@@ -62,7 +62,7 @@ public void AddRequestHandler(Type eventType, IHandlerFactory factory)
         /// </summary>
         /// <typeparam name="TEvent"></typeparam>
         /// <param name="factory"></param>
-        public void AddRequestHandler<TEvent>(IHandlerFactory factory) where TEvent : TransportTray
+        public void AddRequestHandler<TEvent>(IHandlerFactory factory) where TEvent : ITrigger
         {
             DoAddRequestHandler(factory, typeof(TEvent));
         }
@@ -72,7 +72,7 @@ public void AddRequestHandler(Type eventType, IHandlerFactory factory)
         /// </summary>
         /// <param name="request">request object</param>
         /// <returns></returns>
-        public List<IHandlerFactory> GetHandlerFactoriesForRequest(TransportTray request)
+        public List<IHandlerFactory> GetHandlerFactoriesForRequest(ITrigger request)
         {
             return GetOrCreateHandlerFactories(GetRequestName(request.GetType()));
         }
@@ -138,7 +138,7 @@ public void RemoveDynamicRequestHandler(string eventName, Func<dynamic, IRequest
         /// </summary>
         /// <typeparam name="TEvent"></typeparam>
         /// <param name="action"></param>
-        public void RemoveRequestHandler<TEvent>(Func<TEvent, IRequestHandlerContext, Task> action) where TEvent : TransportTray
+        public void RemoveRequestHandler<TEvent>(Func<TEvent, IRequestHandlerContext, Task> action) where TEvent : ITrigger
         {
             GetOrCreateHandlerFactories(typeof(TEvent).Name)
                 .Locking(factories =>
diff --git a/src/ServiceAnt/Subscription/Handler/ActionEventHandler.cs b/src/ServiceAnt/Subscription/Handler/ActionEventHandler.cs
index 9b7b446..69316af 100644
--- a/src/ServiceAnt/Subscription/Handler/ActionEventHandler.cs
+++ b/src/ServiceAnt/Subscription/Handler/ActionEventHandler.cs
@@ -1,42 +1,78 @@
-using System;
+using ServiceAnt.Subscription.Handler;
+using System;
 using System.Threading.Tasks;
 
 namespace ServiceAnt.Handler.Subscription.Handler
 {
-    public class ActionEventHandler<TEvent> : IEventHandler<TEvent> where TEvent : TransportTray
+    /// <summary>
+    /// Handle event by action
+    /// </summary>
+    /// <typeparam name="TEvent"></typeparam>
+    public class ActionEventHandler<TEvent> : IEventHandler<TEvent> where TEvent : ITrigger
     {
         private Func<TEvent, Task> _action;
 
+        /// <summary>
+        /// ctor
+        /// </summary>
+        /// <param name="action"></param>
         public ActionEventHandler(Func<TEvent, Task>  action)
         {
             _action = action;
         }
 
+        /// <summary>
+        /// handle event
+        /// </summary>
+        /// <param name="param"></param>
+        /// <returns></returns>
         public async Task HandleAsync(TEvent param)
         {
             await _action(param);
         }
 
+        /// <summary>
+        /// check if input action is same with self
+        /// </summary>
+        /// <param name="compareAction"></param>
+        /// <returns></returns>
         public bool IsSame(Func<TEvent, Task> compareAction)
         {
             return compareAction == _action;
         }
     }
 
+    /// <summary>
+    /// Handle event by dynamic action
+    /// </summary>
     public class ActionEventHandler : IDynamicEventHandler
     {
         private Func<dynamic, Task> _action;
 
+        /// <summary>
+        /// ctor
+        /// </summary>
+        /// <param name="action"></param>
         public ActionEventHandler(Func<dynamic, Task> action)
         {
             _action = action;
         }
 
+        /// <summary>
+        /// handle event
+        /// </summary>
+        /// <param name="param"></param>
+        /// <returns></returns>
         public async Task HandleAsync(dynamic param)
         {
             await _action(param);
         }
 
+        /// <summary>
+        /// check if input action is same with self
+        /// </summary>
+        /// <param name="compareAction"></param>
+        /// <returns></returns>
         public bool IsSame(Func<dynamic, Task> compareAction)
         {
             return compareAction == _action;
diff --git a/src/ServiceAnt/Subscription/Handler/IEventHandler.cs b/src/ServiceAnt/Subscription/Handler/IEventHandler.cs
index 3361e2f..83793ba 100644
--- a/src/ServiceAnt/Subscription/Handler/IEventHandler.cs
+++ b/src/ServiceAnt/Subscription/Handler/IEventHandler.cs
@@ -1,13 +1,23 @@
-using System;
+using ServiceAnt.Handler;
+using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 
-namespace ServiceAnt.Handler.Subscription.Handler
+namespace ServiceAnt.Subscription.Handler
 {
-    public interface IEventHandler<TEvent> : IHandler where TEvent : TransportTray
+    /// <summary>
+    /// It is used to handle event
+    /// </summary>
+    /// <typeparam name="TEvent"></typeparam>
+    public interface IEventHandler<TEvent> : IHandler where TEvent : ITrigger
     {
+        /// <summary>
+        /// handle event
+        /// </summary>
+        /// <param name="param"></param>
+        /// <returns></returns>
         Task HandleAsync(TEvent param);
     }
 }
diff --git a/src/ServiceAnt/Subscription/IAddSubscription.cs b/src/ServiceAnt/Subscription/IAddSubscription.cs
index 75500d0..d4a4977 100644
--- a/src/ServiceAnt/Subscription/IAddSubscription.cs
+++ b/src/ServiceAnt/Subscription/IAddSubscription.cs
@@ -22,7 +22,7 @@ public interface IAddSubscription
         /// <typeparam name="TEvent">The event must inherit TransportTray </typeparam>
         /// <param name="factory"></param>
         void AddSubscription<TEvent>(IHandlerFactory factory)
-            where TEvent : TransportTray;
+            where TEvent : ITrigger;
 
         /// <summary>
         /// Add Subscription for event by delegate
@@ -30,7 +30,7 @@ void AddSubscription<TEvent>(IHandlerFactory factory)
         /// <typeparam name="TEvent">The event must inherit TransportTray</typeparam>
         /// <param name="action">Handler delegate</param>
         void AddSubscription<TEvent>(Func<TEvent, Task> action)
-            where TEvent : TransportTray;
+            where TEvent : ITrigger;
 
         /// <summary>
         /// Add Subscription for event by delegate with dynamic parameter
@@ -45,7 +45,7 @@ void AddSubscription<TEvent>(Func<TEvent, Task> action)
         /// <typeparam name="TEvent">The event must inherit TransportTray</typeparam>
         /// <param name="action">Handler delegate</param>
         void RemoveSubscription<TEvent>(Func<TEvent, Task> action)
-            where TEvent : TransportTray;
+            where TEvent : ITrigger;
 
         /// <summary>
         /// Remove subscription from servicebus
diff --git a/src/ServiceAnt/Subscription/ISubscriptionManager.cs b/src/ServiceAnt/Subscription/ISubscriptionManager.cs
index 0c3b6d1..f521954 100644
--- a/src/ServiceAnt/Subscription/ISubscriptionManager.cs
+++ b/src/ServiceAnt/Subscription/ISubscriptionManager.cs
@@ -24,7 +24,7 @@ public interface ISubscriptionManager : IAddSubscription
         /// </summary>
         /// <param name="event"></param>
         /// <returns></returns>
-        List<IHandlerFactory> GetHandlerFactoriesForEvent(TransportTray @event);
+        List<IHandlerFactory> GetHandlerFactoriesForEvent(ITrigger @event);
 
         /// <summary>
         /// Get event name by event type
diff --git a/src/ServiceAnt/Subscription/InMemorySubscriptionsManager.cs b/src/ServiceAnt/Subscription/InMemorySubscriptionsManager.cs
index c3add3d..2113310 100644
--- a/src/ServiceAnt/Subscription/InMemorySubscriptionsManager.cs
+++ b/src/ServiceAnt/Subscription/InMemorySubscriptionsManager.cs
@@ -51,7 +51,7 @@ public void AddSubscription(Type eventType, IHandlerFactory factory)
         /// </summary>
         /// <typeparam name="TEvent">The event must inherit TransportTray</typeparam>
         /// <param name="action">Handler delegate</param>
-        public void AddSubscription<TEvent>(Func<TEvent, Task> action) where TEvent : TransportTray
+        public void AddSubscription<TEvent>(Func<TEvent, Task> action) where TEvent : ITrigger
         {
             var eventHandler = new ActionEventHandler<TEvent>(action);
 
@@ -63,7 +63,7 @@ public void AddSubscription(Type eventType, IHandlerFactory factory)
         /// </summary>
         /// <typeparam name="TEvent">The event must inherit TransportTray </typeparam>
         /// <param name="factory"></param>
-        public void AddSubscription<TEvent>(IHandlerFactory factory) where TEvent : TransportTray
+        public void AddSubscription<TEvent>(IHandlerFactory factory) where TEvent : ITrigger
         {
             DoAddSubscription(factory, typeof(TEvent));
         }
@@ -83,7 +83,7 @@ public List<IHandlerFactory> GetHandlerFactoriesForEvent(string eventName)
         /// </summary>
         /// <param name="event"></param>
         /// <returns></returns>
-        public List<IHandlerFactory> GetHandlerFactoriesForEvent(TransportTray @event)
+        public List<IHandlerFactory> GetHandlerFactoriesForEvent(ITrigger @event)
         {
             return GetOrCreateHandlerFactories(GetEventName(@event.GetType()));
         }
@@ -122,7 +122,7 @@ public void RemoveDynamicSubscription(string eventName, Func<dynamic, Task> acti
         /// </summary>
         /// <typeparam name="TEvent">The event must inherit TransportTray</typeparam>
         /// <param name="action">Handler delegate</param>
-        public void RemoveSubscription<TEvent>(Func<TEvent, Task> action) where TEvent : TransportTray
+        public void RemoveSubscription<TEvent>(Func<TEvent, Task> action) where TEvent : ITrigger
         {
             GetOrCreateHandlerFactories(typeof(TEvent).Name)
                 .Locking(factories =>
diff --git a/test/ServiceAnt.IocInstaller.Autofac.Test/ServiceAntModule_Test.cs b/test/ServiceAnt.IocInstaller.Autofac.Test/ServiceAntModule_Test.cs
index 42bd887..0f4376b 100644
--- a/test/ServiceAnt.IocInstaller.Autofac.Test/ServiceAntModule_Test.cs
+++ b/test/ServiceAnt.IocInstaller.Autofac.Test/ServiceAntModule_Test.cs
@@ -5,6 +5,7 @@
 using ServiceAnt.Handler.Subscription.Handler;
 using ServiceAnt.Request.Handler;
 using ServiceAnt.Handler;
+using ServiceAnt.Subscription.Handler;
 
 namespace ServiceAnt.IocInstaller.Autofac.Test
 {
@@ -26,7 +27,7 @@ public async Task CanHandleEventByIocHandler()
             var autofacContainer = newContainer.Build();
             ServiceAntModule.RegisterHandlers(autofacContainer);
 
-            await autofacContainer.Resolve<IServiceBus>().Publish(new TestTray() { Result = testValue });
+            await autofacContainer.Resolve<IServiceBus>().Publish(new TestTrigger() { Result = testValue });
 
             Assert.AreEqual(testValue, RESULT_CONTAINER);
         }
@@ -40,19 +41,19 @@ public async Task CanHandleRequestByIocHandler()
             var autofacContainer = newContainer.Build();
             ServiceAntModule.RegisterHandlers(autofacContainer);
 
-            var result = await autofacContainer.Resolve<IServiceBus>().SendAsync<string>(new TestTray() { Result = testValue });
+            var result = await autofacContainer.Resolve<IServiceBus>().SendAsync<string>(new TestTrigger() { Result = testValue });
 
             Assert.AreEqual(testValue, result);
         }
 
-        public class TestTray : TransportTray
+        public class TestTrigger : ITrigger
         {
             public string Result { get; set; }
         }
 
-        public class IocEventHandler : IEventHandler<TestTray>
+        public class IocEventHandler : IEventHandler<TestTrigger>
         {
-            public Task HandleAsync(TestTray param)
+            public Task HandleAsync(TestTrigger param)
             {
                 RESULT_CONTAINER = param.Result;
 
@@ -60,9 +61,9 @@ public Task HandleAsync(TestTray param)
             }
         }
 
-        public class IocRequestHandler : IRequestHandler<TestTray>
+        public class IocRequestHandler : IRequestHandler<TestTrigger>
         {
-            public Task HandleAsync(TestTray param, IRequestHandlerContext handlerContext)
+            public Task HandleAsync(TestTrigger param, IRequestHandlerContext handlerContext)
             {
                 handlerContext.Response = param.Result;
                 return Task.Delay(1);
diff --git a/test/ServiceAnt.IocInstaller.Castle.test/ServiceAntInstaller_Test.cs b/test/ServiceAnt.IocInstaller.Castle.test/ServiceAntInstaller_Test.cs
index 4215ca8..c9157e9 100644
--- a/test/ServiceAnt.IocInstaller.Castle.test/ServiceAntInstaller_Test.cs
+++ b/test/ServiceAnt.IocInstaller.Castle.test/ServiceAntInstaller_Test.cs
@@ -8,6 +8,7 @@
 using System.Threading.Tasks;
 using Castle.MicroKernel.Registration;
 using ServiceAnt.Request.Handler;
+using ServiceAnt.Subscription.Handler;
 
 namespace ServiceAnt.IocInstaller.Castle.Test
 {
@@ -30,7 +31,7 @@ public async Task CanHandleEventByIocHandler()
             var newContainer = new WindsorContainer();
             newContainer.Install(new ServiceAntInstaller(System.Reflection.Assembly.GetExecutingAssembly()));
 
-            await newContainer.Resolve<IServiceBus>().Publish(new TestTray() { Result = testValue });
+            await newContainer.Resolve<IServiceBus>().Publish(new TestTrigger() { Result = testValue });
 
             Assert.AreEqual(testValue, RESULT_CONTAINER);
         }
@@ -42,19 +43,19 @@ public async Task CanHandleRequestByIocHandler()
             var newContainer = new WindsorContainer();
             newContainer.Install(new ServiceAntInstaller(System.Reflection.Assembly.GetExecutingAssembly()));
 
-            var result = await newContainer.Resolve<IServiceBus>().SendAsync<string>(new TestTray() { Result = testValue });
+            var result = await newContainer.Resolve<IServiceBus>().SendAsync<string>(new TestTrigger() { Result = testValue });
 
             Assert.AreEqual(testValue, result);
         }
 
-        public class TestTray : TransportTray
+        public class TestTrigger : ITrigger
         {
             public string Result { get; set; }
         }
 
-        public class IocEventHandler : IEventHandler<TestTray>
+        public class IocEventHandler : IEventHandler<TestTrigger>
         {
-            public Task HandleAsync(TestTray param)
+            public Task HandleAsync(TestTrigger param)
             {
                 RESULT_CONTAINER = param.Result;
 
@@ -62,9 +63,9 @@ public Task HandleAsync(TestTray param)
             }
         }
 
-        public class IocRequestHandler : IRequestHandler<TestTray>
+        public class IocRequestHandler : IRequestHandler<TestTrigger>
         {
-            public Task HandleAsync(TestTray param, IRequestHandlerContext handlerContext)
+            public Task HandleAsync(TestTrigger param, IRequestHandlerContext handlerContext)
             {
                 handlerContext.Response = param.Result;
                 return Task.Delay(1);
diff --git a/test/ServiceAnt.test/InProcessEventBus_Test.cs b/test/ServiceAnt.test/InProcessEventBus_Test.cs
index df99a0d..4ea9ff1 100644
--- a/test/ServiceAnt.test/InProcessEventBus_Test.cs
+++ b/test/ServiceAnt.test/InProcessEventBus_Test.cs
@@ -14,21 +14,22 @@ namespace YiBan.Common.BaseAbpModule.Tests.Events
     [TestClass]
     public class InProcessServiceBus_Test
     {
-        private class TestEventData : TransportTray
+        private class TestEventData : ITrigger
         {
             public string Msg { get; set; }
         }
 
-        private class TestEventDataWithParam : TransportTray
+        private class TestEventDataWithParam : ITrigger
         {
             public TestEventDataWithParam(string Msg) { }
 
             public string Msg { get; set; }
         }
 
-        private class TestEventDataT<T> : TransportTray<T>
+        private class TestEventDataT<T> : Trigger<T>
         {
-            public TestEventDataT(T test) : base(test) { }
+            public TestEventDataT(T test) : base(test)
+            { }
 
             public string Msg { get; set; }
         }
@@ -431,14 +432,14 @@ public void GenericRequest_ShouldResponse()
             {
                 return Task.Run(() =>
                 {
-                    context.Response = eventData.TransportEntity.Msg + eventData.Msg;
+                    context.Response = eventData.Dto.Msg + eventData.Msg;
                 });
             });
 
             var testEventData = new TestEventDataT<TestEventData>(new TestEventData() { Msg = "non" }) { Msg = "success" };
             var result = eventBus.Send<string>(testEventData);
 
-            Assert.AreEqual(testEventData.TransportEntity.Msg + testEventData.Msg, result);
+            Assert.AreEqual(testEventData.Dto.Msg + testEventData.Msg, result);
         }
 
         [TestMethod]