def METHOD_NAME(self):
    logger.debug('Queue._after_fork()')
    self._closed = False
    self._close = None
    self._send_bytes = self._writer.send_bytes
    self._recv_bytes = self._reader.recv_bytes
    self._poll = self._reader.poll