org.opennms.minion.controller.internal

Class MinionControllerImpl

java.lang.Object

org.opennms.minion.controller.internal.MinionControllerImpl

All Implemented Interfaces:

MinionController, MinionMessageReceiver

public class MinionControllerImpl
extends Object
implements MinionController, MinionMessageReceiver

Field Summary

Fields inherited from interface org.opennms.minion.api.MinionController

PID

Constructor Summary

Constructors

Constructor and Description
MinionControllerImpl()

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MinionControllerImpl

public MinionControllerImpl()

Method Detail

start

public void start()
           throws MinionException

Specified by:

start in interface MinionController

Throws:

MinionException

stop

public void stop()
          throws MinionException

Specified by:

stop in interface MinionController

Throws:

MinionException

sendStartMessage

public void sendStartMessage()
                      throws MinionException

Specified by:

sendStartMessage in interface MinionController

Throws:

MinionException

sendStopMessage

public void sendStopMessage()
                     throws MinionException

Specified by:

sendStopMessage in interface MinionController

Throws:

MinionException

assertMessageSenderExists

protected void assertMessageSenderExists()
                                  throws MinionException

Throws:

MinionException

getId

public String getId()
             throws MinionException

Specified by:

getId in interface MinionController

Throws:

MinionException

getLocation

public String getLocation()
                   throws MinionException

Specified by:

getLocation in interface MinionController

Throws:

MinionException

onMessage

public void onMessage(MinionMessage message)
               throws MinionException

Specified by:

onMessage in interface MinionMessageReceiver

Throws:

MinionException

assertMessageReceiverExists

protected void assertMessageReceiverExists()

assertCamelContextInitialized

protected void assertCamelContextInitialized()
                                      throws MinionException

Throws:

MinionException

createStatusMessage

public MinionStatusMessage createStatusMessage(String withStatus)
                                        throws MinionException

Throws:

MinionException

loadProperty

protected String loadProperty(String propName)
                       throws MinionException

Throws:

MinionException

saveProperty

protected void saveProperty(String key,
                            String value)
                     throws MinionException

Throws:

MinionException

getConfiguration

protected org.osgi.service.cm.Configuration getConfiguration()
                                                      throws MinionException

Throws:

MinionException

setAdminService

public void setAdminService(org.apache.karaf.admin.AdminService adminService)

setConfigurationAdmin

public void setConfigurationAdmin(org.osgi.service.cm.ConfigurationAdmin configurationAdmin)

setMessageSender

public void setMessageSender(MinionMessageSender sender)

setMessageReceiver

public void setMessageReceiver(MinionMessageReceiver receiver)

setCamelContext

public void setCamelContext(org.apache.camel.CamelContext context)

setBrokerUri

public void setBrokerUri(String brokerUri)

setSendQueueName

public void setSendQueueName(String queue)