source: java/main/src/main/java/com/framsticks/diagnostics/DiagnosticsEndpoint.java @ 85

package com.framsticks.diagnostics;

import com.framsticks.core.Instance;
import com.framsticks.dumping.PrintWriterSink;
import com.framsticks.dumping.SaveStream;
import com.framsticks.observers.Endpoint;
import com.framsticks.remote.RecursiveFetcher;
import com.framsticks.util.Logging;
import com.framsticks.util.PeriodicTask;
import com.framsticks.util.StateFunctor;
import com.framsticks.util.io.Encoding;

import org.apache.log4j.Logger;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * @author Piotr Sniegowski
 */
public class DiagnosticsEndpoint extends Endpoint {

        private final static Logger log = Logger.getLogger(DiagnosticsEndpoint.class.getName());

        public DiagnosticsEndpoint() {
                super();
        }

        @Override
        public Diagnostics getObserver() {
                return (Diagnostics)observer;
        }


        @Override
        public void start() {
                super.start();

                if (getObserver().dumpsInterval != null) {
                        new PeriodicTask<Instance>(instance, getObserver().dumpsInterval * 1000) {
                                @Override
                                public void run() {

                                        log.info("starting periodic dump");
                                        new RecursiveFetcher(instance, instance.getRootPath(), new StateFunctor() {
                                                @Override
                                                public void call(Exception e) {
                                                        if (Logging.log(log, "recursively fetch", instance, e)) {
                                                                again();
                                                                return;
                                                        }
                                                        log.info("instance resolved, saving");
                                                        try {
                                                                final String fileName = getObserver().dumpsPath + "/" + instance + "_" + new SimpleDateFormat(getObserver().dumpsFormat).format(new Date()) + ".param";
                                                                File file = new File(fileName);
                                                                new SaveStream(new PrintWriterSink(new PrintWriter(new OutputStreamWriter(new FileOutputStream(file), Encoding.getFramsticksCharset()))), instance, instance.getRootPath(), new StateFunctor() {
                                                                        @Override
                                                                        public void call(Exception e) {
                                                                                Logging.log(log, "periodic dump in " + fileName + " of", DiagnosticsEndpoint.this.instance, e);
                                                                                again();
                                                                        }
                                                                });
                                                        } catch (IOException ex) {
                                                                log.info("failed to initiate dump: " + ex);
                                                                again();
                                                        }

                                                }
                                        });


                                }
                        };
                }
        }

        /*
        @Override
        public void onChange(Path path) {
                super.onChange(path);    //To change body of overridden methods use File | Settings | File Templates.
        }
        */
}