class Zulu::TopicDistributionProcessor

Public Class Methods

new() click to toggle source
# File lib/zulu/topic_distribution_processor.rb, line 10
def initialize
  debug "Distribution Processor starting up"
end

Public Instance Methods

process() click to toggle source
# File lib/zulu/topic_distribution_processor.rb, line 14
def process
  debug "Looking for a topic distribution"
  distribution = TopicDistribution.pop(1)
  if distribution
    debug "Distribution found. Processing..."
    distribution.process
  end
  async.reprocess
end
reprocess() click to toggle source
# File lib/zulu/topic_distribution_processor.rb, line 24
def reprocess
  debug "Distribution Reprocessing..."
  after(0) { process }
end
shutdown() click to toggle source
# File lib/zulu/topic_distribution_processor.rb, line 29
def shutdown
  debug "Distribution Processor shutting down"
end