From f162020eae4c05c48d3af7b56ccbefcad871444c Mon Sep 17 00:00:00 2001 From: Deepak Kaul Date: Mon, 6 Jul 2020 20:42:58 +0000 Subject: Adding in optional protocol variable for rabbitmq export which adds in support for amqps protocol --- glances/exports/glances_rabbitmq.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/glances/exports/glances_rabbitmq.py b/glances/exports/glances_rabbitmq.py index e8f48d1a..2d1d9591 100644 --- a/glances/exports/glances_rabbitmq.py +++ b/glances/exports/glances_rabbitmq.py @@ -44,6 +44,7 @@ class Export(GlancesExport): self.user = None self.password = None self.queue = None + self.protocol = 'amqp' # Optionals configuration keys # N/A @@ -53,7 +54,7 @@ class Export(GlancesExport): mandatories=['host', 'port', 'user', 'password', 'queue'], - options=[]) + options=['protocol']) if not self.export_enable: sys.exit(2) @@ -69,7 +70,8 @@ class Export(GlancesExport): return None try: parameters = pika.URLParameters( - 'amqp://' + self.user + + self.protocol + + '://' + self.user + ':' + self.password + '@' + self.host + ':' + self.port + '/') -- cgit v1.2.3