class Pipe extends Observable {

    public boolean isLiquidEntering() {
        return queue.peekLast() != null && queue.peekLast().getAmount() != 0;
    }

    public  Pipe(float crosssection, int length, byte defaultThreshold);

}