def METHOD_NAME(self):
    push = self.context.socket(zmq.PUSH)
    push.connect(self.url)
    push.send(b'DIE')
    push.close()
    if self._push:
        self._push.close()
    self.thread.join()
    self.context.term()
    self._clear()