Sha256: ba440eff0e0bf865f6639ae8b48f3918181ad95fea18bff1419b6d2404d4f965

Contents?: true

Size: 413 Bytes

Versions: 33

Compression:

Stored size: 413 Bytes

Contents

# frozen_string_literal: true

module Delayed
  #
  # Override the start and stop of the worker itself to capture start/end of the worker lifecycle
  #
  class Worker
    #
    # Starting the worker
    #
    def start
      super
      Delayed::Jobs::Worker.find_or_create_server
    end

    #
    # Stop the worker
    #
    def stop
      Delayed::Jobs::Worker.find_server&.stop
      super
    end
  end
end

Version data entries

33 entries across 33 versions & 1 rubygems

Version Path
web47core-3.2.20 lib/app/models/delayed/worker.rb
web47core-3.2.19 lib/app/models/delayed/worker.rb
web47core-3.2.18 lib/app/models/delayed/worker.rb
web47core-3.2.17 lib/app/models/delayed/worker.rb
web47core-3.2.16 lib/app/models/delayed/worker.rb
web47core-3.2.15 lib/app/models/delayed/worker.rb
web47core-3.2.14 lib/app/models/delayed/worker.rb
web47core-3.2.13 lib/app/models/delayed/worker.rb
web47core-3.2.12 lib/app/models/delayed/worker.rb
web47core-3.2.9 lib/app/models/delayed/worker.rb
web47core-3.2.8 lib/app/models/delayed/worker.rb
web47core-3.2.7 lib/app/models/delayed/worker.rb
web47core-3.2.6 lib/app/models/delayed/worker.rb
web47core-3.2.5 lib/app/models/delayed/worker.rb
web47core-3.2.4 lib/app/models/delayed/worker.rb
web47core-2.2.20 lib/app/models/delayed/worker.rb
web47core-2.2.19 lib/app/models/delayed/worker.rb
web47core-3.2.3 lib/app/models/delayed/worker.rb
web47core-3.2.2 lib/app/models/delayed/worker.rb
web47core-2.2.15 lib/app/models/delayed/worker.rb