astarte_flow
astarte_flow v0.1.0

Astarte.Flow.Blocks.DeviceEventsProducer.RabbitMQClient (astarte_flow v0.1.0)

Link to this section Summary

Functions

generate_config(opts)

Initialize the AMQP client config

setup_channel(config)

Initialize the AMQP channel

Link to this section Functions

Link to this function

generate_config(opts)

@spec generate_config(opts :: keyword()) ::
  {:ok, config :: map()} | {:error, reason :: term()}

Initialize the AMQP client config

Link to this function

setup_channel(config)

@spec setup_channel(config :: map()) ::
  {:ok, chan :: AMQP.Channel.t()} | {:error, reason :: term()}

Initialize the AMQP channel