autobahn_start_AS_two_times.py

#!/usr/bin/env python
# usage: python autobahn_start_AS_two_times.py host port realm

import asyncio
import sys

from autobahn.asyncio.wamp import ApplicationRunner, ApplicationSession


class CheckConnectionSession(ApplicationSession):
    """
    A dummy WAMP Session which disconnect from the server as soon as it joins the
    configured realm.
    """

    async def onJoin(self, details):
        self.leave()
        self.disconnect()

    async def onDisconnect(self):
        loop = asyncio.get_event_loop()
        loop.stop()


def get_wamp_url(host, port):
    """
    :param host: WAMP server host
    :type host: str

    :param port: WAMP server port
    :type port: int

    :return: A url to use with ``Autobahn|Python``
    """
    return f"ws://{host}:{port}/ws"


if __name__ == '__main__':

    url = get_wamp_url(sys.argv[1], sys.argv[2])
    realm = sys.argv[3]

    runner = ApplicationRunner(url, realm)

    loop = asyncio.get_event_loop()

    runner.run(CheckConnectionSession)

    loop.close()

    # Uncomment to make it works
    # if loop.is_closed():
    #     asyncio.set_event_loop(asyncio.new_event_loop())

    runner.run(CheckConnectionSession)

    loop.close()