summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDeepak Kaul <deepak.b.kaul@gmail.com>2020-07-06 20:42:58 +0000
committerDeepak Kaul <deepak.b.kaul@gmail.com>2020-07-06 20:42:58 +0000
commitf162020eae4c05c48d3af7b56ccbefcad871444c (patch)
treebaabd5d6a427ed506c78777c45dd6fc979f6e881
parentb0dc3ff54e04636cc5efba0d7600daaf5c1d9215 (diff)
Adding in optional protocol variable for rabbitmq export which adds in support for amqps protocol
-rw-r--r--glances/exports/glances_rabbitmq.py6
1 files 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 + '/')