changes

goafabric · Jul 6, 2024 · a42e656 · a42e656
1 parent 6fa53e5
commit a42e656
Showing 1 changed file with 9 additions and 12 deletions.
diff --git a/src/main/java/org/goafabric/eventdispatcher/consumer/nats/NatsListenerAspect.java b/src/main/java/org/goafabric/eventdispatcher/consumer/nats/NatsListenerAspect.java
@@ -36,18 +36,15 @@ public NatsListenerAspect(NatsSubscription natsSubscription, ApplicationContext
 
     @PostConstruct
     public void init() {
-        String[] beanNames = applicationContext.getBeanDefinitionNames();
-        for (String beanName : beanNames) {
-            if (!beanName.equals("natsListenerAspect")) {
-                Object bean = applicationContext.getBean(beanName);
-                Arrays.stream(AopUtils.getTargetClass(bean).getDeclaredMethods())
-                        .filter(method -> method.isAnnotationPresent(NatsListener.class))
-                        .forEach(method -> {
-                            NatsListener natsListener = method.getAnnotation(NatsListener.class);
-                            setupSubscription(bean, method, natsListener);
-                        });
-            }
-        }
+        Arrays.stream(applicationContext.getBeanDefinitionNames())
+                .filter(beanName -> !beanName.equals("natsListenerAspect"))
+                .forEach(beanName -> {
+                    var bean = applicationContext.getBean(beanName);
+                    Arrays.stream(AopUtils.getTargetClass(bean).getDeclaredMethods())
+                            .filter(method -> method.isAnnotationPresent(NatsListener.class))
+                            .forEach(method -> setupSubscription(bean, method, method.getAnnotation(NatsListener.class)));
+                });
+
     }
 
     private void setupSubscription(Object bean, Method method, NatsListener natsListener) {