public class FineClusterContext extends java.lang.Object implements ClusterContext
ClusterConnectionFactory.Builder<Request,Response>
构造器和说明 |
---|
FineClusterContext(ClusterMessageSender sender,
ClusterMessageReceiverRepo receiverRepo,
boolean forceSyncAll) |
限定符和类型 | 方法和说明 |
---|---|
<Request,Response> |
build(ClusterServer<Request,Response> server)
构建通信组件
在集群中,获取客户端组件时,必须提供对应的服务端组件,用于接收其他节点的对应请求
|
ClusterMessageSender |
getMessageSender()
获取ClusterMessage发送器
|
ClusterMessageReceiverRepo |
getReceiverRepo()
获取receiver仓库
|
<Request,Response> |
newBuilder(ClusterServer<Request,Response> server)
获取构造器
必须指定server
|
public FineClusterContext(ClusterMessageSender sender, ClusterMessageReceiverRepo receiverRepo, boolean forceSyncAll)
public ClusterMessageSender getMessageSender()
ClusterContext
getMessageSender
在接口中 ClusterContext
public ClusterMessageReceiverRepo getReceiverRepo()
ClusterContext
getReceiverRepo
在接口中 ClusterContext
public <Request,Response> ClusterClient<Request,Response> build(ClusterServer<Request,Response> server)
ClusterConnectionFactory
build
在接口中 ClusterConnectionFactory
public <Request,Response> ClusterConnectionFactory.Builder<Request,Response> newBuilder(ClusterServer<Request,Response> server)
ClusterConnectionFactory
newBuilder
在接口中 ClusterConnectionFactory