diff options
author | Deepak Kaul <deepak.b.kaul@gmail.com> | 2020-07-06 20:42:58 +0000 |
---|---|---|
committer | Deepak Kaul <deepak.b.kaul@gmail.com> | 2020-07-06 20:42:58 +0000 |
commit | f162020eae4c05c48d3af7b56ccbefcad871444c (patch) | |
tree | baabd5d6a427ed506c78777c45dd6fc979f6e881 | |
parent | b0dc3ff54e04636cc5efba0d7600daaf5c1d9215 (diff) |
Adding in optional protocol variable for rabbitmq export which adds in support for amqps protocol
-rw-r--r-- | glances/exports/glances_rabbitmq.py | 6 |
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 + '/') |