lib/startback/event/bus/bunny/async.rb in startback-1.0.1 vs lib/startback/event/bus/bunny/async.rb in startback-1.0.2
- old
+ new
@@ -95,9 +95,13 @@
Thread.current[CHANNEL_KEY] = nil
end
@bunny.close if @bunny
end
+ def connected?
+ @bunny && @bunny.connected?
+ end
+
def channel
unless @bunny
raise Startback::Errors::Error, "Please connect your bus first, or use autoconnect: true"
end