Distribution EOLE

import asyncio

from os import environ

from autobahn.asyncio.wamp import ApplicationSession, ApplicationRunner

class Component(ApplicationSession):

    """

    An application component that publishes an event every second.

    """

    async def onJoin(self, details):

        def update_variable(variable, value=0):

            result = 'update {} with {}'.format(variable, value)

            print(result)

            self.publish(u'com.myapp.cipot1', "le microservice1 a fait modifier {} avec {}".format(variable, value))

            return "Variable updated"

        #counter = 0

        #dico = {}

        await self.register(update_variable, u'com.myapp.update_variable')

        #while True:

        #    print("publish: com.myapp.cipot1", dico)

        #    self.publish(u'com.myapp.cipot1', dico)

        #    dico.update({counter: counter})

        #    counter += 1

        #    await asyncio.sleep(1)

if __name__ == '__main__':

    runner = ApplicationRunner(

        environ.get("AUTOBAHN_DEMO_ROUTER", u"ws://127.0.0.1:8080/ws"),

        u"realm1",

    )

    runner.run(Component)