Sha256: 441121e75457ea3d1726d05f0b0e4101107f0892f2da7ca3dee6f3480e03ab0d

Contents?: true

Size: 587 Bytes

Versions: 7

Compression:

Stored size: 587 Bytes

Contents

module EMJack
  class Job
    attr_accessor :jobid, :body, :ttr, :conn

    def initialize(conn, jobid, body)
      @conn = conn
      @jobid = jobid.to_i
      @body = body
    end

    def delete(&blk)
      @conn.delete(self, &blk)
    end

    def release(opts = {}, &blk)
      @conn.release(self, opts, &blk)
    end

    def stats(&blk)
      @conn.stats(:job, self, &blk)
    end

    def touch(&blk)
      @conn.touch(self, &blk)
    end

    def bury(delay, &blk)
      @conn.bury(self, delay, &blk)
    end

    def to_s
      "#{@jobid} -- #{body.inspect}"
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
em-jack-0.1.5 lib/em-jack/job.rb
em-jack-0.1.4 lib/em-jack/job.rb
em-jack-0.1.3 lib/em-jack/job.rb
em-jack-0.1.2 lib/em-jack/job.rb
em-jack-0.1.1 lib/em-jack/job.rb
em-jack-0.1.0 lib/em-jack/job.rb
em-jack-0.0.9 lib/em-jack/job.rb