protected class IntegrationTestReplication.ClusterID
extends java.lang.Object
Constructor and Description |
---|
ClusterID(Configuration base,
java.lang.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() |
java.lang.String |
toString() |
public ClusterID(Configuration base, java.lang.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 java.lang.String toString()
toString
in class java.lang.Object
public Configuration getConfiguration()
public Connection getConnection() throws java.lang.Exception
java.lang.Exception
public void closeConnection() throws java.lang.Exception
java.lang.Exception
public boolean equals(IntegrationTestReplication.ClusterID other)