twistd_unix_socket_server.py

# Copyright (c) Sandeep Pathivada.

"""
An example unix socket server that sends heartbeat messages.
"""

from twisted.internet.protocol import Factory
from twisted.protocols.basic import LineReceiver
from twisted.internet import reactor, protocol
from twisted.internet.task import LoopingCall


class HeartBeat(LineReceiver):

    def connectionMade(self):
        self.loop = LoopingCall(lambda: self.sendLine("2 seconds have passed"))
        self.loop.start(2, now=True)

    def lineReceived(self, line):
        print('Received: ' + line)
        self.sendLine("Thanks for sending me a message")


def main():
    factory = protocol.ServerFactory()
    factory.protocol = HeartBeat
    reactor.listenUNIX('cfri.sock', factory)
    reactor.run()

if __name__ == '__main__':
    main()