hmm

Author: SentryMan

src/main/java/com/mangasite/config/init/AvajeSpringAdapter.java

@@ -77,7 +77,8 @@ public void initialize(GenericApplicationContext context) {
                   .addCustomResolver(new AuthenticationPrincipalArgumentResolver());
 
               handler.registerMessagingAdvice(
-                  new ControllerAdviceWrapper(context.getBean(ControllerAdviceBean.class)));
+                  new ControllerAdviceWrapper(
+                      new ControllerAdviceBean(scope.get(RSocketAdvice.class))));
             });
   }
 }

src/main/java/com/mangasite/config/init/ControllerAdviceWrapper.java

@@ -1,33 +1,34 @@
 package com.mangasite.config.init;
 
 import org.springframework.messaging.handler.MessagingAdviceBean;
-import org.springframework.web.method.ControllerAdviceBean;
+
+import com.mangasite.rsocket.RSocketAdvice;
 
 public class ControllerAdviceWrapper implements MessagingAdviceBean {
-  private final ControllerAdviceBean delegate;
+  private final RSocketAdvice delegate;
 
-  public ControllerAdviceWrapper(ControllerAdviceBean delegate) {
-    this.delegate = delegate;
+  public ControllerAdviceWrapper(RSocketAdvice rSocketAdvice) {
+    this.delegate = rSocketAdvice;
   }
 
   @Override
   public int getOrder() {
-    return delegate.getOrder();
+    return 1;
   }
 
   @Override
   public Class<?> getBeanType() {
-    return delegate.getBeanType();
+    return delegate.getClass();
   }
 
   @Override
   public Object resolveBean() {
-    return delegate.resolveBean();
+    return delegate;
   }
 
   @Override
   public boolean isApplicableToBeanType(Class<?> beanType) {
-    return delegate.isApplicableToBeanType(beanType);
+    return beanType.isAssignableFrom(delegate.getClass());
   }
   // delegate all methods
 }