@callback accept_msg(
  OffBroadwayAmqp10.Amqp10.State.t(),
  OffBroadwayAmqp10.Amqp10.State.raw_message()
) ::
  :ok

@callback annotations(OffBroadwayAmqp10.Amqp10.State.raw_message()) :: annotations_keys()

@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 flow_link_credit(OffBroadwayAmqp10.Amqp10.State.t(), non_neg_integer()) :: :ok

@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()