From 872eb40a5a5aabf5f36300547b9843344a066371 Mon Sep 17 00:00:00 2001
From: Savorboard <yangxiaodong1214@126.com>
Date: Fri, 13 Dec 2019 15:57:33 +0800
Subject: [PATCH] Provide rewrite subscription attribute extension

---
 .../IConsumerServiceSelector.Default.cs       | 21 ++++++++++++-------
 1 file changed, 13 insertions(+), 8 deletions(-)

diff --git a/src/DotNetCore.CAP/Internal/IConsumerServiceSelector.Default.cs b/src/DotNetCore.CAP/Internal/IConsumerServiceSelector.Default.cs
index 3dda14c..7866c5b 100644
--- a/src/DotNetCore.CAP/Internal/IConsumerServiceSelector.Default.cs
+++ b/src/DotNetCore.CAP/Internal/IConsumerServiceSelector.Default.cs
@@ -123,14 +123,7 @@ namespace DotNetCore.CAP.Internal
 
                 foreach (var attr in topicAttributes)
                 {
-                    if (attr.Group == null)
-                    {
-                        attr.Group = _capOptions.DefaultGroup + "." + _capOptions.Version;
-                    }
-                    else
-                    {
-                        attr.Group = attr.Group + "." + _capOptions.Version;
-                    }
+                    SetSubscribeAttribute(attr);
 
                     var parameters = method.GetParameters()
                         .Select(parameter => new ParameterDescriptor
@@ -145,6 +138,18 @@ namespace DotNetCore.CAP.Internal
             }
         }
 
+        protected virtual void SetSubscribeAttribute(TopicAttribute attribute)
+        {
+            if (attribute.Group == null)
+            {
+                attribute.Group = _capOptions.DefaultGroup + "." + _capOptions.Version;
+            }
+            else
+            {
+                attribute.Group = attribute.Group + "." + _capOptions.Version;
+            }
+        }
+
         private static ConsumerExecutorDescriptor InitDescriptor(
             TopicAttribute attr,
             MethodInfo methodInfo,