SetClient updates the client used by a queue. Used when only client specific fields are updated to avoid restarting the queue.
(c WriteClient)
| 1078 | // SetClient updates the client used by a queue. Used when only client specific |
| 1079 | // fields are updated to avoid restarting the queue. |
| 1080 | func (t *QueueManager) SetClient(c WriteClient) { |
| 1081 | t.clientMtx.Lock() |
| 1082 | t.storeClient = c |
| 1083 | t.clientMtx.Unlock() |
| 1084 | } |
| 1085 | |
| 1086 | func (t *QueueManager) client() WriteClient { |
| 1087 | t.clientMtx.RLock() |