X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Fweb%2Ffederator%2Ffederator.ex;h=57e11b4fb4e72964bb73e8dd56511b9addcc1955;hb=68aa9a2826410463ce8056c7e42ba60013376f19;hp=0b9808b8f919ed1e02ce45b578de2b5c88791382;hpb=92021fd00c538ac24f68dcd95ee18bef9de6cc0e;p=akkoma diff --git a/lib/pleroma/web/federator/federator.ex b/lib/pleroma/web/federator/federator.ex index 0b9808b8f..57e11b4fb 100644 --- a/lib/pleroma/web/federator/federator.ex +++ b/lib/pleroma/web/federator/federator.ex @@ -10,7 +10,9 @@ defmodule Pleroma.Web.Federator do @websub Application.get_env(:pleroma, :websub) @ostatus Application.get_env(:pleroma, :ostatus) @httpoison Application.get_env(:pleroma, :httpoison) - @max_jobs 10 + @instance Application.get_env(:pleroma, :instance) + @federating Keyword.get(@instance, :federating) + @max_jobs 20 def start_link do spawn(fn -> @@ -107,10 +109,12 @@ defmodule Pleroma.Web.Federator do end def enqueue(type, payload, priority \\ 1) do - if Mix.env == :test do - handle(type, payload) - else - GenServer.cast(__MODULE__, {:enqueue, type, payload, priority}) + if @federating do + if Mix.env == :test do + handle(type, payload) + else + GenServer.cast(__MODULE__, {:enqueue, type, payload, priority}) + end end end