Fixes #60 by draining the queue if new hosts are collected before the previous hosts in the queue have been consumed. To prevent future unbounded queue growth due to developer errors, the max size of these queues have been set to 1, which makes it explicit that these queues should never contain more than a single collection result at any point.
A warning log message is now generated when the collection rate outpaces the processing rate.
Fixes #60 by draining the queue if new hosts are collected before the previous hosts in the queue have been consumed. To prevent future unbounded queue growth due to developer errors, the max size of these queues have been set to 1, which makes it explicit that these queues should never contain more than a single collection result at any point.
A warning log message is now generated when the collection rate outpaces the processing rate.