com.baidu.brpc.naming

Class FailbackNamingService

java.lang.Object

com.baidu.brpc.naming.FailbackNamingService

All Implemented Interfaces:

NamingService

public abstract class FailbackNamingService
extends Object
implements NamingService

Field Summary

Fields

Modifier and Type	Field and Description
protected io.netty.util.internal.ConcurrentSet<RegisterInfo>	failedRegisters
protected ConcurrentMap<SubscribeInfo,NotifyListener>	failedSubscribes
protected io.netty.util.internal.ConcurrentSet<RegisterInfo>	failedUnregisters
protected io.netty.util.internal.ConcurrentSet<SubscribeInfo>	failedUnsubscribes

Constructor Summary

Constructors

Constructor and Description
FailbackNamingService(BrpcURL url)

Method Summary

Modifier and Type	Method and Description
void	destroy()
abstract void	doRegister(RegisterInfo registerInfo)
abstract void	doSubscribe(SubscribeInfo subscribeInfo, NotifyListener listener)
abstract void	doUnregister(RegisterInfo registerInfo)
abstract void	doUnsubscribe(SubscribeInfo subscribeInfo)
void	register(RegisterInfo registerInfo) 注册数据，比如：提供者地址，消费者地址，路由规则，覆盖规则，等数据。
void	subscribe(SubscribeInfo subscribeInfo, NotifyListener listener) 订阅符合条件的已注册数据，当有注册数据变更时自动推送.
void	unregister(RegisterInfo registerInfo) 取消注册.
void	unsubscribe(SubscribeInfo subscribeInfo) 取消订阅.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.baidu.brpc.naming.NamingService

lookup

Field Detail

failedRegisters

protected io.netty.util.internal.ConcurrentSet<RegisterInfo> failedRegisters

failedUnregisters

protected io.netty.util.internal.ConcurrentSet<RegisterInfo> failedUnregisters

failedSubscribes

protected ConcurrentMap<SubscribeInfo,NotifyListener> failedSubscribes

failedUnsubscribes

protected io.netty.util.internal.ConcurrentSet<SubscribeInfo> failedUnsubscribes

Constructor Detail

FailbackNamingService

public FailbackNamingService(BrpcURL url)

Method Detail

subscribe

public void subscribe(SubscribeInfo subscribeInfo,
                      NotifyListener listener)

Description copied from interface: NamingService

订阅符合条件的已注册数据，当有注册数据变更时自动推送.

Specified by:

subscribe in interface NamingService

listener - 变更事件监听器，不允许为空

unsubscribe

public void unsubscribe(SubscribeInfo subscribeInfo)

Description copied from interface: NamingService

取消订阅.

Specified by:

unsubscribe in interface NamingService

register

public void register(RegisterInfo registerInfo)

Description copied from interface: NamingService

注册数据，比如：提供者地址，消费者地址，路由规则，覆盖规则，等数据。

Specified by:

register in interface NamingService

Parameters:

registerInfo - service/group/version info

unregister

public void unregister(RegisterInfo registerInfo)

Description copied from interface: NamingService

取消注册.

Specified by:

unregister in interface NamingService

Parameters:

registerInfo - service/group/version info

destroy

public void destroy()

Specified by:

destroy in interface NamingService

doSubscribe

public abstract void doSubscribe(SubscribeInfo subscribeInfo,
                                 NotifyListener listener)
                          throws Exception

Throws:

Exception

doUnsubscribe

public abstract void doUnsubscribe(SubscribeInfo subscribeInfo)
                            throws Exception

Throws:

Exception

doRegister

public abstract void doRegister(RegisterInfo registerInfo)
                         throws Exception

Throws:

Exception

doUnregister

public abstract void doUnregister(RegisterInfo registerInfo)
                           throws Exception

Throws:

Exception