diff --git a/modules/structs/WebClient.go b/modules/structs/WebClient.go index 6d8320a..c0a4040 100644 --- a/modules/structs/WebClient.go +++ b/modules/structs/WebClient.go @@ -132,15 +132,15 @@ func getMessageFromReceivedQueueByCmdID(receivedQueueMessages []*ReceivedQueueMe } func (webClient *WebClient) RemoveMessageFromVoiceSendQueueByCmdID(cmdID int) { - removeMessageFromSendQueueByCmdID(webClient.SendVoiceQueueMessages, &webClient.sendVoiceQueueMessagesMu, cmdID) + webClient.SendVoiceQueueMessages = removeMessageFromSendQueueByCmdID(webClient.SendVoiceQueueMessages, &webClient.sendVoiceQueueMessagesMu, cmdID) logger.WebVoice.Warnln("RemoveMessageFromVoiceSendQueueByCmdID list", webClient.SendVoiceQueueMessages) } func (webClient *WebClient) RemoveMessageFromMobileSendQueueByCmdID(cmdID int) { - removeMessageFromSendQueueByCmdID(webClient.SendMobileQueueMessages, &webClient.sendMobileQueueMessagesMu, cmdID) + webClient.SendMobileQueueMessages = removeMessageFromSendQueueByCmdID(webClient.SendMobileQueueMessages, &webClient.sendMobileQueueMessagesMu, cmdID) } -func removeMessageFromSendQueueByCmdID(queueMessages []*SendQueueMessage, mutex *sync.Mutex, cmdID int) { +func removeMessageFromSendQueueByCmdID(queueMessages []*SendQueueMessage, mutex *sync.Mutex, cmdID int) []*SendQueueMessage { mutex.Lock() defer mutex.Unlock()