lib/bbk/app/dispatcher.rb in bbk-app-1.1.0.200186 vs lib/bbk/app/dispatcher.rb in bbk-app-1.1.0.200751
- old
+ new
@@ -97,10 +97,10 @@
logger.error "Consumer #{cons} stop error: #{e}"
logger.debug e.backtrace
end
end
- @stream_strategy.stop(5)
+ @stream_strategy&.stop(5)
consumers.each do |cons|
begin
cons.close
rescue StandardError => e