IsStopped checks if the queue is still running and active
()
| 131 | |
| 132 | // IsStopped checks if the queue is still running and active |
| 133 | func (q *Queue) IsStopped() bool { |
| 134 | q.smux.RLock() |
| 135 | var stopped = q.stopped |
| 136 | q.smux.RUnlock() |
| 137 | return stopped |
| 138 | } |
| 139 | |
| 140 | func (q *Queue) flushIfNeeded() { |
| 141 | if q.pending >= q.batchSize { |
no outgoing calls