|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.eurotech.framework.core.deployment.CloudDeploymentHandler
public class CloudDeploymentHandler
Field Summary | |
---|---|
static String |
APP_ID
|
static String |
METRIC_INSTALL_COMMAND_FILENAME
|
static String |
METRIC_INSTALL_COMMAND_URL
|
static String |
METRIC_INSTALL_REPLY_PKG_NAME
|
static String |
METRIC_INSTALL_REPLY_PKG_VERSION
|
static String |
RESOURCE_BUNDLES
|
static String |
RESOURCE_INSTALL
|
static String |
RESOURCE_PACKAGES
|
static String |
RESOURCE_START
|
static String |
RESOURCE_STOP
|
static String |
RESOURCE_UNINSTALL
|
Constructor Summary | |
---|---|
CloudDeploymentHandler()
|
Method Summary | |
---|---|
protected void |
activate(org.osgi.service.component.ComponentContext componentContext)
|
protected void |
deactivate(org.osgi.service.component.ComponentContext componentContext)
|
void |
handleEvent(org.osgi.service.event.Event event)
|
void |
onConnectionEstablished()
Called when the CloudClient has successfully connected with the broker. |
void |
onConnectionLost()
Called when the client has lost its connection with the broker. |
void |
onControlMessageArrived(String deviceId,
String appTopic,
EsfPayload msg,
int qos,
boolean retain)
Called by the CloudClient when it receives a published control message from the broker. |
void |
onMessageArrived(String deviceId,
String appTopic,
EsfPayload msg,
int qos,
boolean retain)
Called by the client when it receives a published data message from the broker. |
void |
onMessageConfirmed(int messageId,
String topic)
Called by the CloudClient when a published message has been fully acknowledged by the broker, as appropriate for the quality of service. |
void |
onMessagePublished(int messageId,
String topic)
Called by the CloudClient when a message has been transfered from the publishing queue to the underlying DataTransportService for publishing on the wire. |
protected void |
setCloudService(CloudService cloudService)
|
protected void |
setDeploymentAdmin(org.osgi.service.deploymentadmin.DeploymentAdmin deploymentAdmin)
|
protected void |
setDeploymentAgentService(DeploymentAgentService deploymentAgentService)
|
void |
setSystemService(SystemService systemService)
|
protected void |
unsetCloudService(CloudService cloudService)
|
protected void |
unsetDeploymentAdmin(org.osgi.service.deploymentadmin.DeploymentAdmin deploymentAdmin)
|
protected void |
unsetDeploymentAgentService(DeploymentAgentService deploymentAgentService)
|
void |
unsetSystemService(SystemService systemService)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String APP_ID
public static final String RESOURCE_PACKAGES
public static final String RESOURCE_BUNDLES
public static final String RESOURCE_INSTALL
public static final String RESOURCE_UNINSTALL
public static final String RESOURCE_START
public static final String RESOURCE_STOP
public static final String METRIC_INSTALL_COMMAND_URL
public static final String METRIC_INSTALL_COMMAND_FILENAME
public static final String METRIC_INSTALL_REPLY_PKG_NAME
public static final String METRIC_INSTALL_REPLY_PKG_VERSION
Constructor Detail |
---|
public CloudDeploymentHandler()
Method Detail |
---|
protected void setCloudService(CloudService cloudService)
protected void unsetCloudService(CloudService cloudService)
protected void setDeploymentAdmin(org.osgi.service.deploymentadmin.DeploymentAdmin deploymentAdmin)
protected void unsetDeploymentAdmin(org.osgi.service.deploymentadmin.DeploymentAdmin deploymentAdmin)
protected void setDeploymentAgentService(DeploymentAgentService deploymentAgentService)
protected void unsetDeploymentAgentService(DeploymentAgentService deploymentAgentService)
public void setSystemService(SystemService systemService)
public void unsetSystemService(SystemService systemService)
protected void activate(org.osgi.service.component.ComponentContext componentContext)
protected void deactivate(org.osgi.service.component.ComponentContext componentContext)
public void handleEvent(org.osgi.service.event.Event event)
handleEvent
in interface org.osgi.service.event.EventHandler
public void onControlMessageArrived(String deviceId, String appTopic, EsfPayload msg, int qos, boolean retain)
CloudClientListener
onControlMessageArrived
in interface CloudClientListener
deviceId
- The deviceId this message was addressed to.appTopic
- The appTopic the message arrived on.msg
- The EsfPayload that arrived.qos
- The Quality of Service that the message was received on.retain
- Whether the message was retained by the broker.public void onMessageArrived(String deviceId, String appTopic, EsfPayload msg, int qos, boolean retain)
CloudClientListener
onMessageArrived
in interface CloudClientListener
deviceId
- The asset ID of the semanticTopic prefix the message arrived on.appTopic
- The appTopic the message arrived on.msg
- The EsfPayload that arrived.qos
- The Quality of Service that the message was received on.retain
- Whether the message was retained by the broker.public void onConnectionLost()
CloudClientListener
DataService
configuration, the client will attempt to reconnect and call the CloudClientListener.onConnectionEstablished()
method upon a successful reconnect. This is only a notification, the callback handler should
not attempt to handle the reconnect.
CloudClientListener.onConnectionEstablished()
callback method to restore the subscriptions it needs after a connection loss.
onConnectionLost
in interface CloudClientListener
public void onConnectionEstablished()
CloudClientListener
CloudClientListener.onConnectionEstablished()
callback method to restore the subscriptions it needs after a connection loss.
onConnectionEstablished
in interface CloudClientListener
public void onMessagePublished(int messageId, String topic)
CloudClientListener
DataTransportService
for publishing on the wire.
onMessagePublished
in interface CloudClientListener
public void onMessageConfirmed(int messageId, String topic)
CloudClientListener
onMessageConfirmed
in interface CloudClientListener
messageId
- The message id of the published message
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |