code: def _receiveFromListener(self, quota: Quota) -> int:
          
          i = 0
          incoming_size = 0
          while i < quota.count and incoming_size < quota.size:
              try:
                  ident, msg = self.listener.recv_multipart(flags=zmq.NOBLOCK)
                  if not msg:
                      # Router probing sends empty message on connection
                      continue
                  incoming_size += len(msg)
                  i += 1
                  self._verifyAndAppend(msg, ident)
              except zmq.Again:
                  break
          if i > 0:
              logger.trace('{} got {} messages through listener'.
                           format(self, i))
          return i
docs: Receives messages from listener
          :param quota: number of messages to receive
          :return: number of received messages