AmqpSidecar.Publisher (amqp_sidecar v0.1.0)

Publishes messages to an AMQP exchange with a given routing key.

Opens a connection per call (simple and safe for low-volume sidecar use) and returns :ok or {:error, reason} instead of raising.

Summary

Functions

publish(exchange, routing_key, message, headers \\ %{})

Callback implementation for AmqpSidecar.PublisherBehaviour.publish/4.

Functions

publish(exchange, routing_key, message, headers \\ %{})

Callback implementation for AmqpSidecar.PublisherBehaviour.publish/4.