package org.openslx.taskmanager.api; import java.util.concurrent.LinkedBlockingQueue; public class BoundedLog extends LinkedBlockingQueue { private static final long serialVersionUID = -5425030291381563963L; public final boolean implicitNewlines; public BoundedLog( int capacity, boolean implicitNewlines ) { super( capacity ); this.implicitNewlines = implicitNewlines; } public void addLog( String data ) { while ( !this.offer( data ) ) { // Throw away oldest entry and try again this.poll(); } } }