View Source OffBroadwayAmqp10.Amqp10.Client behaviour (off_broadway_amqp10 v0.1.2)

AMQP 1.0 Client wrapper behaviour

Link to this section Summary

Link to this section Types

@type annotations_key() :: binary() | non_neg_integer()
@type annotations_keys() :: %{required(annotations_key()) => any()}

Link to this section Callbacks

Link to this callback

accept_msg(t, raw_message)

View Source
@callback accept_msg(
  OffBroadwayAmqp10.Amqp10.State.t(),
  OffBroadwayAmqp10.Amqp10.State.raw_message()
) ::
  :ok
Link to this callback

annotations(raw_message)

View Source
@callback annotations(OffBroadwayAmqp10.Amqp10.State.raw_message()) :: annotations_keys()
Link to this callback

application_properties(raw_message)

View Source
@callback application_properties(OffBroadwayAmqp10.Amqp10.State.raw_message()) ::
  :amqp10_msg.amqp10_properties()
@callback attach(OffBroadwayAmqp10.Amqp10.State.t()) ::
  {:ok, OffBroadwayAmqp10.Amqp10.State.receiver()}
@callback begin_session(OffBroadwayAmqp10.Amqp10.State.t()) :: Supervisor.on_start_child()
@callback body(OffBroadwayAmqp10.Amqp10.State.raw_message()) :: binary()
@callback headers(OffBroadwayAmqp10.Amqp10.State.raw_message()) ::
  :amqp10_msg.amqp10_header()
@callback open_connection(OffBroadwayAmqp10.Amqp10.State.t()) ::
  Supervisor.on_start_child()
@callback properties(OffBroadwayAmqp10.Amqp10.State.raw_message()) ::
  :amqp10_msg.amqp10_properties()