Package | Description |
---|---|
com.eurotech.framework |
Contains objects necessary to manage framework exceptions.
|
com.eurotech.framework.cloud |
Provides services for managing communications between M2M applications and remote servers.
|
com.eurotech.framework.data |
Provides services for connecting and communicating with a MQTT broker.
|
Modifier and Type | Class and Description |
---|---|
class |
EsfStoreCapacityReachedException
EsfStoreCapacityReachedException is raised when a message can not be appended
to the publishing queue as the internal database buffer has reached its
capacity for messages that are not yet published or they are still in transit.
|
Modifier and Type | Method and Description |
---|---|
EsfResponsePayload |
CloudCallService.call(String appId,
String appTopic,
EsfPayload appPayload,
int timeout)
Sends a local (to this device) request to a Cloudlet application
with the given application ID waiting for the response.
|
EsfResponsePayload |
CloudCallService.call(String deviceId,
String appId,
String appTopic,
EsfPayload appPayload,
int timeout)
Sends a request to a remote server or device identified by the specified deviceId
and targeting the given application ID waiting for the response.
|
Modifier and Type | Method and Description |
---|---|
List<Integer> |
DataService.getDroppedInFlightMessageIds(String topicRegex)
Finds the list of identifiers of in-flight messages that have been dropped.
|
List<Integer> |
DataService.getInFlightMessageIds(String topicRegex)
Finds the list of identifiers of messages that are still in-flight
(messages published but not confirmed yet).
|
List<Integer> |
DataService.getUnpublishedMessageIds(String topicRegex)
Finds the list of identifiers of messages that have not been published yet.
|
int |
DataService.publish(String topic,
byte[] payload,
int qos,
boolean retain,
int priority)
Publishes a message to the broker.
|
Copyright © 2013. All Rights Reserved.