EventBus v1.0.0 EventBus.Queue.Receiver View Source

Link to this section Summary

Functions

run()

run(queue_name, opts \\ [])

Query SQS for new messages

Link to this section Functions

Link to this function

run() View Source

Link to this function

run(queue_name, opts \\ []) View Source

run(binary(), Keyword.t()) ::
  {:ok, [EventBus.SQSMessage.t()]} | {:error, any()}

Query SQS for new messages