diff --git a/apps/scrapper/lib/scrapper/processor/match_processor.ex b/apps/scrapper/lib/scrapper/processor/match_processor.ex index a27c04f..ff5b6f6 100644 --- a/apps/scrapper/lib/scrapper/processor/match_processor.ex +++ b/apps/scrapper/lib/scrapper/processor/match_processor.ex @@ -14,13 +14,13 @@ defmodule Scrapper.Processor.MatchProcessor do password: "guest", host: "localhost" ], - on_failure: :reject, + on_failure: :reject_and_requeue, qos: [ prefetch_count: 1 ]}, concurrency: 1, rate_limiting: [ - interval: 1000 * 3, + interval: 1000 * 1, allowed_messages: 1 ] ], diff --git a/apps/scrapper/lib/scrapper/processor/player_processor.ex b/apps/scrapper/lib/scrapper/processor/player_processor.ex index d778c7d..6f65ae9 100644 --- a/apps/scrapper/lib/scrapper/processor/player_processor.ex +++ b/apps/scrapper/lib/scrapper/processor/player_processor.ex @@ -15,7 +15,7 @@ defmodule Scrapper.Processor.PlayerProcessor do password: "guest", host: "localhost" ], - on_failure: :reject, + on_failure: :reject_and_requeue, qos: [ prefetch_count: 1 ]}, @@ -46,7 +46,7 @@ defmodule Scrapper.Processor.PlayerProcessor do player -> player |> LolAnalytics.Player.PlayerRepo.update_player(%{ - :last_processed_at => DateTime.utc_now() |> DateTime.truncate(:seconds) + :last_processed_at => DateTime.utc_now() |> DateTime.truncate(:second) }) end