cli,

some refactoring

src/main/java/org/vafer/jmx/Agent.java

@@ -49,14 +49,13 @@ public void stop() {
 
     public static void premain(String args, Instrumentation inst) {
         System.out.println("Starting jmx2any agent");
-        Agent agent = new Agent(args);
-        agent.start();
+        new Agent(args).start();
     }
 
-    public static void main(String[] args) throws Exception {
-        premain("/Users/tcurdt/Projects/jmx2any/config.yaml", null);
-        while(true) {
-            Thread.sleep(10*1000);
-        }
-    }
+//    public static void main(String[] args) throws Exception {
+//        premain("/Users/tcurdt/Projects/jmx2any/config.yaml", null);
+//        while(true) {
+//            Thread.sleep(10*1000);
+//        }
+//    }
 }

src/main/java/org/vafer/jmx/Exporter.java

@@ -1,6 +1,9 @@
 package org.vafer.jmx;
 
 import org.vafer.jmx.output.*;
+import org.vafer.jmx.pipe.CompositePipe;
+import org.vafer.jmx.pipe.ConverterPipe;
+import org.vafer.jmx.pipe.JmxPipe;
 import org.yaml.snakeyaml.Yaml;
 
 import java.io.FileInputStream;

src/main/java/org/vafer/jmx/Main.java

@@ -1,11 +1,34 @@
 package org.vafer.jmx;
 
+import com.beust.jcommander.JCommander;
+import com.beust.jcommander.Parameter;
+
 public final class Main {
 
-    public static void main(String[] args) throws Exception {
+//    @Parameter(names = "-url", description = "jmx url")
+//    private String url = "service:jmx:rmi:///jndi/rmi://localhost:7199/jmxrmi";
+//
+//    @Parameter(names = "-query", description = "query")
+//    private String query = "";
+
+    @Parameter(names = "-config", description = "path to config file", required = true)
+    private String configPath = "";
+
+    private void run() throws Exception {
         Exporter exporter = new Exporter();
-        Exporter.Config config = exporter.load("/Users/tcurdt/Projects/jmx2any/config.yaml");
+        Exporter.Config config = exporter.load(configPath);
         exporter.output(config);
     }
 
+    public static void main(String[] args) throws Exception {
+        Main m = new Main();
+        JCommander cli = new JCommander(m);
+        try {
+            cli.parse(args);
+        } catch(Exception e) {
+            cli.usage();
+            System.exit(1);
+        }
+        m.run();
+    }
 }

src/main/java/org/vafer/jmx/output/OutputFactory.java

@@ -1,11 +1,43 @@
 package org.vafer.jmx.output;
 
+import java.util.Locale;
 import java.util.Map;
 
+import static org.vafer.jmx.output.GangliaOutput.UDPAddressingMode;
+import static org.vafer.jmx.output.GangliaOutput.ProtocolVersion;
+
 public final class OutputFactory {
 
     public static Output createOutput(Map<String, ?> config) {
-        // System.out.println("" + config);
-        return new ConsoleOutput();
+        final String type = ((String) config.get("type")).toLowerCase(Locale.US);
+
+        if ("ganglia".equals(type)) {
+
+            String group = (String) config.get("address");
+            Integer port = (Integer) config.get("port");
+            UDPAddressingMode mode = UDPAddressingMode.valueOf((String)config.get("mode"));
+            ProtocolVersion version = ProtocolVersion.valueOf((String)config.get("version"));
+            return new GangliaOutput(group, port, mode, version);
+
+        } else if ("graphite".equals(type)) {
+
+            String host = (String) config.get("address");
+            Integer port = (Integer) config.get("port");
+            return new GraphiteOutput(host, port);
+
+        } else if ("nagios".equals(type)) {
+
+            return new NagiosOutput();
+
+        } else if ("file".equals(type)) {
+
+            return new FileOutput();
+
+        } else {
+
+            System.err.println("jmx2any: unknown output type [" + type + "]");
+            return new ConsoleOutput();
+
+        }
     }
 }

src/main/java/org/vafer/jmx/output/OutputFilter.java

@@ -2,6 +2,7 @@
 
 import org.vafer.jmx.JmxQuery;
 import org.vafer.jmx.formatter.DefaultFormatter;
+import org.vafer.jmx.pipe.JmxPipe;
 
 import javax.management.AttributeNotFoundException;
 import javax.management.InstanceNotFoundException;

src/main/java/org/vafer/jmx/output/CompositePipe.java → src/main/java/org/vafer/jmx/pipe/CompositePipe.java

@@ -1,4 +1,4 @@
-package org.vafer.jmx.output;
+package org.vafer.jmx.pipe;
 
 import org.vafer.jmx.JmxQuery;
 

src/main/java/org/vafer/jmx/output/ConverterPipe.java → src/main/java/org/vafer/jmx/pipe/ConverterPipe.java

@@ -1,7 +1,9 @@
-package org.vafer.jmx.output;
+package org.vafer.jmx.pipe;
 
 import org.vafer.jmx.JmxQuery;
 import org.vafer.jmx.formatter.DefaultFormatter;
+import org.vafer.jmx.output.Enums;
+import org.vafer.jmx.output.Output;
 
 import java.io.IOException;
 import java.util.List;

src/main/java/org/vafer/jmx/output/JmxPipe.java → src/main/java/org/vafer/jmx/pipe/JmxPipe.java

@@ -1,4 +1,4 @@
-package org.vafer.jmx.output;
+package org.vafer.jmx.pipe;
 
 import org.vafer.jmx.JmxQuery;