View Source Datapio.MQ.Queue (Datapio OpenCore v0.1.0)

Distributed in-memory queue with multiple consumers.

Link to this section Summary

Types

Queue name

Functions

Return a specification to run the queue under a supervisor

Consume a message from the queue and stream it to the current process

Consume a message from the queue and stream it to the specified process

Publish a message to the queue

Shutdown the queue

Start a queue linked to the current process

Link to this section Types

Specs

queue_name() :: atom() | String.t()

Queue name

Link to this section Functions

Specs

child_spec(queue_name()) :: Supervisor.child_spec()

Return a specification to run the queue under a supervisor

Specs

drain(queue_name()) :: :ok

Consume a message from the queue and stream it to the current process

Specs

drain(queue_name(), pid()) :: :ok

Consume a message from the queue and stream it to the specified process

Link to this function

publish(queue_name, message)

View Source

Specs

publish(queue_name(), any()) :: :ok

Publish a message to the queue

Specs

shutdown(queue_name()) :: :ok

Shutdown the queue

Specs

start_link(queue_name()) :: GenServer.on_start()

Start a queue linked to the current process