Method wakeQueueIfNeeded

federationapi/queue/destinationqueue.go:163–173

wakeQueueIfNeeded will wake up the destination queue if it is not already running. If it is running but it is backing off then we will interrupt the backoff, causing any federation requests to retry.

()

// then we will interrupt the backoff, causing any federation
// requests to retry.
func (oq *destinationQueue) wakeQueueIfNeeded() {
	// If we are backing off then interrupt the backoff.
	if oq.backingOff.CAS(true, false) {
		oq.interruptBackoff <- true
	}
	// If we aren't running then wake up the queue.
	if !oq.running.Load() {
		// Start the queue.
		go oq.backgroundSend()
	}
}

// getPendingFromDatabase will look at the database and see if
// there are any persisted events that haven't been sent to this