Skip to content

Commit 1bcbeb3

Browse files
committed
Remove listenerScope field override in annotation processors
This commit fixes the case where SpEL expressions using the `__listener.` bean ref were failing due to the concrete impls of the `AbstractPulsarAnnotationsBeanPostProcessor` hiding/overriding their parent's `listenerScope` field by removing the `listenerScope` field from the following concrete impls: - PulsarListenerAnnotationBeanPostProcessor - ReactivePulsarListenerAnnotationBeanPostProcessor Fixes #1169 Signed-off-by: Chris Bono <[email protected]>
1 parent b45b9eb commit 1bcbeb3

File tree

2 files changed

+0
-4
lines changed

2 files changed

+0
-4
lines changed

spring-pulsar-reactive/src/main/java/org/springframework/pulsar/reactive/config/annotation/ReactivePulsarListenerAnnotationBeanPostProcessor.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -108,8 +108,6 @@ public class ReactivePulsarListenerAnnotationBeanPostProcessor<V> extends Abstra
108108

109109
private final Set<Class<?>> nonAnnotatedClasses = Collections.newSetFromMap(new ConcurrentHashMap<>(64));
110110

111-
private final ListenerScope listenerScope = new ListenerScope();
112-
113111
private final AtomicInteger counter = new AtomicInteger();
114112

115113
private final List<MethodReactivePulsarListenerEndpoint<?>> processedEndpoints = new ArrayList<>();

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -105,8 +105,6 @@ public class PulsarListenerAnnotationBeanPostProcessor<V> extends AbstractPulsar
105105

106106
private final Set<Class<?>> nonAnnotatedClasses = Collections.newSetFromMap(new ConcurrentHashMap<>(64));
107107

108-
private final ListenerScope listenerScope = new ListenerScope();
109-
110108
private final AtomicInteger counter = new AtomicInteger();
111109

112110
private final List<MethodPulsarListenerEndpoint<?>> processedEndpoints = new ArrayList<>();

0 commit comments

Comments
 (0)