'The PUSH socket for use in the zmq message destructor callback.'

@property
def _push_socket(self):

    if ((not self.is_alive()) or (self._push is None)):
        self._push = self.context.socket(zmq.PUSH)
        self._push.connect(self.url)
    return self._push
