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