diff --git a/src/Cap.Consistency/ITopicRouteHandler.cs b/src/Cap.Consistency/ITopicRouteHandler.cs
deleted file mode 100644
index 9faa945..0000000
--- a/src/Cap.Consistency/ITopicRouteHandler.cs
+++ /dev/null
@@ -1,12 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace Cap.Consistency
-{
-    public interface ITopicRouteHandler
-    {
-        Task RouteAsync(TopicRouteContext context);
-    }
-}
diff --git a/src/Cap.Consistency/Internal/ConsumerExcutorSelector.cs b/src/Cap.Consistency/Internal/ConsumerExcutorSelector.cs
index 16a65e5..25ebe36 100644
--- a/src/Cap.Consistency/Internal/ConsumerExcutorSelector.cs
+++ b/src/Cap.Consistency/Internal/ConsumerExcutorSelector.cs
@@ -22,7 +22,7 @@ namespace Cap.Consistency.Internal
             return executeDescriptor.FirstOrDefault(x => x.Attribute.Name == key);
         }
 
-        public IReadOnlyList<ConsumerExecutorDescriptor> SelectCandidates(TopicRouteContext context) {
+        public IReadOnlyList<ConsumerExecutorDescriptor> SelectCandidates(TopicContext context) {
 
             var consumerServices = context.ServiceProvider.GetServices<IConsumerService>();
 
diff --git a/src/Cap.Consistency/Internal/MethodMatcherCache.cs b/src/Cap.Consistency/Internal/MethodMatcherCache.cs
index 06b85c8..3800f26 100644
--- a/src/Cap.Consistency/Internal/MethodMatcherCache.cs
+++ b/src/Cap.Consistency/Internal/MethodMatcherCache.cs
@@ -15,7 +15,7 @@ namespace Cap.Consistency.Internal
             _selector = selector;
         }
 
-        public ConcurrentDictionary<string, ConsumerExecutorDescriptor> GetCandidatesMethods(TopicRouteContext routeContext) {
+        public ConcurrentDictionary<string, ConsumerExecutorDescriptor> GetCandidatesMethods(TopicContext routeContext) {
 
             if (Entries.Count == 0) {
 
diff --git a/src/Cap.Consistency/TopicRouteContext.cs b/src/Cap.Consistency/TopicRouteContext.cs
deleted file mode 100644
index 08ee2d0..0000000
--- a/src/Cap.Consistency/TopicRouteContext.cs
+++ /dev/null
@@ -1,12 +0,0 @@
-using System;
-using System.Collections.Generic; 
-
-namespace Cap.Consistency
-{
-    public class TopicRouteContext
-    {
-        public IServiceProvider ServiceProvider { get; set; }
-
-        public IList<ITopicRouteHandler> Routes { get; set; }
-    }
-}