# File lib/activemessaging/adapters/beanstalk.rb, line 28 def disconnect @connection.close end
# File lib/activemessaging/adapters/beanstalk.rb, line 49 def receive(options={}) message = @connection.reserve Beanstalk::Message.new message end
# File lib/activemessaging/adapters/beanstalk.rb, line 54 def received message, message_headers={} message.delete end
# File lib/activemessaging/adapters/beanstalk.rb, line 40 def send tube, message, message_headers={} priority = message_headers[:priority] || 65536 delay = message_headers[:delay] || 0 ttr = message_headers[:ttr] || 120 @connection.use(tube) @connection.put(message, priority, delay, ttr) end
# File lib/activemessaging/adapters/beanstalk.rb, line 32 def subscribe tube, message_headers={} @connection.watch(tube) end
Generated with the Darkfish Rdoc Generator 2.