lib/mini_autobot/connector.rb in mini_autobot-0.0.2 vs lib/mini_autobot/connector.rb in mini_autobot-0.0.3
- old
+ new
@@ -53,16 +53,15 @@
Thread.current[:active_connector] = nil
end
return unless MiniAutobot.settings.auto_finalize?
- Thread.new do
- while connector = self.finalization_queue.pop
- begin
- connector.finalize!
- rescue => e
- MiniAutobot.logger.error("Could not finalize Connector(##{connector.object_id}): #{e.message}")
- end
+ while self.finalization_queue.size > 0
+ connector = self.finalization_queue.pop
+ begin
+ connector.finalize!
+ rescue => e
+ MiniAutobot.logger.error("Could not finalize Connector(##{connector.object_id}): #{e.message}")
end
end
end
# Given a connector profile and an environment profile, this method will