[ISSUE #674] 修复validate

Author: panzhi33

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ExtConsumerResetConfiguration.java

@@ -87,8 +87,6 @@ private void registerTemplate(String beanName, Object bean) {
         }
 
         ExtRocketMQConsumerConfiguration annotation = clazz.getAnnotation(ExtRocketMQConsumerConfiguration.class);
-        GenericApplicationContext genericApplicationContext = (GenericApplicationContext) applicationContext;
-        validate(annotation, genericApplicationContext);
 
         DefaultLitePullConsumer consumer = null;
         try {
@@ -142,14 +140,4 @@ private String resolvePlaceholders(String text, String defaultValue) {
         String value = environment.resolvePlaceholders(text);
         return StringUtils.hasLength(value) ? value : defaultValue;
     }
-
-    private void validate(ExtRocketMQConsumerConfiguration annotation,
-            GenericApplicationContext genericApplicationContext) {
-        if (genericApplicationContext.isBeanNameInUse(annotation.value())) {
-            throw new BeanDefinitionValidationException(
-                    String.format("Bean {} has been used in Spring Application Context, " +
-                                    "please check the @ExtRocketMQConsumerConfiguration",
-                            annotation.value()));
-        }
-    }
 }

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ExtProducerResetConfiguration.java

@@ -81,8 +81,6 @@ private void registerTemplate(String beanName, Object bean) {
         }
 
         ExtRocketMQTemplateConfiguration annotation = clazz.getAnnotation(ExtRocketMQTemplateConfiguration.class);
-        GenericApplicationContext genericApplicationContext = (GenericApplicationContext) applicationContext;
-        validate(annotation, genericApplicationContext);
 
         DefaultMQProducer mqProducer = createProducer(annotation);
         try {

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

@@ -87,8 +87,6 @@ private void registerTemplate(String beanName, Object bean) {
             throw new IllegalStateException(clazz + " is not instance of " + RocketMQClientTemplate.class.getName());
         }
         org.apache.rocketmq.client.annotation.ExtConsumerResetConfiguration annotation = clazz.getAnnotation(org.apache.rocketmq.client.annotation.ExtConsumerResetConfiguration.class);
-        GenericApplicationContext genericApplicationContext = (GenericApplicationContext) applicationContext;
-        validate(annotation, genericApplicationContext);
 
         SimpleConsumerBuilder consumerBuilder = null;
         SimpleConsumer simpleConsumer = null;
@@ -145,16 +143,6 @@ private String resolvePlaceholders(String text, String defaultValue) {
         return StringUtils.hasLength(value) ? value : defaultValue;
     }
 
-    private void validate(org.apache.rocketmq.client.annotation.ExtConsumerResetConfiguration annotation,
-        GenericApplicationContext genericApplicationContext) {
-        if (genericApplicationContext.isBeanNameInUse(annotation.value())) {
-            throw new BeanDefinitionValidationException(
-                String.format("Bean %s has been used in Spring Application Context, " +
-                        "please check the @ExtRocketMQConsumerConfiguration",
-                    annotation.value()));
-        }
-    }
-
     static class SimpleConsumerInfo {
         String consumerGroup;
 

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

@@ -87,8 +87,6 @@ private void registerTemplate(String beanName, Object bean) {
         }
 
         ExtProducerResetConfiguration annotation = clazz.getAnnotation(ExtProducerResetConfiguration.class);
-        GenericApplicationContext genericApplicationContext = (GenericApplicationContext) applicationContext;
-        validate(annotation, genericApplicationContext);
 
         ProducerBuilder producerBuilder = createProducer(annotation);
         RocketMQClientTemplate rocketMQTemplate = (RocketMQClientTemplate) bean;
@@ -124,13 +122,4 @@ private ProducerBuilder createProducer(ExtProducerResetConfiguration annotation)
         return producerBuilder;
     }
 
-    private void validate(ExtProducerResetConfiguration annotation,
-                          GenericApplicationContext genericApplicationContext) {
-        if (genericApplicationContext.isBeanNameInUse(annotation.value())) {
-            throw new BeanDefinitionValidationException(String.format("Bean %s has been used in Spring Application Context, " +
-                            "please check the @ExtTemplateConfiguration",
-                    annotation.value()));
-        }
-    }
-
 }