Fix for amqps

flower/api/tasks.py

@@ -393,7 +393,7 @@ async def get(self):
         app = self.application
 
         http_api = None
-        if app.transport == 'amqp' and app.options.broker_api:
+        if app.transport in ('amqp','amqps') and app.options.broker_api:
             http_api = app.options.broker_api
 
         broker = Broker(app.capp.connection().as_uri(include_password=True),

flower/utils/broker.py

@@ -20,6 +20,7 @@
 class BrokerBase:
     def __init__(self, broker_url, *_, **__):
         purl = urlparse(broker_url)
+        self.scheme = purl.scheme
         self.host = purl.hostname
         self.port = purl.port
         self.vhost = purl.path[1:]
@@ -40,13 +41,14 @@ def __init__(self, broker_url, http_api, io_loop=None, **__):
         self.io_loop = io_loop or ioloop.IOLoop.instance()
 
         self.host = self.host or 'localhost'
-        self.port = self.port or 15672
+        self.port = self.port or (15671 if self.scheme == 'amqps' else 15672)
         self.vhost = quote(self.vhost, '') or '/' if self.vhost != '/' else self.vhost
         self.username = self.username or 'guest'
         self.password = self.password or 'guest'
 
         if not http_api:
-            http_api = f"http://{self.username}:{self.password}@{self.host}:{self.port}/api/{self.vhost}"
+            http_scheme = 'https' if self.scheme == 'amqps' else 'http'
+            http_api = f"{http_scheme}://{self.username}:{self.password}@{self.host}:{self.port}/api/{self.vhost}"
 
         try:
             self.validate_http_api(http_api)
@@ -228,7 +230,7 @@ def _get_redis_client_args(self):
 class Broker:
     def __new__(cls, broker_url, *args, **kwargs):
         scheme = urlparse(broker_url).scheme
-        if scheme == 'amqp':
+        if scheme in ('amqp','amqps'):
             return RabbitMQ(broker_url, *args, **kwargs)
         if scheme == 'redis':
             return Redis(broker_url, *args, **kwargs)

flower/views/broker.py

@@ -14,7 +14,7 @@ async def get(self):
         app = self.application
 
         http_api = None
-        if app.transport == 'amqp' and app.options.broker_api:
+        if app.transport in ('amqp','amqps') and app.options.broker_api:
             http_api = app.options.broker_api
 
         try: