Aiohttp-crossbar integration



i need to integrate a microservice based on aiohttp in an architecture which uses Crossbar as a pub-sub router.

Basically, i would like to do something like:

# class SampleTaskController(object):
async def handle_get_request(self, request: web.Request) -> web.Response:
    self.publisher.publish('com.myapp.topic1', 'Hello World!')
    return web.HTTPOk()

where handle_get_request is an handler for a route of my aiohttp web server.

How can i achieve that? I’ve looked at the examples on GitHub but they rely on the ApplicationRunner.

A more detailed description of my problem can be found on