|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use DataMessage | |
---|---|
com.eurotech.framework.core.data | |
com.eurotech.framework.core.data.store |
Uses of DataMessage in com.eurotech.framework.core.data |
---|
Methods in com.eurotech.framework.core.data that return DataMessage | |
---|---|
DataMessage |
DataMessage.Builder.build()
|
DataMessage |
DataStore.get(int msgId)
Returns a message from the DataStore by its message id. |
DataMessage |
DataStore.getNextMessage()
Gets the next unpublished message. |
DataMessage |
DataStore.store(String topic,
byte[] payload,
int qos,
boolean retain,
int priority)
Stores an MQTT message for deferred publication. |
Methods in com.eurotech.framework.core.data that return types with arguments of type DataMessage | |
---|---|
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. |
Uses of DataMessage in com.eurotech.framework.core.data.store |
---|
Methods in com.eurotech.framework.core.data.store that return DataMessage | |
---|---|
DataMessage |
DbDataStore.get(int msgId)
|
DataMessage |
DbDataStore.getNextMessage()
|
DataMessage |
DbDataStore.store(String topic,
byte[] payload,
int qos,
boolean retain,
int priority)
|
Methods in com.eurotech.framework.core.data.store that return types with arguments of type DataMessage | |
---|---|
List<DataMessage> |
DbDataStore.allDroppedInFlightMessagesNoPayload()
|
List<DataMessage> |
DbDataStore.allInFlightMessagesNoPayload()
|
List<DataMessage> |
DbDataStore.allUnpublishedMessagesNoPayload()
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |