Я следую основным примерам pubsub для wamp в github код:
В этом примере публикуются сообщения из класса:
class Component(ApplicationSession):
"""
An application component that publishes an event every second.
"""
def __init__(self, realm = "realm1"):
ApplicationSession.__init__(self)
self._realm = realm
def onConnect(self):
self.join(self._realm)
@inlineCallbacks
def onJoin(self, details):
counter = 0
while True:
self.publish('com.myapp.topic1', counter)
counter += 1
yield sleep(1)
Я хочу создать ссылку, чтобы я мог публиковать сообщения через это соединение из другого места в коде, то есть myobject.myconnection.publish('com.myapp.topic1', 'My message')
На этот аналогичный вопрос ответ кажется чтобы это было при подключении, мне нужно установить что-то вроде self.factory.myconnection = self
. Я пробовал несколько вариантов этого безуспешно.
Часть заводской настройки приведена ниже:
## create a WAMP application session factory
##
from autobahn.twisted.wamp import ApplicationSessionFactory
session_factory = ApplicationSessionFactory()
## .. and set the session class on the factory
##
session_factory.session = Component
## create a WAMP-over-WebSocket transport client factory
##
from autobahn.twisted.websocket import WampWebSocketClientFactory
transport_factory = WampWebSocketClientFactory(session_factory, args.wsurl, debug = args.debug)
transport_factory.setProtocolOptions(failByDrop = False)
## start a WebSocket client from an endpoint
##
client = clientFromString(reactor, args.websocket)
client.connect(transport_factory)
Куда будет прикреплена какая-либо ссылка, которую я установил из класса? к client
? к transport_factory
? к session_factory
?