|
@@ -3028,9 +3028,12 @@ public class ZooKeeper implements AutoCloseable {
|
|
|
|
|
|
private ClientCnxnSocket getClientCnxnSocket() throws IOException {
|
|
private ClientCnxnSocket getClientCnxnSocket() throws IOException {
|
|
String clientCnxnSocketName = getClientConfig().getProperty(ZKClientConfig.ZOOKEEPER_CLIENT_CNXN_SOCKET);
|
|
String clientCnxnSocketName = getClientConfig().getProperty(ZKClientConfig.ZOOKEEPER_CLIENT_CNXN_SOCKET);
|
|
- if (clientCnxnSocketName == null) {
|
|
|
|
|
|
+ if (clientCnxnSocketName == null || clientCnxnSocketName.equals(ClientCnxnSocketNIO.class.getSimpleName())) {
|
|
clientCnxnSocketName = ClientCnxnSocketNIO.class.getName();
|
|
clientCnxnSocketName = ClientCnxnSocketNIO.class.getName();
|
|
|
|
+ } else if (clientCnxnSocketName.equals(ClientCnxnSocketNetty.class.getSimpleName())) {
|
|
|
|
+ clientCnxnSocketName = ClientCnxnSocketNetty.class.getName();
|
|
}
|
|
}
|
|
|
|
+
|
|
try {
|
|
try {
|
|
Constructor<?> clientCxnConstructor = Class.forName(clientCnxnSocketName)
|
|
Constructor<?> clientCxnConstructor = Class.forName(clientCnxnSocketName)
|
|
.getDeclaredConstructor(ZKClientConfig.class);
|
|
.getDeclaredConstructor(ZKClientConfig.class);
|