tomd: specify encoding to use when sending data to StatsD. Sadly, StatsD does not specify an encoding and relies on the Node.JS Buffer class defailt of UTF-8, so we have to assume this is what they would choose were an explicit encoding be specified in the future. Fixes #18

Author: scarytom

build.xml

@@ -68,6 +68,7 @@
         <mkdir dir="${build.dir}/testreport"/>
         <mkdir dir="${build.dir}/test.tmp"/>
         <junit printsummary="yes" haltonfailure="yes" forkmode="once" tempdir="${build.dir}/test.tmp">
+            <jvmarg value="-Dfile.encoding=UTF-16"/>
             <classpath>
               <pathelement location="${build.dir}/${ant.project.name}-${version.label}.jar"/>
               <pathelement location="${build.dir}/${ant.project.name}-test-${version.label}.jar"/>

src/main/java/com/timgroup/statsd/NonBlockingStatsDClient.java

@@ -3,6 +3,7 @@
 import java.net.DatagramPacket;
 import java.net.DatagramSocket;
 import java.net.InetSocketAddress;
+import java.nio.charset.Charset;
 import java.util.Locale;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -37,6 +38,8 @@
  */
 public final class NonBlockingStatsDClient extends ConvenienceMethodProvidingStatsDClient {
 
+    private static final Charset STATS_D_ENCODING = Charset.forName("UTF-8");
+
     private static final StatsDClientErrorHandler NO_OP_HANDLER = new StatsDClientErrorHandler() {
         @Override public void handle(Exception e) { /* No-op */ }
     };
@@ -228,7 +231,7 @@ private void send(final String message) {
 
     private void blockingSend(String message) {
         try {
-            final byte[] sendData = message.getBytes();
+            final byte[] sendData = message.getBytes(STATS_D_ENCODING);
             final DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length);
             clientSocket.send(sendPacket);
         } catch (Exception e) {

src/test/java/com/timgroup/statsd/NonBlockingStatsDClientTest.java

@@ -9,6 +9,7 @@
 import java.net.DatagramPacket;
 import java.net.DatagramSocket;
 import java.net.SocketException;
+import java.nio.charset.Charset;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.regex.Matcher;
@@ -193,7 +194,7 @@ public DummyStatsDServer(int port) {
                     try {
                         final DatagramPacket packet = new DatagramPacket(new byte[256], 256);
                         server.receive(packet);
-                        messagesReceived.add(new String(packet.getData()).trim());
+                        messagesReceived.add(new String(packet.getData(), Charset.forName("UTF-8")).trim());
                     } catch (Exception e) { }
                 }
             }).start();