Class: DispatchRider::Runner

Inherits:
Object
  • Object
show all
Includes:
Callbacks::Support
Defined in:
lib/dispatch-rider/runner.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Runner

Returns a new instance of Runner.



9
10
11
12
13
14
 
# File 'lib/dispatch-rider/runner.rb', line 9

def initialize
  callbacks.invoke(:initialize) do
    ready
    set_queue_from_config
  end
end

Class Method Details

.run ⇒ Object 



5
6
7
 
# File 'lib/dispatch-rider/runner.rb', line 5

def self.run
  new.process
end

Instance Method Details

#process ⇒ Object 



17
18
19
20
21
22
 
# File 'lib/dispatch-rider/runner.rb', line 17

def process
  callbacks.invoke(:process) do
    logger.info "Running..."
    @subscriber.process
  end
end