public void start() throws Exception {
		if (client != null) {
			QueueBuilder<DeploymentMessage> builder = QueueBuilder.builder(client, queueConsumer,
					new DeploymentMessageSerializer(), deploymentQueuePath);
			this.distributedQueue = builder.executor(executorService).buildQueue();
			this.distributedQueue.start();
		}
	}
Build and Start the ZK distributed queue.
@throws Exception
spring-xd-dirt/src/main/java/org/springframework/xd/dirt/server/admin/deployment/zk/DeploymentQueue.java