Class: Zulu::TopicDistributionProcessor

Inherits:
Object
  • Object
show all
Includes:
Celluloid::IO, Celluloid::Logger
Defined in:
lib/zulu/topic_distribution_processor.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ TopicDistributionProcessor

Returns a new instance of TopicDistributionProcessor.



10
11
12
 
# File 'lib/zulu/topic_distribution_processor.rb', line 10

def initialize
  debug "Distribution Processor starting up"
end

Instance Method Details

#process ⇒ Object 



14
15
16
17
18
19
20
21
22
 
# 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 ⇒ Object 



24
25
26
27
 
# File 'lib/zulu/topic_distribution_processor.rb', line 24

def reprocess
  debug "Distribution Reprocessing..."
  after(0) { process }
end

#shutdown ⇒ Object 



29
30
31
 
# File 'lib/zulu/topic_distribution_processor.rb', line 29

def shutdown
  debug "Distribution Processor shutting down"
end