StepFlow v0.2.5

StepFlow.Amqp.CommonEmitter (StepFlow v0.2.5) View Source

A common emitter to send job orders to workers.

Link to this section Summary

Functions

publish(queue, message, options \\ [])

Publish a message.

publish_json(queue, priority, message)

Publish a message using JSON serialization before send it.

Link to this section Functions

Link to this function

publish(queue, message, options \\ [])

View Source

Publish a message.

Example:

StepFlow.Amqp.CommonEmitter.publish_json("my_rabbit_mq_queue", "{\"key\": \"value\"}")
Link to this function

publish_json(queue, priority, message)

View Source

Publish a message using JSON serialization before send it.

Example:

StepFlow.Amqp.CommonEmitter.publish_json("my_rabbit_mq_queue", 0, %{key: "value"})