(oq *destinationQueue)
| 179 | } |
| 180 | |
| 181 | func (oqs *OutgoingQueues) clearQueue(oq *destinationQueue) { |
| 182 | oqs.queuesMutex.Lock() |
| 183 | defer oqs.queuesMutex.Unlock() |
| 184 | |
| 185 | delete(oqs.queues, oq.destination) |
| 186 | destinationQueueTotal.Dec() |
| 187 | } |
| 188 | |
| 189 | // SendEvent sends an event to the destinations |
| 190 | func (oqs *OutgoingQueues) SendEvent( |
no test coverage detected