Source code for aj.plugins.core.api.push
from jadi import service
from aj.util import BroadcastQueue
[docs]@service
class Push():
"""
A service providing push messages to the client.
"""
def __init__(self, context):
self.q = BroadcastQueue()
[docs] def register(self):
return self.q.register()
[docs] def push(self, plugin, msg):
"""
Sends a push message to the client.
:param plugin: routing ID
:param msg: message
"""
self.q.broadcast((plugin, msg))
Comments
comments powered by