public class MinionControllerImpl extends Object implements MinionController, MinionMessageReceiver
PID
Constructor and Description |
---|
MinionControllerImpl() |
Modifier and Type | Method and Description |
---|---|
protected void |
assertCamelContextInitialized() |
protected void |
assertMessageReceiverExists() |
protected void |
assertMessageSenderExists() |
MinionStatusMessage |
createStatusMessage(String withStatus) |
protected org.osgi.service.cm.Configuration |
getConfiguration() |
String |
getId() |
String |
getLocation() |
protected String |
loadProperty(String propName) |
void |
onMessage(MinionMessage message) |
protected void |
saveProperty(String key,
String value) |
void |
sendStartMessage() |
void |
sendStopMessage() |
void |
setAdminService(org.apache.karaf.admin.AdminService adminService) |
void |
setBrokerUri(String brokerUri) |
void |
setCamelContext(org.apache.camel.CamelContext context) |
void |
setConfigurationAdmin(org.osgi.service.cm.ConfigurationAdmin configurationAdmin) |
void |
setMessageReceiver(MinionMessageReceiver receiver) |
void |
setMessageSender(MinionMessageSender sender) |
void |
setSendQueueName(String queue) |
void |
start() |
void |
stop() |
public void start() throws MinionException
start
in interface MinionController
MinionException
public void stop() throws MinionException
stop
in interface MinionController
MinionException
public void sendStartMessage() throws MinionException
sendStartMessage
in interface MinionController
MinionException
public void sendStopMessage() throws MinionException
sendStopMessage
in interface MinionController
MinionException
protected void assertMessageSenderExists() throws MinionException
MinionException
public String getId() throws MinionException
getId
in interface MinionController
MinionException
public String getLocation() throws MinionException
getLocation
in interface MinionController
MinionException
public void onMessage(MinionMessage message) throws MinionException
onMessage
in interface MinionMessageReceiver
MinionException
protected void assertMessageReceiverExists()
protected void assertCamelContextInitialized() throws MinionException
MinionException
public MinionStatusMessage createStatusMessage(String withStatus) throws MinionException
MinionException
protected String loadProperty(String propName) throws MinionException
MinionException
protected void saveProperty(String key, String value) throws MinionException
MinionException
protected org.osgi.service.cm.Configuration getConfiguration() throws MinionException
MinionException
public void setAdminService(org.apache.karaf.admin.AdminService adminService)
public void setConfigurationAdmin(org.osgi.service.cm.ConfigurationAdmin configurationAdmin)
public void setMessageSender(MinionMessageSender sender)
public void setMessageReceiver(MinionMessageReceiver receiver)
public void setCamelContext(org.apache.camel.CamelContext context)
public void setBrokerUri(String brokerUri)
public void setSendQueueName(String queue)
Copyright © 2015. All rights reserved.