Contents

# beanstalk-client/job.rb - client library for beanstalk

# Copyright (C) 2007 Philotic Inc.

# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.

# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.

# You should have received a copy of the GNU General Public License
# along with this program.  If not, see <http://www.gnu.org/licenses/>.

require 'yaml'

class Beanstalk::Job
  attr_reader :id, :pri, :body, :conn

  # Return the object that results from loading the body as a yaml stream.
  # Return nil if the body is not a valid yaml stream.
  def ybody()
    (@ybody ||= [begin YAML.load(body) rescue nil end])[0]
  end

  def initialize(conn, id, pri, body)
    @conn = conn
    @id = id
    @pri = pri
    @body = body
  end

  def delete()
    @conn.delete(id)
  end

  def put_back(pri=self.pri)
    @conn.put(body, pri)
  end

  def release(newpri=pri, delay=0)
    @conn.release(id, newpri, delay)
  end

  def bury(newpri=pri)
    @conn.bury(id, newpri)
  end

  def stats()
    @conn.job_stats(id)
  end

  def timeouts() stats['timeouts'] end
  def time_left() stats['time-left'] end
  def age() stats['age'] end
  def state() stats['state'] end
  def delay() stats.fetch('delay', 0) end

  def server()
    @conn.addr
  end

  # Don't delay for more than 48 hours at a time.
  DELAY_MAX = 60 * 60 * 48 unless defined?(DELAY_MAX)

  def decay(d=([1, delay].max * 1.3).ceil)
    return bury() if delay >= DELAY_MAX
    release(pri, d)
  end

  def to_s
    "(job #{body.inspect})"
  end

  def inspect
    "(job server=#{server} id=#{id} pri=#{pri} size=#{body.size})"
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
beanstalk-client-0.1	lib/beanstalk-client/job.rb