Package com.alibaba.spring.boot.rsocket.responder.invocation

Class RSocketServiceAnnotationProcessor

java.lang.Object

com.alibaba.rsocket.rpc.LocalReactiveServiceCallerImpl

com.alibaba.spring.boot.rsocket.responder.invocation.RSocketServiceAnnotationProcessor

All Implemented Interfaces:

LocalReactiveServiceCaller, ReactiveServiceDiscovery, org.springframework.beans.factory.config.BeanPostProcessor

public class RSocketServiceAnnotationProcessor
extends LocalReactiveServiceCallerImpl
implements org.springframework.beans.factory.config.BeanPostProcessor

RSocketService annotation processor

Author:

leijuan

Constructor Summary

Constructors

Constructor	Description
RSocketServiceAnnotationProcessor(RSocketProperties rsocketProperties)

Method Summary

Modifier and Type	Method	Description
Object	postProcessAfterInitialization(@NotNull Object bean, String beanName)
Object	postProcessBeforeInitialization(@NotNull Object bean, String beanName)
protected void	scanRSocketServiceAnnotation(Object bean, String beanName)

Methods inherited from class com.alibaba.rsocket.rpc.LocalReactiveServiceCallerImpl

addProvider, contains, contains, contains, containsHandler, createReactiveServiceInterface, findAllServices, findServiceByFullName, getInvokeMethod, getInvokeMethod, removeProvider

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RSocketServiceAnnotationProcessor

public RSocketServiceAnnotationProcessor(RSocketProperties rsocketProperties)

Method Detail

postProcessBeforeInitialization

public Object postProcessBeforeInitialization(@NotNull
                                              @NotNull Object bean,
                                              String beanName)
                                       throws org.springframework.beans.BeansException

Specified by:

postProcessBeforeInitialization in interface org.springframework.beans.factory.config.BeanPostProcessor

Throws:

org.springframework.beans.BeansException

postProcessAfterInitialization

public Object postProcessAfterInitialization(@NotNull
                                             @NotNull Object bean,
                                             String beanName)
                                      throws org.springframework.beans.BeansException

Specified by:

postProcessAfterInitialization in interface org.springframework.beans.factory.config.BeanPostProcessor

Throws:

org.springframework.beans.BeansException

scanRSocketServiceAnnotation

protected void scanRSocketServiceAnnotation(Object bean,
                                            String beanName)