smitten/akkoma
1
0
Fork 0
forked from AkkomaGang/akkoma
Code Issues Pull requests Projects Releases Packages Wiki Activity

Fix queue name

Browse source
This commit is contained in:
Egor Kislitsyn 2019-02-14 17:02:47 +07:00
parent 305d219413
commit 3f32d7b937
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
lib/pleroma/web/federator/federator.ex
View file

@ -38,31 +38,31 @@ def incoming_ap_doc(params) do
end
def publish(activity, priority \\ 1) do
Jobs.enqueue(:federator_out, __MODULE__, [:publish, activity], priority)
Jobs.enqueue(:federator_outgoing, __MODULE__, [:publish, activity], priority)
end
def publish_single_ap(params) do
Jobs.enqueue(:federator_out, __MODULE__, [:publish_single_ap, params])
Jobs.enqueue(:federator_outgoing, __MODULE__, [:publish_single_ap, params])
end
def publish_single_websub(websub) do
Jobs.enqueue(:federator_out, __MODULE__, [:publish_single_websub, websub])
Jobs.enqueue(:federator_outgoing, __MODULE__, [:publish_single_websub, websub])
end
def verify_websub(websub) do
Jobs.enqueue(:federator_out, __MODULE__, [:verify_websub, websub])
Jobs.enqueue(:federator_outgoing, __MODULE__, [:verify_websub, websub])
end
def request_subscription(sub) do
Jobs.enqueue(:federator_out, __MODULE__, [:request_subscription, sub])
Jobs.enqueue(:federator_outgoing, __MODULE__, [:request_subscription, sub])
end
def refresh_subscriptions() do
Jobs.enqueue(:federator_out, __MODULE__, [:refresh_subscriptions])
Jobs.enqueue(:federator_outgoing, __MODULE__, [:refresh_subscriptions])
end
def publish_single_salmon(params) do
Jobs.enqueue(:federator_out, __MODULE__, [:publish_single_salmon, params])
Jobs.enqueue(:federator_outgoing, __MODULE__, [:publish_single_salmon, params])
end
# Job Worker Callbacks