Datapio OpenCore v0.1.0

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

Message Queue application interface.

Link to this section Summary

Types

consumer_options()
queue_name()

Functions

start_consumer(options)

Start a consumer

start_queue(queue_name)

Start a new queue

Link to this section Types

Link to this type

consumer_options()

View Source

Specs

consumer_options() :: Datapio.MQ.Consumer.consumer_options()
Link to this type

queue_name()

View Source

Specs

queue_name() :: Datapio.MQ.Queue.queue_name()

Link to this section Functions

Link to this function

start_consumer(options)

View Source

Specs

start_consumer(consumer_options()) :: DynamicSupervisor.on_start_child()

Start a consumer

Link to this function

start_queue(queue_name)

View Source

Specs

start_queue(queue_name()) :: DynamicSupervisor.on_start_child()

Start a new queue