astarte_flow
astarte_flow v0.1.0

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

Link to this section Summary

Functions

generate_config(opts)

Initialize the AMQP client config

setup(config, type)

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(config, type)

@spec setup(config :: map(), type :: :producer | :consumer | :producer_consumer) ::
  {:ok, map()} | {:error, reason :: term()}

Initialize the AMQP channel