Struct MemoryQueue 

pub struct MemoryQueue { /* private fields */ }

Deterministic in-memory adapter for tests and local development.

Visibility delays run on a logical clock advanced by MemoryQueue::advance so retry behaviour is testable without a runtime timer.

Implementations

impl MemoryQueue

pub fn advance(&self, elapsed: Duration)

Advances the logical clock so delayed deliveries become visible.

pub fn depth(&self, topic: &str) -> usize

Returns the deliveries waiting on a topic, visible or not.

pub fn in_flight(&self) -> usize

Returns the deliveries currently checked out and unsettled.

Trait Implementations

impl Clone for MemoryQueue

fn clone(&self) -> MemoryQueue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for MemoryQueue

fn default() -> MemoryQueue

Returns the “default value” for a type.

impl Queue for MemoryQueue

fn publish(&self, topic: &str, message: Message) -> QueueFuture<()>

Publishes one message to a topic.

fn receive(&self, topic: &str) -> QueueFuture<Option<Delivery>>

Takes the next visible delivery from a topic, if any.

fn ack(&self, receipt: &str) -> QueueFuture<()>

Settles a delivery so it is never redelivered.

fn nack(&self, receipt: &str, delay: Duration) -> QueueFuture<()>

Returns a delivery to its topic, invisible until delay has elapsed.