HareMq.Consumer.Behaviour behaviour (hare_mq v1.5.0)

Copy Markdown

Summary

Callbacks

consume(arg1)
consume(list, atom)

Callbacks

consume(arg1)

@callback consume(map() | binary()) :: :ok | {:ok, any()} | :error | {:error, any()}

consume(list, atom)

@callback consume([map() | binary()], :batch) ::
  :ok | {:ok, any()} | :error | {:error, any()}