public static interface ClusterConnectionFactory.Builder<Request,Response>
限定符和类型 | 方法和说明 |
---|---|
ClusterClient<Request,Response> |
build()
构建
|
ClusterConnectionFactory.Builder<Request,Response> |
setDefaultMessageTags(ClusterClient.MessageTag[] defaultTag)
默认消息标签
|
ClusterConnectionFactory.Builder<Request,Response> |
setName(java.lang.String name)
设置连接名,默认为server的className
|
ClusterConnectionFactory.Builder<Request,Response> |
setRequestSerializer(Serializer<Request> serializer)
设置请求的序列化器,默认为SerializerSummary.getDefault()
|
ClusterConnectionFactory.Builder<Request,Response> |
setResponseSerializer(Serializer<Response> serializer)
设置响应的序列化器,默认为SerializerSummary.getDefault()
|
ClusterConnectionFactory.Builder<Request,Response> |
setTimeout(long timeout)
超时时间
|
ClusterConnectionFactory.Builder<Request,Response> setName(java.lang.String name)
ClusterConnectionFactory.Builder<Request,Response> setRequestSerializer(Serializer<Request> serializer)
ClusterConnectionFactory.Builder<Request,Response> setResponseSerializer(Serializer<Response> serializer)
ClusterConnectionFactory.Builder<Request,Response> setTimeout(long timeout)
ClusterConnectionFactory.Builder<Request,Response> setDefaultMessageTags(ClusterClient.MessageTag[] defaultTag)
ClusterClient<Request,Response> build()