Kombu.Transport.Memory.Store (Kombu v0.1.0)

Shared state store for the in-memory transport, holding the %BrokerState{} and in-memory :queue queues.

Summary

Functions

broker_state(store \\ __MODULE__)

child_spec(arg)

Returns a specification to start this module under a supervisor.

delete(store \\ __MODULE__, queue)

get(store \\ __MODULE__, queue)

has_queue?(store \\ __MODULE__, queue)

new_queue(store \\ __MODULE__, queue)

purge(store \\ __MODULE__, queue)

put(store \\ __MODULE__, queue, message)

put_front(store \\ __MODULE__, queue, message)

reset(store \\ __MODULE__)

size(store \\ __MODULE__, queue)

start_link(opts \\ [])

update_broker_state(store \\ __MODULE__, fun)

Functions

broker_state(store \\ MODULE)

child_spec(arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

delete(store \\ MODULE, queue)

get(store \\ MODULE, queue)

has_queue?(store \\ MODULE, queue)

new_queue(store \\ MODULE, queue)

purge(store \\ MODULE, queue)

put(store \\ MODULE, queue, message)

put_front(store \\ MODULE, queue, message)

reset(store \\ MODULE)

size(store \\ MODULE, queue)

start_link(opts \\ [])

update_broker_state(store \\ MODULE, fun)