mirror of
https://github.com/fhem/fhem-mirror.git
synced 2025-04-22 02:10:32 +00:00
00_MQTT2_SERVER.pm: SUBACK-fix-fix (Forum #122978)
git-svn-id: https://svn.fhem.de/fhem/trunk@24982 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
parent
806469796f
commit
219e0cdaab
@ -523,6 +523,7 @@ MQTT2_CLIENT_Read($@)
|
|||||||
} else {
|
} else {
|
||||||
Log 1, "M2: Unhandled packet $cpt, disconneting $name";
|
Log 1, "M2: Unhandled packet $cpt, disconneting $name";
|
||||||
MQTT2_CLIENT_Disco($hash);
|
MQTT2_CLIENT_Disco($hash);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
# Allow some IO inbetween, for overloaded systems
|
# Allow some IO inbetween, for overloaded systems
|
||||||
|
@ -405,7 +405,7 @@ MQTT2_SERVER_Read($@)
|
|||||||
push @ret, ($qos > 1 ? 1 : 0); # max qos supported is 1
|
push @ret, ($qos > 1 ? 1 : 0); # max qos supported is 1
|
||||||
}
|
}
|
||||||
# SUBACK
|
# SUBACK
|
||||||
MQTT2_SERVER_out($hash, pack("CCnC*", 0x90, 3, $pid, @ret), $dump);
|
MQTT2_SERVER_out($hash, pack("CCnC*", 0x90, 2+@ret, $pid, @ret), $dump);
|
||||||
|
|
||||||
if(!$hash->{answerScheduled}) {
|
if(!$hash->{answerScheduled}) {
|
||||||
$hash->{answerScheduled} = 1;
|
$hash->{answerScheduled} = 1;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user