Как отправить работающим работникам в Намеко? - PullRequest
0 голосов
/ 01 октября 2018

У меня есть служба веб-сокетов, которая открывает поток, принимает сообщения и т. Д. Я могу создать обработчик событий, который открывает новое соединение, но он не работает для будущих событий.Они будут обрабатываться новым работником, так как взаимодействовать с работающими работниками / зелеными нитями?

class ServiceA:
    """ Event dispatching service. """
    name = "service_a"

    dispatch = EventDispatcher()

    @rpc
    def dispatching_method(self, payload):
        self.dispatch("start_socket", payload)


class ServiceB:
    """ Event listening service. """
    name = "service_b"

    @event_handler("service_a", "start_socket")
    def start_socket(url):
        sock = websocket.start_socket(url)
        gr = eventlet.spawn(sock.run_forever)  

Как мне взаимодействовать с sock или gr из ServiceA после вызова start_socket()?

...