View Source StepFlow.Amqp.CommonEmitter (StepFlow v1.8.0)
A common emitter to send job orders to workers.
Summary
Functions
Publish a message.
Example:
StepFlow.Amqp.CommonEmitter.publish_json("my_rabbit_mq_queue", "{\"key\": \"value\"}")
Link to this function
publish_json(queue, priority, message, exchange \\ "job_submit", options \\ [])
View SourcePublish a message using JSON serialization before send it.
Example:
StepFlow.Amqp.CommonEmitter.publish_json("my_rabbit_mq_queue", 0, %{key: "value"})