support simple consumer supports subscribing to multiple topics

Author: panzhi33

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/RocketMQProperties.java

@@ -16,7 +16,6 @@
  */
 package org.apache.rocketmq.client.autoconfigure;
 
-import org.apache.rocketmq.client.common.FilterExpression;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
 import java.util.Map;
@@ -330,4 +329,26 @@ public String toString() {
                     '}';
         }
     }
+
+    public static class FilterExpression {
+        private String tag;
+
+        private String filterExpressionType;
+
+        public String getTag() {
+            return tag;
+        }
+
+        public void setTag(String tag) {
+            this.tag = tag;
+        }
+
+        public String getFilterExpressionType() {
+            return filterExpressionType;
+        }
+
+        public void setFilterExpressionType(String filterExpressionType) {
+            this.filterExpressionType = filterExpressionType;
+        }
+    }
 }

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/common/FilterExpression.java

@@ -187,7 +187,7 @@ public static FilterExpression createFilterExpression(String tag, String type) {
         return filterExpression;
     }
 
-    public static Map<String, FilterExpression> createSubscriptionExpressions(Map<String, org.apache.rocketmq.client.common.FilterExpression> map) {
+    public static Map<String, FilterExpression> createSubscriptionExpressions(Map<String, RocketMQProperties.FilterExpression> map) {
         Map<String, FilterExpression> subscriptionExpressions = new HashMap<>();
         map.forEach((topic, expression) -> {
             FilterExpressionType filterExpressionType = "tag".equalsIgnoreCase(expression.getFilterExpressionType()) ? FilterExpressionType.TAG : FilterExpressionType.SQL92;