mirror of
https://github.com/centreon/centreon-plugins.git
synced 2025-10-31 03:13:49 +01:00
314 lines
13 KiB
Perl
314 lines
13 KiB
Perl
#
|
|
# Copyright 2020 Centreon (http://www.centreon.com/)
|
|
#
|
|
# Centreon is a full-fledged industry-strength solution that meets
|
|
# the needs in IT infrastructure and application monitoring for
|
|
# service performance.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
#
|
|
|
|
package apps::mq::activemq::jmx::mode::brokers;
|
|
|
|
use base qw(centreon::plugins::templates::counter);
|
|
|
|
use strict;
|
|
use warnings;
|
|
use Digest::MD5 qw(md5_hex);
|
|
|
|
sub set_counters {
|
|
my ($self, %options) = @_;
|
|
|
|
$self->{maps_counters_type} = [
|
|
{ name => 'brokers', type => 3, cb_prefix_output => 'prefix_broker_output', cb_long_output => 'broker_long_output', indent_long_output => ' ', message_multiple => 'All brokers are ok',
|
|
group => [
|
|
{ name => 'global', type => 0, skipped_code => { -10 => 1 } },
|
|
{ name => 'queue', display_long => 1, cb_prefix_output => 'prefix_queue_output', message_multiple => 'All queues are ok', type => 1, skipped_code => { -10 => 1 } },
|
|
{ name => 'topic', display_long => 1, cb_prefix_output => 'prefix_topic_output', message_multiple => 'All topics are ok', type => 1, skipped_code => { -10 => 1 } }
|
|
]
|
|
}
|
|
];
|
|
|
|
$self->{maps_counters}->{global} = [
|
|
{ label => 'store-usage', nlabel => 'broker.store.usage.percentage', set => {
|
|
key_values => [ { name => 'StorePercentUsage' }, { name => 'display' } ],
|
|
output_template => 'store usage: %.2f %%',
|
|
perfdatas => [
|
|
{ template => '%.2f', unit => '%', min => 0, max => 100, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
},
|
|
{ label => 'temporary-usage', nlabel => 'broker.temporary.usage.percentage', set => {
|
|
key_values => [ { name => 'TempPercentUsage' }, { name => 'display' } ],
|
|
output_template => 'temporary usage: %.2f %%',
|
|
perfdatas => [
|
|
{ template => '%.2f', unit => '%', min => 0, max => 100, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
},
|
|
{ label => 'memory-usage', nlabel => 'broker.memory.usage.percentage', set => {
|
|
key_values => [ { name => 'MemoryPercentUsage' }, { name => 'display' } ],
|
|
output_template => 'memory usage: %.2f %%',
|
|
perfdatas => [
|
|
{ template => '%.2f', unit => '%', min => 0, max => 100, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
}
|
|
];
|
|
|
|
foreach (('queue', 'topic')) {
|
|
$self->{maps_counters}->{$_} = [
|
|
{ label => $_ . '-average-enqueue-time', nlabel => 'broker.' . $_ . '.average.enqueue.time.milliseconds', set => {
|
|
key_values => [ { name => 'AverageEnqueueTime' }, { name => 'display' } ],
|
|
output_template => 'average time messages remained enqueued: %.3f ms',
|
|
perfdatas => [
|
|
{ template => '%.3f', unit => 'ms', min => 0, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
},
|
|
{ label => $_ . '-consumers-connected', nlabel => 'broker.' . $_ . '.consumers.connected.count', set => {
|
|
key_values => [ { name => 'ConsumerCount' }, { name => 'display' } ],
|
|
output_template => 'consumers connected: %s',
|
|
perfdatas => [
|
|
{ template => '%s', min => 0, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
},
|
|
{ label => $_ . '-producers-connected', nlabel => 'broker.' . $_ . '.producers.connected.count', display_ok => 0, set => {
|
|
key_values => [ { name => 'ProducerCount' }, { name => 'display' } ],
|
|
output_template => 'producers connected: %s',
|
|
perfdatas => [
|
|
{ template => '%s', min => 0, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
},
|
|
{ label => $_ . '-memory-usage', nlabel => 'broker.' . $_ . '.memory.usage.percentage', display_ok => 0, set => {
|
|
key_values => [ { name => 'MemoryPercentUsage' }, { name => 'display' } ],
|
|
output_template => 'memory usage: %.2f %%',
|
|
perfdatas => [
|
|
{ template => '%.2f', unit => '%', min => 0, max => 100, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
},
|
|
{ label => $_ . '-size', nlabel => 'broker.' . $_ . '.size.count', set => {
|
|
key_values => [ { name => 'QueueSize' }, { name => 'display' } ],
|
|
output_template => 'queue size: %s',
|
|
perfdatas => [
|
|
{ template => '%s', min => 0, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
},
|
|
{ label => $_ . '-messages-enqueued', nlabel => 'broker.' . $_ . '.messages.enqueued.count', display_ok => 0, set => {
|
|
key_values => [ { name => 'EnqueueCount', diff => 1 }, { name => 'display' } ],
|
|
output_template => 'messages enqueued: %s',
|
|
perfdatas => [
|
|
{ template => '%s', min => 0, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
},
|
|
{ label => $_ . '-messages-dequeued', nlabel => 'broker.' . $_ . '.messages.dequeue.count', display_ok => 0, set => {
|
|
key_values => [ { name => 'DequeueCount', diff => 1 }, { name => 'display' } ],
|
|
output_template => 'messages dequeued: %s',
|
|
perfdatas => [
|
|
{ template => '%s', min => 0, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
},
|
|
{ label => $_ . '-messages-expired', nlabel => 'broker.' . $_ . '.messages.expired.count', display_ok => 0, set => {
|
|
key_values => [ { name => 'ExpiredCount', diff => 1 }, { name => 'display' } ],
|
|
output_template => 'messages expired: %s',
|
|
perfdatas => [
|
|
{ template => '%s', min => 0, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
},
|
|
{ label => $_ . '-messages-inflighted', nlabel => 'broker.' . $_ . '.messages.inflighted.count', display_ok => 0, set => {
|
|
key_values => [ { name => 'InFlightCount', diff => 1 }, { name => 'display' } ],
|
|
output_template => 'messages in-flighted: %s',
|
|
perfdatas => [
|
|
{ template => '%s', min => 0, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
},
|
|
{ label => $_ . '-messages-size-average', nlabel => 'broker.' . $_ . '.messages.size.average.bytes', display_ok => 0, set => {
|
|
key_values => [ { name => 'AverageMessageSize' }, { name => 'display' } ],
|
|
output_template => 'average messages size: %s %s',
|
|
output_change_bytes => 1,
|
|
perfdatas => [
|
|
{ template => '%s', unit => 'B', min => 0, label_extra_instance => 1 }
|
|
]
|
|
}
|
|
}
|
|
];
|
|
}
|
|
}
|
|
|
|
sub broker_long_output {
|
|
my ($self, %options) = @_;
|
|
|
|
return "checking broker '" . $options{instance_value}->{display} . "'";
|
|
}
|
|
|
|
sub prefix_broker_output {
|
|
my ($self, %options) = @_;
|
|
|
|
return "Broker '" . $options{instance_value}->{display} . "' ";
|
|
}
|
|
|
|
sub prefix_queue_output {
|
|
my ($self, %options) = @_;
|
|
|
|
return "queue '" . $options{instance_value}->{display} . "' ";
|
|
}
|
|
|
|
sub prefix_topic_output {
|
|
my ($self, %options) = @_;
|
|
|
|
return "topic '" . $options{instance_value}->{display} . "' ";
|
|
}
|
|
|
|
sub new {
|
|
my ($class, %options) = @_;
|
|
my $self = $class->SUPER::new(package => __PACKAGE__, %options, statefile => 1, force_new_perfdata => 1);
|
|
bless $self, $class;
|
|
|
|
$options{options}->add_options(arguments => {
|
|
'filter-broker-name:s' => { name => 'filter_broker_name' },
|
|
'filter-destination-name:s' => { name => 'filter_destination_name' },
|
|
'filter-destination-type:s' => { name => 'filter_destination_type' }
|
|
});
|
|
|
|
return $self;
|
|
}
|
|
|
|
sub manage_selection {
|
|
my ($self, %options) = @_;
|
|
|
|
my $request = [
|
|
{
|
|
mbean => 'org.apache.activemq:brokerName=*,destinationName=*,destinationType=*,type=Broker',
|
|
attributes => [
|
|
{ name => 'AverageEnqueueTime' }, { name => 'ConsumerCount' },
|
|
{ name => 'ProducerCount' }, { name => 'MemoryPercentUsage' },
|
|
{ name => 'QueueSize' }, { name => 'EnqueueCount' },
|
|
{ name => 'DequeueCount' }, { name => 'ExpiredCount' },
|
|
{ name => 'InFlightCount' }, { name => 'AverageMessageSize' }
|
|
]
|
|
},
|
|
{
|
|
mbean => 'org.apache.activemq:brokerName=*,type=Broker',
|
|
attributes => [
|
|
{ name => 'StorePercentUsage' }, { name => 'TempPercentUsage' },
|
|
{ name => 'MemoryPercentUsage' }
|
|
]
|
|
}
|
|
];
|
|
my $result = $options{custom}->get_attributes(request => $request, nothing_quit => 1);
|
|
|
|
$self->{cache_name} = 'activemq_' . $self->{mode} . '_' . md5_hex($options{custom}->get_connection_info()) . '_' .
|
|
(defined($self->{option_results}->{filter_counters}) ? md5_hex($self->{option_results}->{filter_counters}) : md5_hex('all')) . '_' .
|
|
(defined($self->{option_results}->{filter_broker_name}) ? md5_hex($self->{option_results}->{filter_broker_name}) : md5_hex('all')) . '_' .
|
|
(defined($self->{option_results}->{filter_destination_name}) ? md5_hex($self->{option_results}->{filter_destination_name}) : md5_hex('all')) . '_' .
|
|
(defined($self->{option_results}->{filter_destination_type}) ? md5_hex($self->{option_results}->{filter_destination_type}) : md5_hex('all'));
|
|
|
|
$self->{brokers} = {};
|
|
foreach my $mbean (keys %$result) {
|
|
next if ($mbean !~ /org.apache.activemq:brokerName=(.*?),(?:destinationName=(.*?),destinationType=(.*?),|type=Broker)/);
|
|
my ($broker_name, $destination_name, $destination_type) = ($1, $2, $3);
|
|
|
|
if (defined($self->{option_results}->{filter_broker_name}) && $self->{option_results}->{filter_broker_name} ne '' &&
|
|
$broker_name !~ /$self->{option_results}->{filter_broker_name}/) {
|
|
$self->{output}->output_add(long_msg => "skipping '" . $broker_name . "': no matching filter.", debug => 1);
|
|
next;
|
|
}
|
|
if (defined($self->{option_results}->{filter_destination_type}) && $self->{option_results}->{filter_destination_type} ne '' &&
|
|
$destination_type !~ /$self->{option_results}->{filter_destination_type}/) {
|
|
$self->{output}->output_add(long_msg => "skipping '" . $broker_name . "': no matching filter.", debug => 1);
|
|
next;
|
|
}
|
|
|
|
if (!defined($self->{brokers}->{$broker_name})) {
|
|
$self->{brokers}->{$broker_name} = {
|
|
display => $broker_name,
|
|
queue => {},
|
|
topic => {}
|
|
};
|
|
}
|
|
|
|
if (defined($destination_name)) {
|
|
my $type = lc($destination_type);
|
|
next if ($type ne 'topic' && $type ne 'queue');
|
|
|
|
if (defined($self->{option_results}->{filter_destination_name}) && $self->{option_results}->{filter_destination_name} ne '' &&
|
|
$destination_name !~ /$self->{option_results}->{filter_destination_name}/) {
|
|
$self->{output}->output_add(long_msg => "skipping '" . $destination_name . "': no matching filter.", debug => 1);
|
|
next;
|
|
}
|
|
|
|
$self->{brokers}->{$broker_name}->{$type}->{$destination_name} = {
|
|
display => $destination_name,
|
|
%{$result->{$mbean}}
|
|
};
|
|
} else {
|
|
$self->{brokers}->{$broker_name}->{global} = {
|
|
display => $broker_name,
|
|
%{$result->{$mbean}}
|
|
};
|
|
}
|
|
|
|
}
|
|
|
|
if (scalar(keys %{$self->{brokers}}) <= 0) {
|
|
$self->{output}->output_add(short_msg => 'no brokers found');
|
|
}
|
|
}
|
|
|
|
1;
|
|
|
|
__END__
|
|
|
|
=head1 MODE
|
|
|
|
Check brokers.
|
|
|
|
=over 8
|
|
|
|
=item B<--filter-broker-name>
|
|
|
|
Filter broker name (Can be a regexp).
|
|
|
|
=item B<--filter-destination-name>
|
|
|
|
Filter destination name (Can be a regexp).
|
|
|
|
=item B<--filter-destination-type>
|
|
|
|
Filter destination type (Can be a regexp).
|
|
|
|
=item B<--warning-*> B<--critical-*>
|
|
|
|
Thresholds.
|
|
Can be: 'store-usage' (%), 'temporary-usage' (%), 'memory-usage' (%),
|
|
'queue-average-enqueue-time' (ms), 'queue-consumers-connected',
|
|
'queue-producers-connected', 'queue-memory-usage' (%), 'queue-size',
|
|
'queue-messages-enqueued', 'queue-messages-dequeued', 'queue-messages-expired',
|
|
'queue-messages-inflighted',
|
|
'topic-average-enqueue-time' (ms), 'topic-consumers-connected',
|
|
'topic-producers-connected', 'topic-memory-usage' (%), 'topic-size',
|
|
'topic-messages-enqueued', 'topic-messages-dequeued', 'topic-messages-expired',
|
|
'topic-messages-inflighted'.
|
|
|
|
=back
|
|
|
|
=cut
|