abstract class BaseClient extends Object implements AutoCloseable
Constructor and Description |
---|
BaseClient(List<StreamBaseURI> uris,
ClientSettings settings)
Construct a BaseClient with the given URI
|
Modifier and Type | Method and Description |
---|---|
abstract void |
close()
close the client
|
ClientSettings |
getSettings()
Return the settings for this client
|
StreamBaseURI |
getURI()
Return the URI used by this Client.
|
List<StreamBaseURI> |
getURIs()
get all of the URI's for this client
|
protected boolean |
haModeOn()
is HA mode on
|
String[] |
operatorStatus(String containerName)
Return the status of all the operators in the specified container
|
String[] |
status()
Return the status of the StreamBase Server
|
String[] |
status(boolean verbose)
Return the status of the StreamBase Server
|
BaseClient(List<StreamBaseURI> uris, ClientSettings settings) throws StreamBaseException
uris
- list of URIs to usesettings
- settingsStreamBaseException
- Node connection failedprotected boolean haModeOn()
public abstract void close() throws StreamBaseException
close
in interface AutoCloseable
StreamBaseException
public ClientSettings getSettings()
public String[] status() throws StreamBaseException
StreamBaseException
- thrown on network and other errorspublic String[] status(boolean verbose) throws StreamBaseException
verbose
- return a verbose statusStreamBaseException
- thrown on network and other errorspublic String[] operatorStatus(String containerName) throws StreamBaseException
containerName
- the name of the containerStreamBaseException
public StreamBaseURI getURI()
public List<StreamBaseURI> getURIs()
Copyright © 2015–2018 Cloud Software Group, Inc.. All rights reserved.