ConsoleObserver.java

package fr.cemagref.observation.observers;

import java.awt.Dimension;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.PrintStream;
import java.lang.reflect.InvocationTargetException;

import fr.cemagref.observation.gui.Configurable;
import fr.cemagref.observation.kernel.ObservablesHandler;
import fr.cemagref.observation.kernel.ObserverListener;
import fr.cemagref.ohoui.annotations.Anchor;
import fr.cemagref.ohoui.annotations.Description;
import fr.cemagref.ohoui.annotations.Link;
import fr.cemagref.ohoui.filters.NoTransientField;
import fr.cemagref.ohoui.swing.OhOUI;
import fr.cemagref.ohoui.swing.OhOUIDialog;
import java.io.BufferedOutputStream;
import java.io.FileOutputStream;
import java.util.ArrayList;
import java.util.List;

public class ConsoleObserver implements ObserverListener, Configurable {

    @Description(name = "Use standard output", tooltip = "")
    @Link(action = "disable", target = "filename")
    private boolean sysout = true;
    @Anchor(id = "filename")
    private File outputFile = new File("");
    private transient File outputFileBak = outputFile;
    protected transient PrintStream outputStream = System.out;
    private List<Integer> dates;

    public ConsoleObserver() {
    }

    public ConsoleObserver(boolean sysout, String outputFile) {
        this.sysout = sysout;
        this.outputFile = new File(outputFile);
        this.init();
    }

    @Override
    public void addObservable(ObservablesHandler classObservable) {
        // nothing to do
    }

    protected boolean isInDates(long date) {
        return dates == null || dates.contains((int) date);
    }

    @Override
    public void valueChanged(ObservablesHandler clObservable, Object instance, long t) {
        if (isInDates(t)) {
            StringBuffer buf = new StringBuffer(t + " " + instance.getClass().getName() + " :\n");
            for (int i = 0; i < clObservable.numberOfAttributes(); i++) {
                buf.append("  " + clObservable.getDescription(i) + " = ");
                try {
                    buf.append(clObservable.getObservableFetcher(i).fetchValue(instance));
                } catch (IllegalArgumentException e) {
                    e.printStackTrace();
                } catch (IllegalAccessException e) {
                    e.printStackTrace();
                } catch (InvocationTargetException e) {
                    e.printStackTrace();
                    return;
                }
                if (i < clObservable.numberOfAttributes() - 1) {
                    buf.append("\n");
                }