handle_message_1.ex

def handle_message(_, %Message{data: %{event: {:ok, taxidata}}} = message, _) do
    IO.puts("#{inspect(self())} Handling first step: #{inspect(taxidata)}")
    message = Broadway.Message.update_data(message, fn _data -> taxidata end)
    case taxidata["ride_status"] do
      "enroute" ->
        message
        |> Broadway.Message.put_batcher(:enroute)
      "pickup" ->
        message
        |> Broadway.Message.put_batcher(:pickup)
      "dropoff" ->
        message
        |> Broadway.Message.put_batcher(:dropoff)
      _ ->
        message
        |> Broadway.Message.failed("invalid-data")
    end
  end