提交 f162020e 编写于 作者: D Deepak Kaul

Adding in optional protocol variable for rabbitmq export which adds in support for amqps protocol

上级 b0dc3ff5
......@@ -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 + '/')
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册