|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.eurotech.demo.heater.Heater
public class Heater
Constructor Summary | |
---|---|
Heater()
|
Method Summary | |
---|---|
protected void |
activate(org.osgi.service.component.ComponentContext componentContext,
Map<String,Object> properties)
|
protected void |
deactivate(org.osgi.service.component.ComponentContext componentContext)
|
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 appTopic)
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 appTopic)
Called by the CloudClient when a message has been transfered from the publishing queue to the underlying DataTransportService for publishing on the wire. |
void |
setCloudService(CloudService cloudService)
|
void |
unsetCloudService(CloudService cloudService)
|
void |
updated(Map<String,Object> properties)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public Heater()
Method Detail |
---|
public void setCloudService(CloudService cloudService)
public void unsetCloudService(CloudService cloudService)
protected void activate(org.osgi.service.component.ComponentContext componentContext, Map<String,Object> properties)
protected void deactivate(org.osgi.service.component.ComponentContext componentContext)
public void updated(Map<String,Object> properties)
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 onMessageConfirmed(int messageId, String appTopic)
CloudClientListener
onMessageConfirmed
in interface CloudClientListener
messageId
- The message id of the published messagepublic void onMessagePublished(int messageId, String appTopic)
CloudClientListener
DataTransportService
for publishing on the wire.
onMessagePublished
in interface CloudClientListener
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |