Module: Postqueue

Extended by:

Enqueue, Processing

Defined in:

lib/postqueue.rb,
lib/postqueue/item.rb,
lib/postqueue/enqueue.rb,
lib/postqueue/version.rb,
lib/postqueue/processing.rb

Defined Under Namespace

Modules: Enqueue, Processing Classes: Item

Constant Summary

VERSION =

'0.0.8'

MAX_ATTEMPTS =

3

Constants included from Enqueue

Enqueue::Item

Class Method Summary

• .migrate! ⇒ Object
• .unmigrate! ⇒ Object

Methods included from Enqueue

enqueue

Methods included from Processing

process, process_one

Class Method Details

.migrate! ⇒ Object

# File 'lib/postqueue/item.rb', line 14

def self.migrate!
  Item.connection.execute "  CREATE TABLE postqueue (\n    id          SERIAL PRIMARY KEY, \n    op          VARCHAR,\n    entity_type VARCHAR,\n    entity_id   INTEGER NOT NULL DEFAULT 0,\n    created_at  timestamp without time zone NOT NULL DEFAULT (now() at time zone 'utc'),\n    next_run_at timestamp without time zone NOT NULL DEFAULT (now() at time zone 'utc'),\n    failed_attempts INTEGER NOT NULL DEFAULT 0\n  );\n\n  CREATE INDEX postqueue_idx1 ON postqueue(entity_id);\n  CREATE INDEX postqueue_idx2 ON postqueue(next_run_at);\n  SQL\nend\n"

.unmigrate! ⇒ Object

# File 'lib/postqueue/item.rb', line 8

def self.unmigrate!
  Item.connection.execute "    DROP TABLE IF EXISTS postqueue;\n  SQL\nend\n"