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.



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

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

Class Method Details

.run ⇒ Object 



7
8
9
 
# File 'lib/dispatch-rider/runner.rb', line 7

def self.run
  new.process
end

Instance Method Details

#process ⇒ Object 



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

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