Uses of Class
com.eurotech.framework.EsfStoreException

Packages that use EsfStoreException

com.eurotech.framework
com.eurotech.framework.cloud
com.eurotech.framework.core.cloud.call
com.eurotech.framework.core.data
com.eurotech.framework.core.data.store
com.eurotech.framework.data

Uses of EsfStoreException in com.eurotech.framework

Subclasses of EsfStoreException in com.eurotech.framework

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.

Uses of EsfStoreException in com.eurotech.framework.cloud

Methods in com.eurotech.framework.cloud that throw EsfStoreException

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.

Uses of EsfStoreException in com.eurotech.framework.core.cloud.call

Methods in com.eurotech.framework.core.cloud.call that throw EsfStoreException

EsfResponsePayload	CloudCallServiceImpl.call(String appId, String appTopic, EsfPayload appPayload, int timeout)
EsfResponsePayload	CloudCallServiceImpl.call(String deviceId, String appId, String appTopic, EsfPayload appPayload, int timeout)

Uses of EsfStoreException in com.eurotech.framework.core.data

Methods in com.eurotech.framework.core.data that throw EsfStoreException

List<DataMessage>	DataStore.allDroppedInFlightMessagesNoPayload() Finds the list of all published messages that will not be confirmed and returns them WITHOUT loading the payload.
List<DataMessage>	DataStore.allInFlightMessagesNoPayload() Finds the list of all published but not yet confirmed messages and returns them WITHOUT loading the payload.
List<DataMessage>	DataStore.allUnpublishedMessagesNoPayload() Finds the list of all unpublished messages and returns them WITHOUT loading the payload.
void	DataStore.checkpoint() Performs a checkpoint of the store.
void	DataStore.confirmed(int msgId) Acknowledges the delivery of the DataMessage published with the given protocol (e.g.
void	DataStore.defrag() Defragments the store.
void	DataStore.deleteStaleMessages(int purgeAge) Deletes stale messages.
void	DataStore.dropAllInFlightMessages() Drops all in-flight messages.
DataMessage	DataStore.get(int msgId) Returns a message from the DataStore by its message id.
List<Integer>	DataServiceImpl.getDroppedInFlightMessageIds(String topicRegex)
List<Integer>	DataServiceImpl.getInFlightMessageIds(String topicRegex)
DataMessage	DataStore.getNextMessage() Gets the next unpublished message.
List<Integer>	DataServiceImpl.getUnpublishedMessageIds(String topicRegex)
int	DataServiceImpl.publish(String topic, byte[] payload, int qos, boolean retain, int priority)
void	DataStore.published(int msgId) Acknowledges the publication of the DataMessage with the given ID.
void	DataStore.published(int msgId, int publishedMsgId, String sessionId) Acknowledges the publication of the DataMessage with the given ID associating it to the protocol (e.g.
void	DataStore.start(DbService dbService, int houseKeeperInterval, int purgeAge, int capacity)
DataMessage	DataStore.store(String topic, byte[] payload, int qos, boolean retain, int priority) Stores an MQTT message for deferred publication.
void	DataStore.unpublishAllInFlighMessages() Marks all in-flight messages as unpublished.

Uses of EsfStoreException in com.eurotech.framework.core.data.store

Methods in com.eurotech.framework.core.data.store that throw EsfStoreException

List<DataMessage>	DbDataStore.allDroppedInFlightMessagesNoPayload()
List<DataMessage>	DbDataStore.allInFlightMessagesNoPayload()
List<DataMessage>	DbDataStore.allUnpublishedMessagesNoPayload()
void	DbDataStore.checkpoint()
void	DbDataStore.confirmed(int msgId)
void	DbDataStore.defrag()
void	DbDataStore.deleteStaleMessages(int purgeAge)
void	DbDataStore.dropAllInFlightMessages()
DataMessage	DbDataStore.get(int msgId)
DataMessage	DbDataStore.getNextMessage()
void	DbDataStore.published(int msgId)
void	DbDataStore.published(int msgId, int publishedMsgId, String sessionId)
void	DbDataStore.start(DbService dbService, int houseKeeperInterval, int purgeAge, int capacity)
DataMessage	DbDataStore.store(String topic, byte[] payload, int qos, boolean retain, int priority)
void	DbDataStore.unpublishAllInFlighMessages()

Uses of EsfStoreException in com.eurotech.framework.data

Methods in com.eurotech.framework.data that throw EsfStoreException

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.