@@ -324,11 +324,12 @@ void SinricProClass::handleRequest(DynamicJsonDocument& requestMessage, interfac
324
324
}
325
325
326
326
void SinricProClass::handleReceiveQueue () {
327
- if (receiveQueue.count () == 0 ) return ;
327
+ if (receiveQueue.size () == 0 ) return ;
328
328
329
- DEBUG_SINRIC (" [SinricPro.handleReceiveQueue()]: %i message(s) in receiveQueue\r\n " , receiveQueue.count ());
330
- while (receiveQueue.count () > 0 ) {
331
- SinricProMessage* rawMessage = receiveQueue.pop ();
329
+ DEBUG_SINRIC (" [SinricPro.handleReceiveQueue()]: %i message(s) in receiveQueue\r\n " , receiveQueue.size ());
330
+ while (receiveQueue.size () > 0 ) {
331
+ SinricProMessage* rawMessage = receiveQueue.front ();
332
+ receiveQueue.pop ();
332
333
DynamicJsonDocument jsonMessage (1024 );
333
334
deserializeJson (jsonMessage, rawMessage->getMessage ());
334
335
@@ -357,11 +358,11 @@ void SinricProClass::handleReceiveQueue() {
357
358
void SinricProClass::handleSendQueue () {
358
359
if (!isConnected ()) return ;
359
360
if (!baseTimestamp) return ;
360
- while (sendQueue.count () > 0 ) {
361
- DEBUG_SINRIC (" [SinricPro:handleSendQueue()]: %i message(s) in sendQueue\r\n " , sendQueue.count ());
361
+ while (sendQueue.size () > 0 ) {
362
+ DEBUG_SINRIC (" [SinricPro:handleSendQueue()]: %i message(s) in sendQueue\r\n " , sendQueue.size ());
362
363
DEBUG_SINRIC (" [SinricPro:handleSendQueue()]: Sending message...\r\n " );
363
364
364
- SinricProMessage* rawMessage = sendQueue.pop ();
365
+ SinricProMessage* rawMessage = sendQueue.front (); sendQueue. pop ();
365
366
366
367
DynamicJsonDocument jsonMessage (1024 );
367
368
deserializeJson (jsonMessage, rawMessage->getMessage ());
0 commit comments