class ActiveMessaging::Adapters::Beanstalk::Message

Attributes

beanstalk_job[RW]

Public Class Methods

new(beanstalk_job) click to toggle source
Calls superclass method ActiveMessaging::BaseMessage::new
# File lib/activemessaging/adapters/beanstalk.rb, line 67
def initialize beanstalk_job
  bsh = {
    'destination' => beanstalk_job.stats['tube'],
    'priority'    => beanstalk_job.pri,
    'delay'       => beanstalk_job.delay,
    'ttr'         => beanstalk_job.ttr
  }
  super(beanstalk_job.body, beanstalk_job.id, bsh, beanstalk_job.stats['tube'])
  @beanstalk_job = beanstalk_job
end

Public Instance Methods

delete() click to toggle source
# File lib/activemessaging/adapters/beanstalk.rb, line 78
def delete
  @beanstalk_job.delete
end
release() click to toggle source
# File lib/activemessaging/adapters/beanstalk.rb, line 82
def release
  @beanstalk_job.release
end