clearlinux/clearstack
2
0
Fork 0
mirror of https://github.com/clearlinux/clearstack.git synced 2026-06-15 18:46:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

Improve debug messages for the rabbitmq setup

Browse Source 
Signed-off-by: Simental Magana, Marcos <marcos.simental.magana@intel.com>
This commit is contained in:
Simental Magana, Marcos
2016-01-27 15:18:18 -06:00
parent c917497510
commit a9cdc41794
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
clearstack/modules/rabbitmq.py
+7 -4
View File
@@ -35,37 +35,40 @@ class Rabbitmq:
stdout = None
stderr = None
try:
LOG.debug("Checking if rabbitmq user '{0}' exists".format(user))
stdout, stderr = util.run_command("rabbitmqctl list_users"
" | grep {0}".format(user))
except:
pass
if not stdout:
LOG.debug("rabbitmq user '{0}' does not exists".format(user))
return False
LOG.debug("rabbitmq user '{0}' does exists".format(user))
return True
def install(self):
swupd_client.install("message-broker-rabbitmq")
def start_server(self):
LOG.debug("starting services")
LOG.debug("starting rabbitmq-server service")
util.run_command("systemctl enable rabbitmq-server")
util.run_command("systemctl restart rabbitmq-server")
def add_user(self, auth_user, auth_pw):
""" todo: what we do with guest """
LOG.debug("adding user")
LOG.debug("adding rabbitmq user '{0}'".format(auth_user))
if not self.user_exists(auth_user):
util.run_command("rabbitmqctl add_user {0} {1}"
.format(auth_user, auth_pw), debug=False)
def delete_user(self, user):
LOG.debug("deleting user")
LOG.debug("deleting rabbitmq user '{0}'".format(user))
util.run_command("rabbitmqctl delete_user {1}"
.format(user))
def set_permissions(self, auth_user, permissions):
LOG.debug("setting permissions")
LOG.debug("setting rabbitmq permissions for user '{0}'".format(auth_user))
util.run_command("rabbitmqctl set_permissions {0} {1}"
.format(auth_user, permissions))