_miniCluster.getMaster().shutdown();
ZkClient zkClient = new ZkClient(_miniCluster.getZkConfiguration().getZKServers());
InteractionProtocol protocol = new InteractionProtocol(zkClient, _miniCluster.getZkConfiguration());
Master master = new Master(protocol, false);
master.start();
TestUtil.waitUntilBecomeMaster(master);
final IDeployClient deployClient = new DeployClient(_protocol);
WatchedEvent event = new WatchedEvent(new WatcherEvent(EventType.None.getIntValue(), KeeperState.Expired
.getIntValue(), null));