| Added Methods |
Entry dequeueDeliverableEntry(String)
|
Dequeue message and payload to be delivered. |
List getEntriesRequiringAck(String)
|
Get entities for a device that require ack
|
void markAcknowledged(String, String)
|
Mark the entry containing the message as acknowledged
|
void markDeliveredOrRemove(String, String)
|
Mark the entry containing the message as delivered and, if not requiring acknowledgement or already acknowledged, remove it from the queue given by the path
|
void queue(String, String, boolean)
|
Queue message
|
void remove(String, String)
|
Remove the specified message from the queue defined by the path
|