Fixed issue with initializing the AMQP extension

Author: Relrin

sage_utils/amqp/extension.py

@@ -6,6 +6,7 @@
 
 
 class AmqpExtension(BaseExtension):
+    extension_name = 'amqp'
     app_attribute = 'amqp'
     workers = []
     active_tasks = []
@@ -31,6 +32,7 @@ async def connect(self):
     async def init(self, loop):
         if not hasattr(self.app, 'extensions'):
             setattr(self.app, 'extensions', {})
+        setattr(self.app, self.app_attribute, self)
         self.app.extensions[self.extension_name] = self
 
         for worker in self.workers:
@@ -47,4 +49,4 @@ async def deinit(self, loop):
 
         setattr(self.app, self.app_attribute, None)
         extensions = getattr(self.app, 'extensions', {})
-        extensions.pop(self.extension_name, None)
+        extensions.pop(self.extension_name, None)