Improve guides to include publishing messages

[dashbitco]

Improve guides to include publishing messages

[noozo]

Would awesome. Had to kill some brain cells trying to dig out how to simply do this (which in reality in not directly related to Broadway :)):

def broadcast(queue_name, event_type, message_struct) do
    struct = %{event_type: event_type, body: message_struct}

    IO.puts("Broadcasting '#{event_type}' to queue '#{queue_name}'.")

    # TODO: Eventually store the broadcasted message in the database as
    # an history/log entry (or send to datadog)

    ExAws.SQS.send_message(
      queue_name,
      Poison.encode!(struct)
    )
    |> ExAws.request(%{
      secret_access_key: System.get_env("AWS_SECRET_ACCESS_KEY"),
      access_key_id: System.get_env("AWS_ACCESS_KEY_ID"),
      region: System.get_env("AWS_REGION"),
      host: "sqs.eu-west-1.amazonaws.com",
      scheme: "https"
    })
  end

Would be great to be able to post a message to a queue reusing the credentials i already define for Broadway. If there is, please let me know how :)

And while i'm here, is there a way to fake the producer for testing purposes? Would love to test my worker without having to have AWS queues setup or having to install RabbitMQ :(

[josevalim]

You can share credentials by simply moving the code to a function and calling that function from both! For a faker, you can use Mox or similar.

[msaraiva]

You'll also be able to use a DummyProducer in your tests after #91 is merged.

[noozo]

Cool, thank you guys!

[noozo]

I was trying to create a fake producer as well, but couldn't figure out the @behaviour thing. Total noob in Elixir here. Thanks again! :)