com.baidu.jprotobuf.pbrpc.spring

类 HaProtobufRpcProxyBean<T>

java.lang.Object

com.baidu.jprotobuf.pbrpc.client.ha.NamingServiceChangeListener

com.baidu.jprotobuf.pbrpc.client.ha.HaProtobufRpcProxy<T>

com.baidu.jprotobuf.pbrpc.spring.HaProtobufRpcProxyBean<T>

类型参数:

T - the generic type

所有已实现的接口:

org.aopalliance.aop.Advice, org.aopalliance.intercept.Interceptor, org.aopalliance.intercept.MethodInterceptor

public class HaProtobufRpcProxyBean<T>
extends HaProtobufRpcProxy<T>

To enhance HaProtobufRpcProxy to process extra parameters transportation.

从以下版本开始:

2.17

作者:

xiemalin

字段概要

从类继承的字段 com.baidu.jprotobuf.pbrpc.client.ha.HaProtobufRpcProxy

LOGGER

构造器概要

构造器

构造器和说明
HaProtobufRpcProxyBean(RpcClient rpcClient, Class<T> interfaceClass, NamingService namingService) Instantiates a new ha protobuf rpc proxy bean.
HaProtobufRpcProxyBean(RpcClient rpcClient, Class<T> interfaceClass, NamingService namingService, NamingServiceLoadBalanceStrategyFactory loadBalanceStrategyFactory, SocketFailOverInterceptor failOverInterceptor) Instantiates a new ha protobuf rpc proxy bean.

方法概要

方法

限定符和类型	方法和说明
org.springframework.remoting.support.RemoteInvocationFactory	getRemoteInvocationFactory() Gets the remote invocation factory.
Object	invoke(org.aopalliance.intercept.MethodInvocation invocation)
protected ProtobufRpcProxy<T>	onBuildProtobufRpcProxy(RpcClient rpcClient, Class<T> interfaceClass) On build protobuf rpc proxy.
void	setRemoteInvocationFactory(org.springframework.remoting.support.RemoteInvocationFactory remoteInvocationFactory) Sets the remote invocation factory.

从类继承的方法 com.baidu.jprotobuf.pbrpc.client.ha.HaProtobufRpcProxy

close, getNamingService, isLookupStubOnStartup, proxy, reInit, setInterceptor, setLookupStubOnStartup

从类继承的方法 com.baidu.jprotobuf.pbrpc.client.ha.NamingServiceChangeListener

setDelay, setPeriod, startUpdateNamingServiceTask

从类继承的方法 java.lang.Object

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

构造器详细资料

HaProtobufRpcProxyBean

public HaProtobufRpcProxyBean(RpcClient rpcClient,
                      Class<T> interfaceClass,
                      NamingService namingService)

Instantiates a new ha protobuf rpc proxy bean.

参数:

rpcClient - the rpc client

interfaceClass - the interface class

namingService - the naming service

HaProtobufRpcProxyBean

public HaProtobufRpcProxyBean(RpcClient rpcClient,
                      Class<T> interfaceClass,
                      NamingService namingService,
                      NamingServiceLoadBalanceStrategyFactory loadBalanceStrategyFactory,
                      SocketFailOverInterceptor failOverInterceptor)

Instantiates a new ha protobuf rpc proxy bean.

参数:

rpcClient - the rpc client

interfaceClass - the interface class

namingService - the naming service

loadBalanceStrategyFactory - the load balance strategy factory

failOverInterceptor - the fail over interceptor

方法详细资料

getRemoteInvocationFactory

public org.springframework.remoting.support.RemoteInvocationFactory getRemoteInvocationFactory()

Gets the remote invocation factory.

返回:

the remote invocation factory

setRemoteInvocationFactory

public void setRemoteInvocationFactory(org.springframework.remoting.support.RemoteInvocationFactory remoteInvocationFactory)

Sets the remote invocation factory.

参数:

remoteInvocationFactory - the new remote invocation factory

onBuildProtobufRpcProxy

protected ProtobufRpcProxy<T> onBuildProtobufRpcProxy(RpcClient rpcClient,
                                          Class<T> interfaceClass)

从类复制的说明: HaProtobufRpcProxy

On build protobuf rpc proxy.

覆盖:

onBuildProtobufRpcProxy 在类中 HaProtobufRpcProxy<T>

参数:

rpcClient - the rpc client

interfaceClass - the interface class

返回:

the protobuf rpc proxy

invoke

public Object invoke(org.aopalliance.intercept.MethodInvocation invocation)
              throws Throwable

指定者:

invoke 在接口中 org.aopalliance.intercept.MethodInterceptor

覆盖:

invoke 在类中 HaProtobufRpcProxy<T>

抛出:

Throwable