resque requires a job to be assigned to a queue. enable resque logging on posting to a hub
This commit is contained in:
parent
c16d0c46a2
commit
685b809248
2 changed files with 5 additions and 2 deletions
|
|
@ -3,9 +3,9 @@
|
||||||
# the COPYRIGHT file.
|
# the COPYRIGHT file.
|
||||||
#
|
#
|
||||||
module Jobs
|
module Jobs
|
||||||
class PostToService
|
class PostToService
|
||||||
extend ResqueJobLogging
|
extend ResqueJobLogging
|
||||||
@queue = :http
|
@queue = :http_service
|
||||||
|
|
||||||
def self.perform(service_id, post_id, url)
|
def self.perform(service_id, post_id, url)
|
||||||
service = Service.find_by_id(service_id)
|
service = Service.find_by_id(service_id)
|
||||||
|
|
|
||||||
|
|
@ -4,6 +4,9 @@
|
||||||
|
|
||||||
module Jobs
|
module Jobs
|
||||||
class PublishToHub
|
class PublishToHub
|
||||||
|
extend ResqueJobLogging
|
||||||
|
@queue = :http_service
|
||||||
|
|
||||||
def self.perform(sender_public_url)
|
def self.perform(sender_public_url)
|
||||||
PubSubHubbub.new(AppConfig[:pubsub_server]).publish(sender_public_url)
|
PubSubHubbub.new(AppConfig[:pubsub_server]).publish(sender_public_url)
|
||||||
end
|
end
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue