commit 08b126e558d757ffa83099948d03c203cfb68fae
Author: Matthias Runge <mrunge@redhat.com>
Date:   Tue Oct 6 17:46:55 2020 +0200

    Add amqp send queue limit for collectd
    
    send_queue_limit was added recently to puppet-collectd and
    will be available in puppet-collectd-12.2
    
    Change-Id: Ida812cdbe5141ff91a7db7c46e422f86fb762f98

diff --git a/Puppetfile_extras b/Puppetfile_extras
index 67974fa..a948b6b 100644
--- a/Puppetfile_extras
+++ b/Puppetfile_extras
@@ -65,10 +65,9 @@ mod 'pacemaker',
   :git => 'https://github.com/openstack/puppet-pacemaker',
   :ref => 'master'
 
-# NOTE(tkajinam): Pinnned due to LP#1862434
 mod 'collectd',
   :git => 'https://github.com/voxpupuli/puppet-collectd',
-  :ref => '25904923910c6e3316d762a1817fc10313b9ca21'
+  :ref => '20494e44a90073273a18fce71f4a602d5b5d0690'
 
 # see https://github.com/rdo-packages/puppet-keepalived-distgit/blob/rpm-master/puppet-keepalived.spec
 mod 'keepalived',
diff --git a/manifests/profile/base/metrics/collectd.pp b/manifests/profile/base/metrics/collectd.pp
index effabc0..4344c36 100644
--- a/manifests/profile/base/metrics/collectd.pp
+++ b/manifests/profile/base/metrics/collectd.pp
@@ -201,6 +201,11 @@
 #  as the send-to address for communications over the messaging link.
 #  Defaults to {}.
 #
+# [*amqp_send_queue_limit*]
+#  (Optional) Number. Number of data sets to be kept in memory, older sets
+#  will be discarded; if set to undef, this feature is disabled.
+#  Defaults to undef
+#
 # [*qdr_mode*]
 #  (Optional) String. Mode in which the QDR service, to which collectd
 #  should be connected, is running.
@@ -254,6 +259,7 @@ class tripleo::profile::base::metrics::collectd (
   $amqp_instances = {},
   $amqp_retry_delay = undef,
   $amqp_interval = undef,
+  $amqp_send_queue_limit = undef,
   $qdr_mode = hiera('tripleo::profile::base::metrics::qdr::router_mode', 'edge'),
   $service_names = hiera('service_names', []),
   $collectd_manage_repo = false,
@@ -326,17 +332,18 @@ class tripleo::profile::base::metrics::collectd (
       }
     } elsif !empty($amqp_host) {
       class { 'collectd::plugin::amqp1':
-        ensure         => 'present',
-        manage_package => true,
-        transport      => $amqp_transport_name,
-        host           => $amqp_host,
-        port           => $amqp_port,
-        user           => $amqp_user,
-        password       => $amqp_password,
-        address        => $amqp_address,
-        instances      => $amqp_instances,
-        retry_delay    => $amqp_retry_delay,
-        interval       => $amqp_interval,
+        ensure           => 'present',
+        manage_package   => true,
+        transport        => $amqp_transport_name,
+        host             => $amqp_host,
+        port             => $amqp_port,
+        user             => $amqp_user,
+        password         => $amqp_password,
+        address          => $amqp_address,
+        instances        => $amqp_instances,
+        retry_delay      => $amqp_retry_delay,
+        interval         => $amqp_interval,
+        send_queue_limit => $amqp_send_queue_limit,
       }
     } elsif !empty($gnocchi_server) or !empty($gnocchi_keystone_auth_url) {
       if !empty($gnocchi_server) {