class Zulu::SubscriptionRequestProcessor
Public Class Methods
new()
click to toggle source
# File lib/zulu/subscription_request_processor.rb, line 10 def initialize debug "Request Processor starting up" end
Public Instance Methods
process()
click to toggle source
# File lib/zulu/subscription_request_processor.rb, line 14 def process debug "Looking for a subscription request" request = SubscriptionRequest.pop(1) if request debug "Request found. Processing..." request.process end async.reprocess end
reprocess()
click to toggle source
# File lib/zulu/subscription_request_processor.rb, line 24 def reprocess debug "Reprocessing..." after(0) { process } end
shutdown()
click to toggle source
# File lib/zulu/subscription_request_processor.rb, line 29 def shutdown debug "Request Processor shutting down" end