RocksQ Library
- rocksq.remove_mpmc_queue(path)
Removes
MpmcQueue
at the given path. The queue must be closed.- Parameters:
path (str) – The path to the queue to remove.
- Raises:
PyRuntimeError – If the queue could not be removed.
- rocksq.remove_queue(path)
Removes
PersistentQueueWithCapacity
at the given path. The queue must be closed.- Parameters:
path (str) – The path to the queue to remove.
- Raises:
PyRuntimeError – If the queue could not be removed.
- rocksq.version()
Returns the version of the underlying queue_rs library.
- Returns:
version – The version of the underlying queue_rs library.
- Return type:
str