程序包 | 说明 |
---|---|
com.fr.cluster.engine.transport.context.impl | |
com.fr.cluster.message |
限定符和类型 | 方法和说明 |
---|---|
<Request,Response> |
FineClusterContext.newBuilder(ClusterServer<Request,Response> server) |
限定符和类型 | 方法和说明 |
---|---|
<Request,Response> |
ClusterConnectionFactory.newBuilder(ClusterServer<Request,Response> server)
获取构造器
必须指定server
|
ClusterConnectionFactory.Builder<Request,Response> |
ClusterConnectionFactory.Builder.setDefaultMessageTags(ClusterClient.MessageTag[] defaultTag)
默认消息标签
|
ClusterConnectionFactory.Builder<Request,Response> |
ClusterConnectionFactory.Builder.setName(java.lang.String name)
设置连接名,默认为server的className
|
ClusterConnectionFactory.Builder<Request,Response> |
ClusterConnectionFactory.Builder.setRequestSerializer(Serializer<Request> serializer)
设置请求的序列化器,默认为SerializerSummary.getDefault()
|
ClusterConnectionFactory.Builder<Request,Response> |
ClusterConnectionFactory.Builder.setResponseSerializer(Serializer<Response> serializer)
设置响应的序列化器,默认为SerializerSummary.getDefault()
|
ClusterConnectionFactory.Builder<Request,Response> |
ClusterConnectionFactory.Builder.setTimeout(long timeout)
超时时间
|