def write(self, data):

        if len(self._data_queue) >= self.MAXSIZE:
            self._cleanup()

        self._data_queue.append(data)
        self.startWriting()
Adding data to the data_queue to be sent into the pipe.
dataset/ETHPy150Open marineam/nagcat/python/nagcat/nagios_api.py/NagiosWriter.write