Improve redirection of logs

PoDiGG · Mar 23, 2017 · ac21d5c · ac21d5c
1 parent a2f53d6
commit ac21d5c
Showing 1 changed file with 14 additions and 7 deletions.
diff --git a/src/main/java/org/hobbit/podigg/PodiggGenerator.java b/src/main/java/org/hobbit/podigg/PodiggGenerator.java
@@ -19,18 +19,21 @@ public class PodiggGenerator extends AbstractComponent {
 
     public static final String DEFAULT_QUEUE_NAME = "hobbit.podigg.queuename";
 
+    protected void generate() throws Exception {
+        // Call the generator
+        FileUtils.forceMkdir(new File("output_data"));
+        String memory = System.getenv().getOrDefault("NODE_MEM", "2056");
+        ProcessBuilder processBuilder = new ProcessBuilder("node", "--max_old_space_size=" + memory, "bin/generate-env", "output_data");
+        processBuilder.inheritIO();
+        processBuilder.start().waitFor();
+    }
+
     @Override
     public void run() throws Exception {
         String queueName = System.getenv().getOrDefault(Constants.DATA_QUEUE_NAME_KEY, DEFAULT_QUEUE_NAME);
         SimpleFileSender sender = SimpleFileSender.create(this, queueName);
 
-        // Call the generator
-        FileUtils.forceMkdir(new File("output_data"));
-        String memory = System.getenv().getOrDefault("NODE_MEM", "2056");
-        Process process = Runtime.getRuntime().exec("node --harmony_destructuring --max_old_space_size=" + memory + " bin/generate-env output_data");
-        process.waitFor();
-        System.err.println(IOUtils.toString(process.getErrorStream()));
-        System.out.println(IOUtils.toString(process.getInputStream()));
+        generate();
 
         // Forward the output
         InputStream is = new FileInputStream("output_data/lc.ttl");
@@ -42,4 +45,8 @@ public void run() throws Exception {
             IOUtils.closeQuietly(is);
         }
     }
+
+    public static void main(String[] args) throws Exception {
+        new PodiggGenerator().generate();
+    }
 }