From e89225bfb758008cc30338e99fd81ec8754fa9a5 Mon Sep 17 00:00:00 2001 From: yangxiaodong Date: Fri, 16 Jun 2017 15:48:56 +0800 Subject: [PATCH] Reflector and rename. --- src/Cap.Consistency/ITopicRouteHandler.cs | 12 ------------ .../Internal/ConsumerExcutorSelector.cs | 2 +- src/Cap.Consistency/Internal/MethodMatcherCache.cs | 2 +- src/Cap.Consistency/TopicRouteContext.cs | 12 ------------ 4 files changed, 2 insertions(+), 26 deletions(-) delete mode 100644 src/Cap.Consistency/ITopicRouteHandler.cs delete mode 100644 src/Cap.Consistency/TopicRouteContext.cs 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 SelectCandidates(TopicRouteContext context) { + public IReadOnlyList SelectCandidates(TopicContext context) { var consumerServices = context.ServiceProvider.GetServices(); 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 GetCandidatesMethods(TopicRouteContext routeContext) { + public ConcurrentDictionary 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 Routes { get; set; } - } -}