mkdir "$queue" if ( ! -e "$queue" );
mkdir "$queue/$dir" if ( ! -e "$queue/$dir" );
mkdir "$queue/$dir/up" if ( ! -e "$queue/$dir/up" );
- write_file "$queue/$dir/up/$t", $msg->string;
+
+ my $function_code = unpack('C',substr($msg->message,2,1));
+
+ write_file "$queue/$dir/up/$t.$function_code", $msg->message;
mkdir "$queue/$dir/down" if ( ! -e "$queue/$dir/down" );
mkdir "$queue/$dir/down/.done" if ( ! -e "$queue/$dir/down/.done" );
retain => 0, #$retain,
topic => $topic,
message => $raw);
+ $pending =~ s{$queue/$dir/down/}{};
rename "$queue/$dir/down/$pending", "$queue/$dir/down/.done/$pending";
}
}