@@ -12,7 +12,7 @@ use open ':utf8';

 use open ':std';

 use utf8;

-use Data::Dumper;

+#use Data::Dumper;

 use threads;

 use threads::shared;

@@ -114,7 +114,9 @@ sub massive_send_sms {

 }

 sub send_mail {

-    while (my $msg = $mail_queue->dequeue) {

+    while (1) {

+        my $msg = $mail_queue->dequeue_timed(10, 1);

+        next if ! defined $msg;

         defined($msg->{to}) or $msg->{to} = $cfg::config{mail};

         open(MAIL, "|msmtp $msg->{to}");

         print MAIL "Subject: $msg->{Subject}\n";

@@ -214,7 +216,9 @@ sub react_on_message {

 }

 sub inbox_sms_parse {

-    while (my $msg = $inbox_sms_queue->dequeue) {

+    while (1) {

+        my $msg = $inbox_sms_queue->dequeue_timed(10, 1);

+        next if ! defined $msg;

         my %part_from_user = (

             $cfg::user{"message de groupe"} => sub {

@@ -229,9 +233,9 @@ sub inbox_sms_parse {

             $cfg::user{"ping"} => sub {

                 my $envoi_en_cours = '';

                 if ($outbox_sms_queue->pending() > 0) {

-                    for (my $queue_id = $outbox_sms_queue->pending(); $queue_id >= 0; $queue_id--) {

-                        log_bot(Dumper($outbox_sms_queue->peek($queue_id)));

-                    }

+#                    for (my $queue_id = $outbox_sms_queue->pending(); $queue_id >= 0; $queue_id--) {

+#                        log_bot(Dumper($outbox_sms_queue->peek($queue_id)));

+#                    }

                     $envoi_en_cours = "\nenvoi en cours de traitement (reste " . $outbox_sms_queue->pending() . ") ";

                     $envoi_en_cours .= "par $cfg::config{last_sender}" if defined($cfg::config{last_sender});

                 }