amqp_array() :: [{amqp_field_type(), amqp_value()}]

amqp_field_type() ::
  :longstr
  | :signedint
  | :decimal
  | :timestamp
  | :unsignedbyte
  | :unsignedshort
  | :unsignedint
  | :table
  | :byte
  | :double
  | :float
  | :long
  | :short
  | :bool
  | :binary
  | :void
  | :array

amqp_msg() :: {:amqp_msg, props :: p_basic(), payload :: String.t()}

amqp_table() :: [{binary(), amqp_field_type(), amqp_value()}]

amqp_value() ::
  binary()
  | integer()
  | {non_neg_integer(), non_neg_integer()}
  | amqp_table()
  | amqp_array()
  | byte()
  | float()
  | integer()
  | boolean()
  | binary()
  | :undefined
  | non_neg_integer()

basic_deliver() ::
  {:"basic.deliver", consumer_tag :: String.t(), delivery_tag :: String.t(),
   redelivered :: bool(), exchange :: String.t(), routing_key :: String.t()}

p_basic() ::
  {:P_basic, content_type :: String.t(), content_encoding :: String.t(),
   headers :: amqp_table(), delivery_mode :: any(), priority :: any(),
   correlation_id :: String.t(), reply_to :: String.t(), expiration :: any(),
   message_id :: any(), timestamp :: any(), type :: any(), user_id :: any(),
   app_id :: any(), cluster_id :: any()}