Sample WAMP subscriber

subscriber.py

# Install asphalt-wamp first:
# pip install git+https://github.com/asphalt-framework/asphalt-wamp.git@932183440a064
from pprint import pprint

from asphalt.core import Context, run_application, ContainerComponent


def handle_event(ctx, event):
    pprint(event)


class SubscriberComponent(ContainerComponent):
    async def start(self, ctx: Context):
        self.add_component('wamp', host='localhost', port=8800, realm='myrealm')
        await super().start(ctx)

        await ctx.wamp.subscribe(handle_event, 'some.topic')

run_application(SubscriberComponent())