diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/annotation/PulsarListenerAnnotationBeanPostProcessor.java b/spring-pulsar/src/main/java/org/springframework/pulsar/annotation/PulsarListenerAnnotationBeanPostProcessor.java index c57f9a0e..21d1efa6 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/annotation/PulsarListenerAnnotationBeanPostProcessor.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/annotation/PulsarListenerAnnotationBeanPostProcessor.java @@ -167,19 +167,6 @@ public class PulsarListenerAnnotationBeanPostProcessor return LOWEST_PRECEDENCE; } - public void setEndpointRegistry(PulsarListenerEndpointRegistry endpointRegistry) { - this.endpointRegistry = endpointRegistry; - } - - public void setDefaultContainerFactoryBeanName(String containerFactoryBeanName) { - this.defaultContainerFactoryBeanName = containerFactoryBeanName; - } - - public void setCharset(Charset charset) { - Assert.notNull(charset, "'charset' cannot be null"); - this.charset = charset; - } - @Override public void afterPropertiesSet() { buildEnhancer(); @@ -603,20 +590,6 @@ public class PulsarListenerAnnotationBeanPostProcessor return method; } - private Collection findListenerAnnotations(Class clazz) { - Set listeners = new HashSet<>(); - PulsarListener ann = AnnotatedElementUtils.findMergedAnnotation(clazz, PulsarListener.class); - if (ann != null) { - ann = enhance(clazz, ann); - listeners.add(ann); - } - PulsarListeners anns = AnnotationUtils.findAnnotation(clazz, PulsarListeners.class); - if (anns != null) { - listeners.addAll(Arrays.stream(anns.value()).map(anno -> enhance(clazz, anno)).toList()); - } - return listeners; - } - private Set findListenerAnnotations(Method method) { Set listeners = new HashSet<>(); PulsarListener ann = AnnotatedElementUtils.findMergedAnnotation(method, PulsarListener.class);