程序包 org.apache.dubbo.rpc.cluster.filter.support

类 ConsumerContextFilter

java.lang.Object

org.apache.dubbo.rpc.cluster.filter.support.ConsumerContextFilter

所有已实现的接口:

BaseFilter, BaseFilter.Listener, ClusterFilter

@Activate(group="consumer",
          order=-10000)
public class ConsumerContextFilter
extends Object
implements ClusterFilter, BaseFilter.Listener

ConsumerContextFilter set current RpcContext with invoker,invocation, local host, remote host and port for consumer invoker.It does it to make the requires info available to execution thread's RpcContext.

另请参阅:

Filter, RpcContext

嵌套类概要

从接口继承的嵌套类/接口 org.apache.dubbo.rpc.BaseFilter

BaseFilter.Listener

构造器概要

构造器

构造器	说明
ConsumerContextFilter()

方法概要

修饰符和类型	方法	说明
Result	invoke(Invoker<?> invoker, Invocation invocation)	Make sure call invoker.invoke() in your implementation.
void	onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)

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

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

构造器详细资料

ConsumerContextFilter

public ConsumerContextFilter()

方法详细资料

invoke

public Result invoke(Invoker<?> invoker,
                     Invocation invocation)
              throws RpcException

从接口复制的说明: BaseFilter

Make sure call invoker.invoke() in your implementation.

指定者:

invoke 在接口中 BaseFilter

抛出:

RpcException

onResponse

public void onResponse(Result appResponse,
                       Invoker<?> invoker,
                       Invocation invocation)

指定者:

onResponse 在接口中 BaseFilter.Listener

onError

public void onError(Throwable t,
                    Invoker<?> invoker,
                    Invocation invocation)

指定者:

onError 在接口中 BaseFilter.Listener