Searched refs:outputQueue (Results 1 – 1 of 1) sorted by relevance
90 private final BlockingQueue<StreamItem> outputQueue = Queues.newLinkedBlockingQueue(); field in StreamService196 StreamItem line = outputQueue.poll(timeout, unit); in readItem()286 outputQueue.add(EOF_ITEM); in closeReadStream()374 outputQueue.put(new StreamItem(logMessage));418 outputQueue.put(new StreamItem(message));