com.alibaba.dubbo.registry.support

Class ProviderConsumerRegTable

java.lang.Object

com.alibaba.dubbo.registry.support.ProviderConsumerRegTable

public class ProviderConsumerRegTable
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static ConcurrentHashMap<String,Set<ConsumerInvokerWrapper>>	consumerInvokers
static ConcurrentHashMap<String,Set<ProviderInvokerWrapper>>	providerInvokers

Constructor Summary

Constructors

Constructor and Description
ProviderConsumerRegTable()

Method Summary

Methods

Modifier and Type	Method and Description
static Set<ConsumerInvokerWrapper>	getConsumerInvoker(String serviceUniqueName)
static Set<ProviderInvokerWrapper>	getProviderInvoker(String serviceUniqueName)
static ProviderInvokerWrapper	getProviderWrapper(com.alibaba.dubbo.rpc.Invoker invoker)
static void	registerConsumer(com.alibaba.dubbo.rpc.Invoker invoker, com.alibaba.dubbo.common.URL registryUrl, com.alibaba.dubbo.common.URL consumerUrl, RegistryDirectory registryDirectory)
static void	registerProvider(com.alibaba.dubbo.rpc.Invoker invoker, com.alibaba.dubbo.common.URL registryUrl, com.alibaba.dubbo.common.URL providerUrl)

Methods inherited from class java.lang.Object

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

Field Detail

providerInvokers

public static ConcurrentHashMap<String,Set<ProviderInvokerWrapper>> providerInvokers

consumerInvokers

public static ConcurrentHashMap<String,Set<ConsumerInvokerWrapper>> consumerInvokers

Constructor Detail

ProviderConsumerRegTable

public ProviderConsumerRegTable()

Method Detail

registerProvider

public static void registerProvider(com.alibaba.dubbo.rpc.Invoker invoker,
                    com.alibaba.dubbo.common.URL registryUrl,
                    com.alibaba.dubbo.common.URL providerUrl)

getProviderInvoker

public static Set<ProviderInvokerWrapper> getProviderInvoker(String serviceUniqueName)

getProviderWrapper

public static ProviderInvokerWrapper getProviderWrapper(com.alibaba.dubbo.rpc.Invoker invoker)

registerConsumer

public static void registerConsumer(com.alibaba.dubbo.rpc.Invoker invoker,
                    com.alibaba.dubbo.common.URL registryUrl,
                    com.alibaba.dubbo.common.URL consumerUrl,
                    RegistryDirectory registryDirectory)

getConsumerInvoker

public static Set<ConsumerInvokerWrapper> getConsumerInvoker(String serviceUniqueName)