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
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
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