Class: Que::Adapters::Sequel

Inherits:

Base

• Object
• Base
• Que::Adapters::Sequel

Defined in:

lib/que/adapters/sequel.rb

Instance Method Summary

• #checkout(&block) ⇒ Object
• #initialize(db) ⇒ Sequel constructor

  A new instance of Sequel.

• #wake_worker_after_commit ⇒ Object

Methods inherited from Base

#cleanup!, #execute, #in_transaction?

Constructor Details

#initialize(db) ⇒ Sequel

Returns a new instance of Sequel.

# File 'lib/que/adapters/sequel.rb', line 6

def initialize(db)
  @db = db
  super
end

Instance Method Details

#checkout(&block) ⇒ Object

# File 'lib/que/adapters/sequel.rb', line 11

def checkout(&block)
  @db.synchronize(&block)
end

#wake_worker_after_commit ⇒ Object

# File 'lib/que/adapters/sequel.rb', line 15

def wake_worker_after_commit
  @db.after_commit { Que.wake! }
end