diff --git a/lib/ex_finance/currencies/currency_producer.ex b/lib/ex_finance/currencies/currency_producer.ex index e6d6ea5..a9dd0d3 100644 --- a/lib/ex_finance/currencies/currency_producer.ex +++ b/lib/ex_finance/currencies/currency_producer.ex @@ -51,7 +51,7 @@ defmodule ExFinance.Currencies.CurrencyProducer do end def handle_message(_processor, %Broadway.Message{} = message, _context) do - Logger.debug("Loading product from message=#{inspect(message)}") + Logger.debug("Loading currency from message=#{inspect(message)}") %Redis.Stream.Entry{} = entry = Redis.Client.parse_stream_entry(message.data)