Added support for JsonLines to file

Author: danielbodart

src/com/googlecode/utterlyidle/monitoring/CarbonClient.java

@@ -22,7 +22,7 @@ default void close() throws IOException {
     }
 
     static CarbonClient carbonClient(SocketAddress socketAddress, Clock clock) throws IOException {
-        TcpMessenger messenger = new TcpMessenger(SocketChannel.open(socketAddress));
+        ChannelMessenger messenger = ChannelMessenger.tcpMessager(socketAddress);
         return new CarbonClient() {
             @Override
             public void gauge(final String name, final long value) throws IOException {

src/com/googlecode/utterlyidle/monitoring/ChannelMessenger.java

@@ -1,11 +1,21 @@
 package com.googlecode.utterlyidle.monitoring;
 
+import com.googlecode.totallylazy.LazyException;
+
+import java.io.File;
 import java.io.IOException;
+import java.net.SocketAddress;
+import java.nio.channels.DatagramChannel;
+import java.nio.channels.FileChannel;
+import java.nio.channels.SocketChannel;
 import java.nio.channels.WritableByteChannel;
 
 import static com.googlecode.totallylazy.Bytes.bytes;
 import static com.googlecode.totallylazy.Sequences.sequence;
 import static java.nio.ByteBuffer.wrap;
+import static java.nio.file.StandardOpenOption.APPEND;
+import static java.nio.file.StandardOpenOption.CREATE;
+import static java.nio.file.StandardOpenOption.WRITE;
 
 public class ChannelMessenger<C extends WritableByteChannel> implements Messenger {
     protected final C channel;
@@ -23,4 +33,28 @@ public void message(Iterable<? extends String> values) throws IOException {
     public void close() throws IOException {
         channel.close();
     }
+
+    public static ChannelMessenger<DatagramChannel> udpMessager(SocketAddress socketAddress) {
+        try {
+            return new ChannelMessenger<>(DatagramChannel.open().connect(socketAddress));
+        } catch (IOException e) {
+            throw LazyException.lazyException(e);
+        }
+    }
+
+    public static ChannelMessenger<SocketChannel> tcpMessager(SocketAddress socketAddress) {
+        try {
+            return new ChannelMessenger<>(SocketChannel.open(socketAddress));
+        } catch (IOException e) {
+            throw LazyException.lazyException(e);
+        }
+    }
+
+    public static ChannelMessenger<FileChannel> fileMessenger(File file)  {
+        try {
+            return new ChannelMessenger<>(FileChannel.open(file.toPath(), WRITE, APPEND, CREATE));
+        } catch (IOException e) {
+            throw LazyException.lazyException(e);
+        }
+    }
 }

src/com/googlecode/utterlyidle/monitoring/JsonLinesClient.java

@@ -3,9 +3,15 @@
 import com.googlecode.totallylazy.json.Json;
 
 import java.io.Closeable;
+import java.io.File;
 import java.io.IOException;
 import java.net.SocketAddress;
+import java.nio.channels.FileChannel;
 import java.nio.channels.SocketChannel;
+import java.nio.channels.WritableByteChannel;
+
+import static com.googlecode.utterlyidle.monitoring.ChannelMessenger.fileMessenger;
+import static com.googlecode.utterlyidle.monitoring.ChannelMessenger.tcpMessager;
 
 public interface JsonLinesClient extends Closeable {
     void send(Object value) throws IOException;
@@ -15,7 +21,18 @@ default void close() throws IOException {
     }
 
     static JsonLinesClient jsonClient(SocketAddress socketAddress) throws IOException {
-        TcpMessenger messenger = new TcpMessenger(SocketChannel.open(socketAddress));
+        return jsonLinesClient(socketAddress);
+    }
+
+    static JsonLinesClient jsonLinesClient(File file) throws IOException {
+        return jsonLinesClient(fileMessenger(file));
+    }
+
+    static JsonLinesClient jsonLinesClient(SocketAddress socketAddress) throws IOException {
+        return jsonLinesClient(tcpMessager(socketAddress));
+    }
+
+    static JsonLinesClient jsonLinesClient(ChannelMessenger<?> messenger) {
         return new JsonLinesClient() {
             @Override
             public void send(final Object value) throws IOException {
@@ -33,4 +50,5 @@ static JsonLinesClient noOp() {
         return value -> {
         };
     }
+
 }

src/com/googlecode/utterlyidle/monitoring/StatsDClient.java

@@ -5,6 +5,7 @@
 import java.net.InetSocketAddress;
 import java.net.SocketAddress;
 
+import static com.googlecode.utterlyidle.monitoring.ChannelMessenger.udpMessager;
 import static java.lang.String.format;
 
 /**
@@ -16,7 +17,7 @@ static StatsDClient statsDClient(String host, int port) throws IOException {
     }
 
     static StatsDClient statsDClient(SocketAddress socketAddress) throws IOException {
-        return statsDClient(UdpMessenger.udpMessager(socketAddress));
+        return statsDClient(udpMessager(socketAddress));
     }
 
     static StatsDClient statsDClient(final Messenger messenger) {