protected class IntegrationTestReplication.ClusterID extends Object
Constructor and Description |
---|
ClusterID(Configuration base,
String key)
This creates a new ClusterID wrapper that will automatically build connections and
configurations to be able to talk to the specified cluster
|
Modifier and Type | Method and Description |
---|---|
void |
closeConnection() |
boolean |
equals(IntegrationTestReplication.ClusterID other) |
Configuration |
getConfiguration() |
Connection |
getConnection() |
String |
toString() |
public ClusterID(Configuration base, String key)
base
- the base configuration that this class will add tokey
- the cluster key in the form of zk_quorum:zk_port:zk_parent_nodepublic Configuration getConfiguration()
public Connection getConnection() throws Exception
Exception
public boolean equals(IntegrationTestReplication.ClusterID other)