- if ( substr($msg->message,2,1) eq "\x07" ) { # heartbeat
- $topic =~ s/up$/down/;
-
- my @all_pending = sort glob "$queue/$dir/.pending/*";
- if ( my $pending = shift @all_pending ) {
- my $raw = read_file $pending;
- my $pending_function_code = unpack('C',substr($msg->message,2,1));
-
- send_message($socket,
- message_type => MQTT_PUBLISH,
- retain => 0, #$retain,
- topic => $topic,
- message => $raw);
- $pending =~ s{$queue/$dir/.pending/}{};
- rename "$queue/$dir/.pending/$pending", "$queue/$dir/$pending.sent.$pending_function_code";
- }
-