@Override
	public void consumeMessage(DeploymentMessage deploymentMessage) throws Exception {
		switch (deploymentMessage.getDeploymentUnitType()) {
			case Stream:
				processDeploymentMessage(streamDeployer, deploymentMessage);
				break;
			case Job:
				processDeploymentMessage(jobDeployer, deploymentMessage);
				break;
		}
	}
Consume the deployment message and delegate to the deployer.

@param deploymentMessage the deployment message
@throws Exception
spring-xd-dirt/src/main/java/org/springframework/xd/dirt/server/admin/deployment/zk/DeploymentMessageConsumer.java