public class DominionControllerImpl extends Object implements MinionMessageReceiver
Constructor and Description |
---|
DominionControllerImpl() |
Modifier and Type | Method and Description |
---|---|
protected void |
assertCamelContextInitialized() |
protected void |
assertMessageSenderExists() |
void |
onMessage(MinionMessage message) |
protected void |
sendInitializationMessage(MinionInitializationMessage message) |
void |
setBrokerUri(String brokerUri) |
void |
setCamelContext(org.apache.camel.CamelContext context) |
void |
setListenQueueName(String queueName) |
void |
setMessageReceiver(MinionMessageReceiver receiver) |
void |
setMessageSender(MinionMessageSender sender) |
void |
setStatusMessageWriter(StatusMessageWriter writer) |
void |
start() |
void |
stop() |
public void start() throws MinionException
MinionException
public void stop() throws MinionException
MinionException
public void onMessage(MinionMessage message) throws MinionException
onMessage
in interface MinionMessageReceiver
MinionException
protected void sendInitializationMessage(MinionInitializationMessage message) throws MinionException
MinionException
protected void assertMessageSenderExists() throws MinionException
MinionException
protected void assertCamelContextInitialized() throws MinionException
MinionException
public void setBrokerUri(String brokerUri)
public void setListenQueueName(String queueName)
public void setStatusMessageWriter(StatusMessageWriter writer)
public void setMessageSender(MinionMessageSender sender)
public void setMessageReceiver(MinionMessageReceiver receiver)
public void setCamelContext(org.apache.camel.CamelContext context)
Copyright © 2015. All rights reserved.