lib/ruote/worker.rb
# Shuts down this worker (makes sure it won't fetch further messages
# and schedules).
#
Shuts down this worker (makes sure it won't fetch further messages
and schedules).
Shuts down this worker ( makes sure it won ' t fetch further messages and schedules ) .
def shutdown
      @state_mutex.synchronize { @state = 'stopped' }
      join
    end
def shutdown @state_mutex . synchronize { @state = 'stopped' } join end
Shuts down this worker (makes sure it won't fetch further messages
and schedules).
Shuts down this worker ( makes sure it won ' t fetch further messages and schedules ) .