Implemented microservice register worker

Author: Relrin

sage_utils/__init__.py

@@ -1,4 +1,4 @@
 __title__ = 'sage-utils'
-__version__ = '0.2.0'
+__version__ = '0.3.0'
 __license__ = 'BSD'
 VERSION = __version__

sage_utils/amqp/workers.py

@@ -0,0 +1,27 @@
+from sage_utils.amqp.base import AmqpWorker
+from sage_utils.amqp.clients import RpcAmqpClient
+
+
+class MicroserviceRegisterWorker(AmqpWorker):
+    REQUEST_QUEUE_NAME = "auth.microservices.register"
+    REQUEST_EXCHANGE_NAME = "open-matchmaking.direct"
+    RESPONSE_EXCHANGE_NAME = "open-matchmaking.responses.direct"
+    CONTENT_TYPE = 'application/json'
+
+    def get_microservice_data(self, app):
+        raise NotImplementedError("The `get_microservice_data(data)` method "
+                                  "must be implemented.")
+
+    async def run(self, *args, **kwargs):
+        client = RpcAmqpClient(
+            self.app,
+            routing_key=self.REQUEST_QUEUE_NAME,
+            request_exchange=self.REQUEST_EXCHANGE_NAME,
+            response_queue='',
+            response_exchange=self.RESPONSE_EXCHANGE_NAME
+        )
+        response = await client.send(self.get_microservice_data(self.app))
+
+        assert 'error' not in response.keys(), response['error']
+        assert 'content' in response.keys()
+        assert response['content'] == 'OK'