Integrating ZeroMQ with Masonite

ZeroMQProvider.py

from masonite.providers import Provider


class ZeroMQProvider(Provider):
    def __init__(self, application):
        self.application = application

    def register(self):
        print("Starting zeromq")
        import zmq

        context = zmq.Context()
        socket = context.socket(zmq.REP)
        socket.bind("tcp://*:5555")

        while True:
            #  Wait for data sent from client
            data = socket.recv()
            print(f"Received request: {message}")

            #  Send reply back to client
            socket.send(b"World {}")

            # With self.application you have access to all Masonite resources.. 
            # Make a queue to receiving data from client zeromq and run some job to make some processing ( persist in database maybe ):
            # self.application.make("queue").push(Job(data))

    def boot(self):
        pass