amqp_director v1.5.1 AmqpDirector.Definitions View Source

Link to this section Summary

Link to this section Types

Link to this type amqp_array() View Source
amqp_array() :: [{amqp_field_type(), amqp_value()}]
Link to this type amqp_field_type() View Source
amqp_field_type() ::
  :longstr
  | :signedint
  | :decimal
  | :timestamp
  | :unsignedbyte
  | :unsignedshort
  | :unsignedint
  | :table
  | :byte
  | :double
  | :float
  | :long
  | :short
  | :bool
  | :binary
  | :void
  | :array
Link to this type amqp_msg() View Source
amqp_msg() :: {:amqp_msg, props :: p_basic(), payload :: String.t()}
Link to this type amqp_table() View Source
amqp_table() :: [{binary(), amqp_field_type(), amqp_value()}]
Link to this type amqp_value() View Source
amqp_value() ::
  binary()
  | integer()
  | {non_neg_integer(), non_neg_integer()}
  | amqp_table()
  | amqp_array()
  | byte()
  | float()
  | integer()
  | boolean()
  | binary()
  | :undefined
  | non_neg_integer()
Link to this type basic_deliver() View Source
basic_deliver() ::
  {:"basic.deliver", consumer_tag :: String.t(), delivery_tag :: String.t(),
   redelivered :: bool(), exchange :: String.t(), routing_key :: String.t()}
Link to this type p_basic() View Source
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()}

Link to this section Functions

Link to this macro amqp_msg(args \\ []) View Source (macro)
Link to this macro amqp_msg(record, args) View Source (macro)
Link to this macro basic_deliver(args \\ []) View Source (macro)
Link to this macro basic_deliver(record, args) View Source (macro)
Link to this macro p_basic(args \\ []) View Source (macro)
Link to this macro p_basic(record, args) View Source (macro)