from txsockjs_client import SockJS
from twisted.internet import defer, reactor

@defer.inlineCallbacks
def helloSockJS():
    client = SockJS('/echo', host='127.0.0.1', port=5000)
    yield client.send('Hello SockJS')
    yield client.close()

    if reactor.running:
        reactor.stop()

if __name__ == '__main__':
    helloSockJS()
    reactor.run()

class SockJSClient(SockJS):
    def onOpen(self):
        print '[OPEN]'

    def onError(self, reason):
        print '[ERROR]: %s' % reason

    def onClose(self, wasClean, code, reason):
        print '[CLOSE]: %s' % reason

    def onMessage(self, message, isBinary):
        print '[MESSAGE]: %s' % message

client = SockJSClient('/echo')

client.factory.retry()