Seperate queues for jobs
This commit is contained in:
parent
8798f05ff7
commit
07fdabbbd4
2 changed files with 2 additions and 2 deletions
|
|
@ -1,6 +1,6 @@
|
||||||
module Jobs
|
module Jobs
|
||||||
class ReceiveSalmon
|
class ReceiveSalmon
|
||||||
@queue = :receive
|
@queue = :receive_salmon
|
||||||
def self.perform(user_id, xml)
|
def self.perform(user_id, xml)
|
||||||
user = User.find(user_id)
|
user = User.find(user_id)
|
||||||
user.receive_salmon(xml)
|
user.receive_salmon(xml)
|
||||||
|
|
|
||||||
|
|
@ -1,6 +1,6 @@
|
||||||
module Jobs
|
module Jobs
|
||||||
class SocketWebfinger
|
class SocketWebfinger
|
||||||
@queue = :receive
|
@queue = :socket_webfinger
|
||||||
def self.perform(user_id, account, opts={})
|
def self.perform(user_id, account, opts={})
|
||||||
finger = Webfinger.new(account)
|
finger = Webfinger.new(account)
|
||||||
begin
|
begin
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue