lib/backburner/worker.rb in backburner-0.4.6 vs lib/backburner/worker.rb in backburner-1.0.0
- old
+ new
@@ -51,11 +51,11 @@
end
end
# Returns the worker connection.
# @example
- # Backburner::Worker.connection # => <Beaneater::Pool>
+ # Backburner::Worker.connection # => <Beaneater::Connection>
def self.connection
@connection ||= Connection.new(Backburner.configuration.beanstalk_url)
end
# List of tube names to be watched and processed
@@ -157,10 +157,10 @@
# @raise [Beaneater::NotConnected] If beanstalk fails to connect multiple times.
#
def self.retryable_command(max_tries=8, &block)
begin
yield
- rescue Beaneater::NotConnected => e
+ rescue Beaneater::NotConnected
retry_connection!(max_tries)
yield
end
end