diff --git a/bin/pt-agent b/bin/pt-agent index bf1bf62f..503592fc 100755 --- a/bin/pt-agent +++ b/bin/pt-agent @@ -4858,7 +4858,7 @@ sub BUILD { while ( $self->_message_queue && $self->_message_queue->pending() && $max_log_entries-- - && (my $entry = $self->message_queue->dequeue()) ) + && (my $entry = $self->_message_queue->dequeue()) ) { $oktorun = 0 if !defined $entry; push @log_entries, Percona::WebAPI::Resource::LogEntry->new( diff --git a/lib/Percona/Agent/Logger.pm b/lib/Percona/Agent/Logger.pm index ff4eae48..c5d8720d 100644 --- a/lib/Percona/Agent/Logger.pm +++ b/lib/Percona/Agent/Logger.pm @@ -87,7 +87,7 @@ sub BUILD { while ( $self->_message_queue && $self->_message_queue->pending() && $max_log_entries-- - && (my $entry = $self->message_queue->dequeue()) ) + && (my $entry = $self->_message_queue->dequeue()) ) { $oktorun = 0 if !defined $entry; # $event = [ level, "message" ]