Sending a request from client factory to server factory running in the same python script

[n-srinidhi]

Hi! Thanks to the pointers in this discussion I now have a single python script housing client factory and server websockets executing concurrently. Now on receiving a message in the server factory, I want to propogate it or send it forward to the client factory within the same script which will in turn send it to an external server. I tried declaring the objects globally:

client_factory = WebSocketClientFactory(url)
client_factory.protocol = ManagerClientProtocol
server_factory = WebSocketServerFactory(url)
server_factory.protocol = EngineServerProtocol

and then in the onMessage event of the server factory, I am trying to use the reactor to sendMessage using the client websocket

reactor.callFromThread(client_factory.protocol.sendMessage(str("SUBSCRIBE|"+_users).encode('utf8')))

And I tried this option
client_factory.protocol.sendMessage(str("SUBSCRIBE|"+_users).encode('utf8'))

Both don't seem to work. How do I go about achieving this? Can I create custom events and then raise them in the server factory so that the callback in the client protocol is called?