Returns a specification to start this module under a supervisor.

See Supervisor.

Allow setting SSL client connection options

Attempts to connect to queue. It can succeed and enter status: :connected Or it can fail and enter status: :reconnecting

Reconnecting procedure - shutdown processing and schedule connection attempt after_seconds

Connect, (todo: reconnect) functionality

Specs

publish(map(), String.t(), String.t(), AMQP.Channel | nil) ::
  :ok | {:error, term()}

Publish data to exchange with a routing key.

You can pass a channel to re-use it.

Error values: {:error, :reconnectiong | other} - can come from connection() call or opening a channel (though that should not result in an error) or publishing :error - any error with JSON.encode / other errors