@Override
		public void onDisconnect(CuratorFramework client) {
			taps.getListenable().removeListener(tapListener);
			try {
				taps.close();
			}
			catch (Exception e) {
				throw ZooKeeperUtils.wrapThrowable(e);
			}
		}
A {@link ZooKeeperConnectionListener} that manages the lifecycle of the taps cache listener.
spring-xd-dirt/src/main/java/org/springframework/xd/dirt/plugins/AbstractMessageBusBinderPlugin.java