private void startTapListener(CuratorFramework client) {
		String tapPath = Paths.build(Paths.TAPS);
		Paths.ensurePath(client, tapPath);
		taps = new PathChildrenCache(client, tapPath, true,
				ThreadUtils.newThreadFactory("TapsPathChildrenCache"));
		taps.getListenable().addListener(tapListener);
		try {
			taps.start(PathChildrenCache.StartMode.POST_INITIALIZED_EVENT);
		}
		catch (Exception e) {
			throw ZooKeeperUtils.wrapThrowable(e, "failed to start TapListener");
		}
	}
Map of channels that can be tapped. The keys are the tap channel names (e.g. tap:stream:ticktock.time.0),
and the values are the output channels from modules where the actual WireTap interceptors would be added.
spring-xd-dirt/src/main/java/org/springframework/xd/dirt/plugins/AbstractMessageBusBinderPlugin.java