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 streams.
Exports the contents of the store to the provided streams. Each stream should contain a list of framed protobuf objects with the corresponding object types.
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.
Loads the queue information for a given queue key.
Loads the queue information for a given queue key.
Imports a previously exported set of streams.
Imports a previously exported set of streams. This deletes any previous data in the store.
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.