Cleanup imports

Author: iksaif

README.md

@@ -23,13 +23,32 @@ The client jar is distributed via Maven central, and can be downloaded [from Mav
 
 ### Unix Domain Socket support
 
-As an alternative to UDP, Agent v6 can receive metrics via a UNIX Socket (on Linux only). This library supports transmission via this protocol. To use it, pass the socket path as a hostname, and `0` as port.
+As an alternative to UDP, Agent v6 can receive metrics via a UNIX Socket (on Linux only). This library supports transmission via this protocol. To use it, pass the socket path as a hostname, and `0` as port
+or use the `socket()` method of the builder.
+
+```java
+StatsDClient client = new NonBlockingStatsDClientBuilder()
+    .hostname("/var/run/datadog/dsd.socket")
+    .port(0) // Necessary for unix socket
+    .build();
+```
+
+or
+
+```java
+StatsDClient client = new NonBlockingStatsDClientBuilder()
+    .socket("/var/run/datadog/dsd.socket")
+    .build();
+```
 
 By default, all exceptions are ignored, mimicking UDP behaviour. When using Unix Sockets, transmission errors trigger exceptions you can choose to handle by passing a `StatsDClientErrorHandler`:
 
 - Connection error because of an invalid/missing socket triggers a `java.io.IOException: No such file or directory`.
 - If DogStatsD's reception buffer were to fill up and the non blocking client is used, the send times out after 100ms and throw either a `java.io.IOException: No buffer space available` or a `java.io.IOException: Resource temporarily unavailable`.
 
+The default UDS transport is using `SOCK_DATAGRAM` sockets. We also have experimental support for `SOCK_STREAM` sockets which can
+be enabled by using the `socket()` method of the builder. This is not recommended for production use at this time.
+
 ## Configuration
 
 Once your DogStatsD client is installed, instantiate it in your code:

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

@@ -1,10 +1,8 @@
 package com.timgroup.statsd;
 
 import java.io.IOException;
-import java.nio.Buffer;
 import java.nio.ByteBuffer;
 import java.nio.channels.DatagramChannel;
-import java.nio.charset.StandardCharsets;
 import jnr.unixsocket.UnixDatagramChannel;
 import jnr.unixsocket.UnixSocketAddress;
 

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

@@ -1,11 +1,6 @@
 package com.timgroup.statsd;
 
-import java.net.SocketAddress;
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.concurrent.Callable;
 import java.util.logging.Logger;
-import jnr.unixsocket.UnixSocketAddress;
 import org.junit.After;
 import org.junit.Assume;
 import org.junit.Before;
@@ -14,10 +9,7 @@
 import java.io.IOException;
 import java.io.File;
 import java.nio.file.Files;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
 
-import static org.hamcrest.CoreMatchers.anyOf;
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.contains;
 import static org.hamcrest.Matchers.nullValue;

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

@@ -1,19 +1,12 @@
 package com.timgroup.statsd;
 
-import com.sun.xml.internal.ws.api.message.Packet;
 import java.io.IOException;
 import java.nio.Buffer;
 import java.nio.ByteBuffer;
 import java.nio.ByteOrder;
-import java.nio.channels.SelectionKey;
 import java.nio.channels.SocketChannel;
-import java.nio.channels.spi.AbstractSelector;
-import java.nio.charset.StandardCharsets;
-import java.util.ArrayList;
-import java.util.List;
 import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.logging.Logger;
-import jnr.enxio.channels.NativeSelectorProvider;
 import jnr.unixsocket.UnixServerSocketChannel;
 import jnr.unixsocket.UnixSocketAddress;
 import jnr.unixsocket.UnixSocketChannel;
@@ -23,7 +16,6 @@
 public class UnixStreamSocketDummyStatsDServer extends DummyStatsDServer {
     private final UnixServerSocketChannel server;
     private final ConcurrentLinkedQueue<UnixSocketChannel> channels = new ConcurrentLinkedQueue<>();
-    private final ConcurrentLinkedQueue<Packet> packets = new ConcurrentLinkedQueue<>();
 
     private final Logger logger = Logger.getLogger(UnixStreamSocketDummyStatsDServer.class.getName());
 

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

@@ -1,9 +1,6 @@
 package com.timgroup.statsd;
 
-import java.net.SocketAddress;
-import java.util.concurrent.Callable;
 import java.util.logging.Logger;
-import jnr.unixsocket.UnixSocketAddress;
 import org.junit.After;
 import org.junit.Assume;
 import org.junit.Before;