- Timestamp:
- 06/24/13 13:38:40 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/diagnostics/DiagnosticsEndpoint.java
r84 r85 1 1 package com.framsticks.diagnostics; 2 2 3 import com.framsticks.core.Instance; 3 4 import com.framsticks.dumping.PrintWriterSink; 4 5 import com.framsticks.dumping.SaveStream; … … 8 9 import com.framsticks.util.PeriodicTask; 9 10 import com.framsticks.util.StateFunctor; 11 import com.framsticks.util.io.Encoding; 12 10 13 import org.apache.log4j.Logger; 11 14 12 15 import java.io.File; 16 import java.io.FileOutputStream; 13 17 import java.io.IOException; 18 import java.io.OutputStreamWriter; 14 19 import java.io.PrintWriter; 15 20 import java.text.SimpleDateFormat; … … 22 27 23 28 private final static Logger log = Logger.getLogger(DiagnosticsEndpoint.class.getName()); 24 25 29 26 30 public DiagnosticsEndpoint() { … … 39 43 40 44 if (getObserver().dumpsInterval != null) { 41 new PeriodicTask (instance, getObserver().dumpsInterval * 1000) {45 new PeriodicTask<Instance>(instance, getObserver().dumpsInterval * 1000) { 42 46 @Override 43 47 public void run() { … … 55 59 final String fileName = getObserver().dumpsPath + "/" + instance + "_" + new SimpleDateFormat(getObserver().dumpsFormat).format(new Date()) + ".param"; 56 60 File file = new File(fileName); 57 new SaveStream(new PrintWriterSink(new PrintWriter( file)), instance, instance.getRootPath(), new StateFunctor() {61 new SaveStream(new PrintWriterSink(new PrintWriter(new OutputStreamWriter(new FileOutputStream(file), Encoding.getFramsticksCharset()))), instance, instance.getRootPath(), new StateFunctor() { 58 62 @Override 59 63 public void call(Exception e) {
Note: See TracChangeset
for help on using the changeset viewer.