supports one method subscribing multiple messages.

src/DotNetCore.CAP/Internal/IConsumerServiceSelector.Default.cs

@@ -58,13 +58,7 @@ namespace DotNetCore.CAP.Internal
                     continue;
                 }
 
-                foreach (var method in typeInfo.DeclaredMethods)
-                {
-                    var topicAttr = method.GetCustomAttribute<TopicAttribute>(true);
-                    if (topicAttr == null) continue;
-
-                    executorDescriptorList.Add(InitDescriptor(topicAttr, method, typeInfo));
-                }
+                executorDescriptorList.AddRange(GetTopicAttributesDescription(typeInfo));
             }
             return executorDescriptorList;
         }
@@ -82,16 +76,25 @@ namespace DotNetCore.CAP.Internal
                 //double check
                 if (!Helper.IsController(typeInfo)) continue;
 
+                executorDescriptorList.AddRange(GetTopicAttributesDescription(typeInfo));
+            }
+
+            return executorDescriptorList;
+        }
+
+        private static IEnumerable<ConsumerExecutorDescriptor> GetTopicAttributesDescription(TypeInfo typeInfo)
+        {
             foreach (var method in typeInfo.DeclaredMethods)
             {
-                    var topicAttr = method.GetCustomAttribute<TopicAttribute>(true);
-                    if (topicAttr == null) continue;
+                var topicAttrs = method.GetCustomAttributes<TopicAttribute>(true);
+
+                if (topicAttrs.Count() == 0) continue;
 
-                    executorDescriptorList.Add(InitDescriptor(topicAttr, method, typeInfo));
+                foreach (var attr in topicAttrs)
+                {
+                    yield return InitDescriptor(attr, method, typeInfo);
                 }
             }
-
-            return executorDescriptorList;
         }
 
         private static ConsumerExecutorDescriptor InitDescriptor(