Crate lmq

A message queue based on a linked list structure that allows consumption of any message in the queue and for messages to be processed and claimed atomically and independent of other consumers.

Modules

hasher

Structs

LinkMessageQueue

A message queue based upon a linked list so that consuming iterators can decide to process any message atomically and independent of other consumers, who might be looking at a different set of messages.

MessageConsumer

Linked-list message queue iterator.

MessageRef

Smart pointer referencing the Vec<u8> payload inside of a stored element, guarded by a mutex for a temporary view of the data.

NextMessage

Represents an element in the unclaimed messages linked list.