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