public class DeploymentMessageConsumer extends java.lang.Object implements org.apache.curator.framework.recipes.queue.QueueConsumer<DeploymentMessage>
DeploymentMessage
which delegates to the corresponding @ResourceDeployer
to process the deployment requests.Constructor and Description |
---|
DeploymentMessageConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
consumeMessage(DeploymentMessage deploymentMessage)
Consume the deployment message and delegate to the deployer.
|
void |
consumeMessage(DeploymentMessage message,
StreamDeployer streamDeployer,
JobDeployer jobDeployer) |
void |
stateChanged(org.apache.curator.framework.CuratorFramework client,
org.apache.curator.framework.state.ConnectionState newState) |
public void consumeMessage(DeploymentMessage message, StreamDeployer streamDeployer, JobDeployer jobDeployer) throws java.lang.Exception
java.lang.Exception
public void consumeMessage(DeploymentMessage deploymentMessage) throws java.lang.Exception
consumeMessage
in interface org.apache.curator.framework.recipes.queue.QueueConsumer<DeploymentMessage>
deploymentMessage
- the deployment messagejava.lang.Exception
public void stateChanged(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.state.ConnectionState newState)
stateChanged
in interface org.apache.curator.framework.state.ConnectionStateListener