Only check for queue in ready check
The logWriterFactory may be nil even when the processor pool is running.
@@ -87,7 +87,7 @@ func (p *ProcessorPool) Each(f func(int, *Processor)) {
// Ready returns true if the processor pool is running as expected.
// Returns false if the processor pool has not been started yet.
func (p *ProcessorPool) Ready() bool {
- return p.queue != nil && p.logWriterFactory != nil
+ return p.queue != nil
}
// Size returns the number of processors that are currently running.
