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.Exceptionpublic void consumeMessage(DeploymentMessage deploymentMessage) throws java.lang.Exception
consumeMessage in interface org.apache.curator.framework.recipes.queue.QueueConsumer<DeploymentMessage>deploymentMessage - the deployment messagejava.lang.Exceptionpublic void stateChanged(org.apache.curator.framework.CuratorFramework client,
org.apache.curator.framework.state.ConnectionState newState)
stateChanged in interface org.apache.curator.framework.state.ConnectionStateListener