Threading: sendMessage at onMessage

[Alejandro Torrado]

Hi, I'm implementing Autobahn with user actions handled in web,
triggered by the back-end in python. Because of the nature of user
actions, these are executed in separated threads for separated users.

The code looks something like this:

def onMessage(self, msg, binary):
class ActionThread(CThread):
def __init__(self, protocol):
self.protocol = protocol
def run(self):
.......
print 1
self.protocol.sendMessage("something")
print 2
.......
ActionThread(self).start()

Doing this, the message "something" isn't delivered even though 1 and
2 are printed to console. Then, when the user sends another message to
the server, the first message arrives.

How can I fix this? Thanks!

[Tobias Oberstein]

try:

reactor.callFromThread(self.protocol.sendMessage, "something")

see:

https://github.com/oberstet/Autobahn/issues/90

and search for similar posts on this list or

checkout the Twisted docs on callFromThread etc.

[Alejandro Torrado]

Thanks a lot! Worked like a charm!