com.eurotech.example.project
Class ExampleComponent

java.lang.Object
  extended by com.eurotech.example.project.ExampleComponent
All Implemented Interfaces:
CloudClientListener, org.osgi.service.event.EventHandler

public class ExampleComponent
extends Object
implements CloudClientListener, org.osgi.service.event.EventHandler


Constructor Summary
ExampleComponent()
           
 
Method Summary
protected  void activate(org.osgi.service.component.ComponentContext componentContext)
           
protected  void deactivate(org.osgi.service.component.ComponentContext componentContext)
           
 void doPublish()
           
 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 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 setClockService(ClockService clockService)
           
 void setCloudService(CloudService cloudService)
           
 void setConfigurationService(ConfigurationService configurationService)
           
 void setConnectionFactory(org.osgi.service.io.ConnectionFactory connectionFactory)
           
 void setNetworkService(NetworkService networkService)
           
 void setPositionService(PositionService positionService)
           
 void setUsbService(UsbService usbService)
           
 void unsetClockService(ClockService clockService)
           
 void unsetCloudService(CloudService cloudService)
           
 void unsetConfigurationService(ConfigurationService configurationService)
           
 void unsetConnectionFactory(org.osgi.service.io.ConnectionFactory connectionFactory)
           
 void unsetNetworkService(NetworkService networkService)
           
 void unsetPositionService(PositionService positionService)
           
 void unsetUsbService(UsbService usbService)
           
 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

ExampleComponent

public ExampleComponent()
Method Detail

setCloudService

public void setCloudService(CloudService cloudService)

unsetCloudService

public void unsetCloudService(CloudService cloudService)

setPositionService

public void setPositionService(PositionService positionService)

unsetPositionService

public void unsetPositionService(PositionService positionService)

setConnectionFactory

public void setConnectionFactory(org.osgi.service.io.ConnectionFactory connectionFactory)

unsetConnectionFactory

public void unsetConnectionFactory(org.osgi.service.io.ConnectionFactory connectionFactory)

setConfigurationService

public void setConfigurationService(ConfigurationService configurationService)

unsetConfigurationService

public void unsetConfigurationService(ConfigurationService configurationService)

setClockService

public void setClockService(ClockService clockService)

unsetClockService

public void unsetClockService(ClockService clockService)

setNetworkService

public void setNetworkService(NetworkService networkService)

unsetNetworkService

public void unsetNetworkService(NetworkService networkService)

setUsbService

public void setUsbService(UsbService usbService)

unsetUsbService

public void unsetUsbService(UsbService usbService)

activate

protected void activate(org.osgi.service.component.ComponentContext componentContext)

deactivate

protected void deactivate(org.osgi.service.component.ComponentContext componentContext)

updated

public void updated(Map<String,Object> properties)

doPublish

public void doPublish()

onControlMessageArrived

public void onControlMessageArrived(String deviceId,
                                    String appTopic,
                                    EsfPayload msg,
                                    int qos,
                                    boolean retain)
Description copied from interface: CloudClientListener
Called by the CloudClient when it receives a published control message from the broker. If the message received has a binary payload that it has NOT been encoded using the the EsfPayload class, the received bytes will be set as the body field of a new EsfPaylaod instance which is passed to the callback Listener interface.

Specified by:
onControlMessageArrived in interface CloudClientListener
Parameters:
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.

onMessageArrived

public void onMessageArrived(String deviceId,
                             String appTopic,
                             EsfPayload msg,
                             int qos,
                             boolean retain)
Description copied from interface: CloudClientListener
Called by the client when it receives a published data message from the broker. If the message received has a binary payload that it has NOT been encoded using the the EsfPayload class, the received bytes will be set as the body field of a new EsfPaylaod instance which is passed to the callback Listener interface.

Specified by:
onMessageArrived in interface CloudClientListener
Parameters:
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.

onConnectionLost

public void onConnectionLost()
Description copied from interface: CloudClientListener
Called when the client has lost its connection with the broker. Depending on the 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.
If the bundle using the client relies on subscriptions beyond the default ones, it is responsibility of the application to implement the CloudClientListener.onConnectionEstablished() callback method to restore the subscriptions it needs after a connection loss.

Specified by:
onConnectionLost in interface CloudClientListener

onConnectionEstablished

public void onConnectionEstablished()
Description copied from interface: CloudClientListener
Called when the CloudClient has successfully connected with the broker.
If the bundle using the client relies on subscriptions beyond the default ones, it is responsibility of the application to implement the CloudClientListener.onConnectionEstablished() callback method to restore the subscriptions it needs after a connection loss.

Specified by:
onConnectionEstablished in interface CloudClientListener

onMessagePublished

public void onMessagePublished(int messageId,
                               String appTopic)
Description copied from interface: CloudClientListener
Called by the CloudClient when a message has been transfered from the publishing queue to the underlying DataTransportService for publishing on the wire.

Specified by:
onMessagePublished in interface CloudClientListener

onMessageConfirmed

public void onMessageConfirmed(int messageId,
                               String appTopic)
Description copied from interface: CloudClientListener
Called by the CloudClient when a published message has been fully acknowledged by the broker, as appropriate for the quality of service. The published method is not called for QoS 0 publications.

Specified by:
onMessageConfirmed in interface CloudClientListener
Parameters:
messageId - The message id of the published message

handleEvent

public void handleEvent(org.osgi.service.event.Event event)
Specified by:
handleEvent in interface org.osgi.service.event.EventHandler


Copyright © 2013. All Rights Reserved.