com.alibaba.dubbo.registry.support

Class ConsumerInvokerWrapper<T>

java.lang.Object

com.alibaba.dubbo.registry.support.ConsumerInvokerWrapper<T>

All Implemented Interfaces:

com.alibaba.dubbo.common.Node, com.alibaba.dubbo.rpc.Invoker

public class ConsumerInvokerWrapper<T>
extends Object
implements com.alibaba.dubbo.rpc.Invoker

Constructor Summary

Constructors

Constructor and Description
ConsumerInvokerWrapper(com.alibaba.dubbo.rpc.Invoker<T> invoker, com.alibaba.dubbo.common.URL registryUrl, com.alibaba.dubbo.common.URL consumerUrl, RegistryDirectory registryDirectory)

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy()
com.alibaba.dubbo.common.URL	getConsumerUrl()
Class<T>	getInterface()
com.alibaba.dubbo.rpc.Invoker<T>	getInvoker()
com.alibaba.dubbo.common.URL	getOriginUrl()
RegistryDirectory	getRegistryDirectory()
com.alibaba.dubbo.common.URL	getRegistryUrl()
com.alibaba.dubbo.common.URL	getUrl()
com.alibaba.dubbo.rpc.Result	invoke(com.alibaba.dubbo.rpc.Invocation invocation)
boolean	isAvailable()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerInvokerWrapper

public ConsumerInvokerWrapper(com.alibaba.dubbo.rpc.Invoker<T> invoker,
                      com.alibaba.dubbo.common.URL registryUrl,
                      com.alibaba.dubbo.common.URL consumerUrl,
                      RegistryDirectory registryDirectory)

Method Detail

getInterface

public Class<T> getInterface()

Specified by:

getInterface in interface com.alibaba.dubbo.rpc.Invoker

getUrl

public com.alibaba.dubbo.common.URL getUrl()

Specified by:

getUrl in interface com.alibaba.dubbo.common.Node

isAvailable

public boolean isAvailable()

Specified by:

isAvailable in interface com.alibaba.dubbo.common.Node

invoke

public com.alibaba.dubbo.rpc.Result invoke(com.alibaba.dubbo.rpc.Invocation invocation)
                                    throws com.alibaba.dubbo.rpc.RpcException

Specified by:

invoke in interface com.alibaba.dubbo.rpc.Invoker

Throws:

com.alibaba.dubbo.rpc.RpcException

destroy

public void destroy()

Specified by:

destroy in interface com.alibaba.dubbo.common.Node

getOriginUrl

public com.alibaba.dubbo.common.URL getOriginUrl()

getRegistryUrl

public com.alibaba.dubbo.common.URL getRegistryUrl()

getInvoker

public com.alibaba.dubbo.rpc.Invoker<T> getInvoker()

getConsumerUrl

public com.alibaba.dubbo.common.URL getConsumerUrl()

getRegistryDirectory

public RegistryDirectory getRegistryDirectory()