ressurected old KillSession.java for backward compatibilty
Project: http://git-wip-us.apache.org/repos/asf/curator/repo Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/c05b6ca6 Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/c05b6ca6 Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/c05b6ca6 Branch: refs/heads/master Commit: c05b6ca646f756d2670243e09f3605c786dbdc75 Parents: 171a200 Author: randgalt <[email protected]> Authored: Sun Jul 23 14:10:57 2017 -0500 Committer: randgalt <[email protected]> Committed: Sun Jul 23 14:10:57 2017 -0500 ---------------------------------------------------------------------- .../org/apache/curator/test/KillSession.java | 67 ++++++++++++++++++++ 1 file changed, 67 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/curator/blob/c05b6ca6/curator-test/src/main/java/org/apache/curator/test/KillSession.java ---------------------------------------------------------------------- diff --git a/curator-test/src/main/java/org/apache/curator/test/KillSession.java b/curator-test/src/main/java/org/apache/curator/test/KillSession.java new file mode 100644 index 0000000..ce2b7e6 --- /dev/null +++ b/curator-test/src/main/java/org/apache/curator/test/KillSession.java @@ -0,0 +1,67 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +package org.apache.curator.test; + +import org.apache.zookeeper.ZooKeeper; + +/** + * <p> + * Utility to simulate a ZK session dying. + * </p> + */ +public class KillSession +{ + /** + * Kill the given ZK session + * + * @param client the client to kill + * @since 3.0.0 + */ + public static void kill(ZooKeeper client) + { + client.getTestable().injectSessionExpiration(); + } + + /** + * Kill the given ZK session + * + * @param client the client to kill + * @param connectString server connection string + * @throws Exception errors + * @deprecated use {@link #kill(ZooKeeper)} instead + */ + public static void kill(ZooKeeper client, String connectString) throws Exception + { + kill(client); + } + + /** + * Kill the given ZK session + * + * @param client the client to kill + * @param connectString server connection string + * @param maxMs max time ms to wait for kill + * @throws Exception errors + * @deprecated use {@link #kill(ZooKeeper)} instead + */ + public static void kill(ZooKeeper client, String connectString, int maxMs) throws Exception + { + kill(client); + } +}
