Examples of ConnectStringParser

org.apache.zookeeper.client.ConnectStringParser
A parser for ZooKeeper Client connect strings. This class is not meant to be seen or used outside of ZooKeeper itself. The chrootPath member should be replaced by a Path object in issue ZOOKEEPER-849. @see org.apache.zookeeper.ZooKeeper

Examples of org.apache.zookeeper.client.ConnectStringParser

        LOG.info("Initiating client connection, connectString=" + connectString
                + " sessionTimeout=" + sessionTimeout + " watcher=" + watcher);


        watchManager.defaultWatcher = watcher;


        ConnectStringParser connectStringParser = new ConnectStringParser(
                connectString);
        HostProvider hostProvider = new StaticHostProvider(
                connectStringParser.getServerAddresses());
        cnxn = new ClientCnxn(connectStringParser.getChrootPath(),
                hostProvider, sessionTimeout, this, watchManager,
                getClientCnxnSocket(), canBeReadOnly);
        cnxn.start();
    }

View Full Code Here

Examples of org.apache.zookeeper.client.ConnectStringParser

                + " sessionPasswd="
                + (sessionPasswd == null ? "<null>" : "<hidden>"));


        watchManager.defaultWatcher = watcher;


        ConnectStringParser connectStringParser = new ConnectStringParser(
                connectString);
        HostProvider hostProvider = new StaticHostProvider(
                connectStringParser.getServerAddresses());
        cnxn = new ClientCnxn(connectStringParser.getChrootPath(),
                hostProvider, sessionTimeout, this, watchManager,
                getClientCnxnSocket(), sessionId, sessionPasswd, canBeReadOnly);
        cnxn.seenRwServerBefore = true; // since user has provided sessionId
        cnxn.start();
    }

View Full Code Here

Examples of org.apache.zookeeper.client.ConnectStringParser

        LOG.info("Initiating client connection, connectString=" + connectString
                + " sessionTimeout=" + sessionTimeout + " watcher=" + watcher);


        watchManager.defaultWatcher = watcher;


        ConnectStringParser connectStringParser = new ConnectStringParser(
                connectString);
        HostProvider hostProvider = new StaticHostProvider(
                connectStringParser.getServerAddresses());
        cnxn = new ClientCnxn(connectStringParser.getChrootPath(),
                hostProvider, sessionTimeout, this, watchManager,
                getClientCnxnSocket(), canBeReadOnly);
        cnxn.start();
    }

View Full Code Here

Examples of org.apache.zookeeper.client.ConnectStringParser

                + " sessionPasswd="
                + (sessionPasswd == null ? "<null>" : "<hidden>"));


        watchManager.defaultWatcher = watcher;


        ConnectStringParser connectStringParser = new ConnectStringParser(
                connectString);
        HostProvider hostProvider = new StaticHostProvider(
                connectStringParser.getServerAddresses());
        cnxn = new ClientCnxn(connectStringParser.getChrootPath(),
                hostProvider, sessionTimeout, this, watchManager,
                getClientCnxnSocket(), sessionId, sessionPasswd, canBeReadOnly);
        cnxn.seenRwServerBefore = true; // since user has provided sessionId
        cnxn.start();
    }

View Full Code Here

Examples of org.apache.zookeeper.client.ConnectStringParser

                    ClientCnxn cnxn = (ClientCnxn) ReflectionUtils.getField(clientCnxnField, zk);
                    HostProvider hostProvider = (HostProvider) ReflectionUtils.getField(hostProviderField, cnxn);
                    List<InetSocketAddress> serverAddrs = (List<InetSocketAddress>) ReflectionUtils.getField(serverAddressesField,
                                                                                                             hostProvider);
                    // 添加第二组集群列表
                    serverAddrs.addAll(new ConnectStringParser(cluster).getServerAddresses());
                }
            }
        } catch (Exception e) {
            try {
                if (zk != null) {

View Full Code Here

Examples of org.apache.zookeeper.client.ConnectStringParser

        LOG.info("Initiating client connection, connectString=" + connectString
                + " sessionTimeout=" + sessionTimeout + " watcher=" + watcher);


        watchManager.defaultWatcher = watcher;


        ConnectStringParser connectStringParser = new ConnectStringParser(
                connectString);
        HostProvider hostProvider = new StaticHostProvider(
                connectStringParser.getServerAddresses());
        cnxn = new ClientCnxn(connectStringParser.getChrootPath(),
                hostProvider, sessionTimeout, this, watchManager,
                getClientCnxnSocket(), canBeReadOnly);
        cnxn.start();
    }

View Full Code Here

Examples of org.apache.zookeeper.client.ConnectStringParser

                + " sessionPasswd="
                + (sessionPasswd == null ? "<null>" : "<hidden>"));


        watchManager.defaultWatcher = watcher;


        ConnectStringParser connectStringParser = new ConnectStringParser(
                connectString);
        HostProvider hostProvider = new StaticHostProvider(
                connectStringParser.getServerAddresses());
        cnxn = new ClientCnxn(connectStringParser.getChrootPath(),
                hostProvider, sessionTimeout, this, watchManager,
                getClientCnxnSocket(), sessionId, sessionPasswd, canBeReadOnly);
        cnxn.seenRwServerBefore = true; // since user has provided sessionId
        cnxn.start();
    }

View Full Code Here

Examples of org.apache.zookeeper.client.ConnectStringParser

        LOG.info("Initiating client connection, connectString=" + connectString
                + " sessionTimeout=" + sessionTimeout + " watcher=" + watcher);


        watchManager.defaultWatcher = watcher;


        ConnectStringParser connectStringParser = new ConnectStringParser(
                connectString);
        HostProvider hostProvider = new StaticHostProvider(
                connectStringParser.getServerAddresses());
        cnxn = new ClientCnxn(connectStringParser.getChrootPath(),
                hostProvider, sessionTimeout, this, watchManager,
                getClientCnxnSocket(), canBeReadOnly);
        cnxn.start();
    }

View Full Code Here

Examples of org.apache.zookeeper.client.ConnectStringParser

                + " sessionPasswd="
                + (sessionPasswd == null ? "<null>" : "<hidden>"));


        watchManager.defaultWatcher = watcher;


        ConnectStringParser connectStringParser = new ConnectStringParser(
                connectString);
        HostProvider hostProvider = new StaticHostProvider(
                connectStringParser.getServerAddresses());
        cnxn = new ClientCnxn(connectStringParser.getChrootPath(),
                hostProvider, sessionTimeout, this, watchManager,
                getClientCnxnSocket(), sessionId, sessionPasswd, canBeReadOnly);
        cnxn.seenRwServerBefore = true; // since user has provided sessionId
        cnxn.start();
    }

View Full Code Here

Examples of org.apache.zookeeper.client.ConnectStringParser

    }


    @VisibleForTesting
    ResolvingEnsembleProvider(String connectString, Resolver resolver) {
        _resolver = resolver;
        _connectStringParser = new ConnectStringParser(connectString);
    }

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.