RSocketServiceAnnotationProcessor extends LocalReactiveServiceCallerImpl implements BeanPostProcessor { protected void scanRSocketServiceAnnotation(Object bean, String beanName) { Class<?> managedBeanClass = bean.getClass(); RSocketService reactiveService = AnnotationUtils.findAnnotation(managedBeanClass, RSocketService.class); if (reactiveService != null) { registerRSocketService(reactiveService, bean); } } RSocketServiceAnnotationProcessor(RSocketProperties rsocketProperties); @Override Object postProcessBeforeInitialization(@NotNull Object bean, String beanName); @Override Object postProcessAfterInitialization(@NotNull Object bean, String beanName);  }
@Test public void testScanRSocketServiceAnnotation() { ReactiveTestService reactiveTestService = new ReactiveTestServiceImpl(); processor.scanRSocketServiceAnnotation(reactiveTestService, "reactiveTestService"); Assertions.assertTrue(processor.contains(ReactiveTestService.class.getCanonicalName())); Assertions.assertNotNull(processor.getInvokeMethod(ReactiveTestService.class.getCanonicalName(),"findNickById")); }