-
Notifications
You must be signed in to change notification settings - Fork 0
/
counter.py
40 lines (29 loc) · 1.12 KB
/
counter.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
# coding: utf-8
from __future__ import unicode_literals
from twisted.internet.defer import inlineCallbacks
from autobahn.twisted.util import sleep
from autobahn.twisted.wamp import ApplicationSession
from autobahn.twisted.wamp import ApplicationRunner
from config.settings import REALM_NAME, WEB_SOCKET_HOST, WEB_SOCKET_PORT
class ListenForEvent(ApplicationSession):
def __init__(self, config):
ApplicationSession.__init__(self)
self.config = config
def onConnect(self):
print("connected")
self.join(self.config.realm)
@inlineCallbacks
def onJoin(self, details):
# callback = lambda x: log.msg("Received event %s" % x)
# yield self.subscribe(callback, 'un_evenement')
print("session ready")
counter = 0
while True:
self.publish('com.messaging.demo', counter)
counter += 1
yield sleep(1)
# Python doesn't have a default event loop, so
# we need to start one
if __name__ == '__main__':
runner = ApplicationRunner("ws://%s:%d/ws" % (WEB_SOCKET_HOST, WEB_SOCKET_PORT), REALM_NAME)
runner.run(ListenForEvent)