|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.eurotech.demo.tbm.TbmDemo
public class TbmDemo
Constructor Summary | |
---|---|
TbmDemo()
|
Method Summary | |
---|---|
protected void |
activate(org.osgi.service.component.ComponentContext componentContext)
|
void |
configureDIOConnection()
|
protected void |
deactivate(org.osgi.service.component.ComponentContext componentContext)
|
Properties |
getSerialDIOProperties()
|
boolean |
isDIO_Changed()
|
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 |
setConnectionFactory(org.osgi.service.io.ConnectionFactory connectionFactory)
|
void |
setDIO_Changed(boolean dIO_Changed)
|
void |
unsetCloudService(CloudService cloudService)
|
void |
unsetConnectionFactory(org.osgi.service.io.ConnectionFactory connectionFactory)
|
void |
updated(Map<String,Object> properties)
|
void |
updateMetrics(int dio_lsb,
int dio_msb)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TbmDemo()
Method Detail |
---|
public Properties getSerialDIOProperties()
public void setCloudService(CloudService cloudService)
public void unsetCloudService(CloudService cloudService)
public void setConnectionFactory(org.osgi.service.io.ConnectionFactory connectionFactory)
public void unsetConnectionFactory(org.osgi.service.io.ConnectionFactory connectionFactory)
protected void activate(org.osgi.service.component.ComponentContext componentContext)
protected void deactivate(org.osgi.service.component.ComponentContext componentContext)
public void updated(Map<String,Object> properties)
public void updateMetrics(int dio_lsb, int dio_msb)
public void configureDIOConnection() throws Exception
Exception
public void onConnectionEstablished()
CloudClientListener
CloudClientListener.onConnectionEstablished()
callback method to restore the subscriptions it needs after a connection loss.
onConnectionEstablished
in interface CloudClientListener
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 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 onMessagePublished(int messageId, String appTopic)
CloudClientListener
DataTransportService
for publishing on the wire.
onMessagePublished
in interface CloudClientListener
public void onMessageConfirmed(int messageId, String appTopic)
CloudClientListener
onMessageConfirmed
in interface CloudClientListener
messageId
- The message id of the published messagepublic boolean isDIO_Changed()
public void setDIO_Changed(boolean dIO_Changed)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |