lib/message_bus/backends/postgres.rb in message_bus-2.1.2 vs lib/message_bus/backends/postgres.rb in message_bus-2.1.3
- old
+ new
@@ -377,10 +377,10 @@
yield m
end
end
end
rescue => error
- MessageBus.logger.warn "#{error} subscribe failed, reconnecting in 1 second. Call stack\n#{error.backtrace.join("\n")}"
+ @config[:logger].warn "#{error} subscribe failed, reconnecting in 1 second. Call stack\n#{error.backtrace.join("\n")}"
sleep 1
retry
end
end