Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Further removal of unused code (#248)

Browse Source 
- Removing unused code in PulsarListenerAnnotationBeanPostProcessor
This commit is contained in:
Soby Chacko
2022-11-29 21:32:23 -05:00
committed by GitHub
parent ac87330416
commit a3077fe994
1 changed files with 0 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
spring-pulsar/src/main/java/org/springframework/pulsar/annotation/PulsarListenerAnnotationBeanPostProcessor.java
View File

@@ -167,19 +167,6 @@ public class PulsarListenerAnnotationBeanPostProcessor<V>
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<V>
return method;
}
private Collection<PulsarListener> findListenerAnnotations(Class<?> clazz) {
Set<PulsarListener> 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<PulsarListener> findListenerAnnotations(Method method) {
Set<PulsarListener> listeners = new HashSet<>();
PulsarListener ann = AnnotatedElementUtils.findMergedAnnotation(method, PulsarListener.class);