lib/backburner/connection.rb in backburner-allq-1.0.18 vs lib/backburner/connection.rb in backburner-allq-1.0.19
- old
+ new
@@ -36,9 +36,13 @@
rescue
false
end
end
+ def tubes
+ @allq_wrapper.tube_names if @allq_wrapper
+ end
+
# Attempt to reconnect to allq. Note: the connection will not be watching
# or using the tubes it was before it was reconnected (as it's actually a
# completely new connection)
# @raise [Beaneater::NotConnected] If allq fails to connect
def reconnect!