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