接口 com.fr.cluster.engine.transport.context.ClusterMessageReceiverRepo
的使用

使用ClusterMessageReceiverRepo的程序包

程序包	说明
com.fr.cluster.engine.transport.context
com.fr.cluster.engine.transport.context.components	Created by juhaoyu on 2017/12/13.
com.fr.cluster.engine.transport.context.impl
com.fr.cluster.engine.transport.context.impl.adaptor

com.fr.cluster.engine.transport.context中ClusterMessageReceiverRepo的使用

返回ClusterMessageReceiverRepo的com.fr.cluster.engine.transport.context中的方法

限定符和类型	方法和说明
ClusterMessageReceiverRepo	ClusterContext.getReceiverRepo() 获取receiver仓库

com.fr.cluster.engine.transport.context.components中ClusterMessageReceiverRepo的使用

参数类型为ClusterMessageReceiverRepo的com.fr.cluster.engine.transport.context.components中的方法

限定符和类型	方法和说明
ClusterMessageReceiver	ClusterMessageDispatcher.chooseReceiver(T message, ClusterMessageReceiverRepo receiverRepo) 选择出正确的Receiver

com.fr.cluster.engine.transport.context.impl中ClusterMessageReceiverRepo的使用

实现ClusterMessageReceiverRepo的com.fr.cluster.engine.transport.context.impl中的类

限定符和类型	类和说明
class	FineClusterReceiverRepo Created by juhaoyu on 2017/12/20.

返回ClusterMessageReceiverRepo的com.fr.cluster.engine.transport.context.impl中的方法

限定符和类型	方法和说明
ClusterMessageReceiverRepo	FineClusterContext.getReceiverRepo()

参数类型为ClusterMessageReceiverRepo的com.fr.cluster.engine.transport.context.impl中的方法

限定符和类型	方法和说明
ClusterMessageReceiver	DefaultMessageDispatcher.chooseReceiver(com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage message, ClusterMessageReceiverRepo receiverRepo)

参数类型为ClusterMessageReceiverRepo的com.fr.cluster.engine.transport.context.impl中的构造器

构造器和说明
FineClusterContext(ClusterMessageSender sender, ClusterMessageReceiverRepo receiverRepo, boolean forceSyncAll)

com.fr.cluster.engine.transport.context.impl.adaptor中ClusterMessageReceiverRepo的使用

参数类型为ClusterMessageReceiverRepo的com.fr.cluster.engine.transport.context.impl.adaptor中的构造器

构造器和说明
RequestHandlerAdaptor(ClusterMessageDispatcher<?> messageDispatcher, ClusterMessageReceiverRepo receiverRepo)