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
MinionExceptionpublic void stop()
throws MinionException
MinionExceptionpublic void onMessage(MinionMessage message) throws MinionException
onMessage in interface MinionMessageReceiverMinionExceptionprotected void sendInitializationMessage(MinionInitializationMessage message) throws MinionException
MinionExceptionprotected void assertMessageSenderExists()
throws MinionException
MinionExceptionprotected void assertCamelContextInitialized()
throws MinionException
MinionExceptionpublic 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 © 2016. All rights reserved.