Source code for txzmq.pushpull

"""
ZeroMQ PUSH-PULL wrappers.
"""
from zmq import constants

from txzmq.connection import ZmqConnection


class ZmqPushConnection(ZmqConnection):
    """
    Pushing messages to the socket.

    Wrapper around ZeroMQ PUSH socket.
    """
    socketType = constants.PUSH

    def push(self, message):
        """
        Push a message L{message}.

        :param message: message data
        :type message: str
        """
        self.send(message)


class ZmqPullConnection(ZmqConnection):
    """
    Pull messages from a socket.

    Wrapper around ZeroMQ PULL socket.

    Subclass and override :meth:`onPull`.
    """
    socketType = constants.PULL

    def messageReceived(self, message):
        """
        Called on incoming message from ZeroMQ.

        :param message: message data
        """
        self.onPull(message)

    def onPull(self, message):
        """
        Called on incoming message received by puller.

        :param message: message data
        """
        raise NotImplementedError(self)