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