Adds a queue.
Adds a queue.
This method auto generates and assigns the key field of the queue record and returns true if it succeeded.
Creates a store uow which is used to perform persistent operations as unit of work.
Creates a store uow which is used to perform persistent operations as unit of work.
Exports the contents of the store to the provided stream.
Exports the contents of the store to the provided stream.
Removes a the delivery associated with the provided from any internal buffers/caches.
Removes a the delivery associated with the provided from any internal buffers/caches. The callback is executed once, the message is no longer buffered.
Ges the last queue key identifier stored.
Ges the last queue key identifier stored.
Gets a value of a previously stored map entry.
Gets a value of a previously stored map entry.
Gets a value of a previously stored map entry.
Gets a value of a previously stored map entry.
Loads the queue information for a given queue key.
Loads the queue information for a given queue key.
Imports a previous export from the input stream.
Imports a previous export from the input stream.
Loads all the queue entry records for the given queue id between the first and last provided queue sequences (inclusive).
Loads all the queue entry records for the given queue id between the first and last provided queue sequences (inclusive).
Groups all the entries in the specified queue into ranges containing up limit entries big and returns those ranges.
Groups all the entries in the specified queue into ranges containing up limit entries big and returns those ranges. Allows you to incrementally, load all the entries in a queue.
Gets a listing of all queue entry sequences previously added and reports them to the callback.
Gets a listing of all queue entry sequences previously added and reports them to the callback.
Loads a delivery with the associated id from persistent storage.
Loads a delivery with the associated id from persistent storage.
Removes all previously stored data.
Removes all previously stored data.
Removes a queue.
Removes a queue. Success is reported via the callback.
The Store is service which offers asynchronous persistence services to a Broker.