code: def get_rmq_cluster_status(self, sentry_unit):
          
          cmd = 'rabbitmqctl cluster_status'
          output, _ = self.run_cmd_unit(sentry_unit, cmd)
          self.log.debug('{} cluster_status:\n{}'.format(
              sentry_unit.info['unit_name'], output))
          return str(output)
docs: Execute rabbitmq cluster status command on a unit and return
          the full output.
  
          :param unit: sentry unit
          :returns: String containing console output of cluster status command