natas_hw
/
paho
mirror of https://github.com/eclipse/paho.mqtt.c
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Call onFailure when removing queued publish messages

This commit is contained in:
ydy 2024-12-17 19:40:39 +08:00 committed by Ian Craggs
parent 802992b8dd
commit cb4facf000
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/MQTTAsyncUtils.c
View File

@ -907,7 +907,27 @@ int MQTTAsync_addCommand(MQTTAsync_queuedCommand* command, int command_size)
if (command->client->c->persistence)
MQTTAsync_unpersistCommand(first_publish);
#endif
if (first_publish->command.onFailure)
{
MQTTAsync_failureData data;
data.token = first_publish->command.token;
data.code = MQTTASYNC_MAX_BUFFERED_MESSAGES;
data.message = NULL;
Log(TRACE_MIN, -1, "Cache is full, messages have been removed.");
(*(first_publish->command.onFailure))(first_publish->command.context, &data);
}
else if (first_publish->command.onFailure5)
{
MQTTAsync_failureData5 data;
data.token = first_publish->command.token;
data.code = MQTTASYNC_MAX_BUFFERED_MESSAGES;
data.message = NULL;
data.packet_type = PUBLISH;
Log(TRACE_MIN, -1, "Cache is full, messages have been removed.");
(*(first_publish->command.onFailure5))(first_publish->command.context, &data);
}
MQTTAsync_freeCommand(first_publish);
}
}