Class: Primer::Worker::Agent

Inherits:
Object
  • Object
show all
Defined in:
lib/primer/worker.rb

Direct Known Subclasses

ActiveRecordAgent, ChangesAgent

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.run!Object


7
8
9
10
11
# File 'lib/primer/worker.rb', line 7

def self.run!
  agent = new
  agent.run!
  agent
end

.topic(topic_name = nil) ⇒ Object


13
14
15
# File 'lib/primer/worker.rb', line 13

def self.topic(topic_name = nil)
  @topic_name ||= topic_name
end

Instance Method Details

#run!Object


17
18
19
# File 'lib/primer/worker.rb', line 17

def run!
  Primer.bus.subscribe(self.class.topic) { |m| on_message(m) }
end