UDP Java server (incomplete example for a blog post)

UdpBenchmarkServer.java

public class UdpBenchmarkServer implements Runnable {

    public static void main(String[] args) throws Exception {

        // Start service
        UdpBenchmarkServer server = new UdpBenchmarkServer(SERVER_PORT);
        Thread thread = new Thread(server);
        thread.setDaemon(true);
        thread.start();

        // Periodically persist buffered data to disk
        FileChannel fileChannel = new FileOutputStream("output.bin").getChannel();
        while (true) {
            server.log.writeTo(fileChannel);
            Silencer.sleepMillis(1000);
        }

    }

    public UdpBenchmarkServer(int port) throws IOException {

        // Setup channel
        channel = DatagramChannel.open(StandardProtocolFamily.INET);
        channel.setOption(StandardSocketOptions.SO_RCVBUF, DEFAULT_BUFFER_SIZE);
        channel.setOption(StandardSocketOptions.SO_SNDBUF, DEFAULT_BUFFER_SIZE);
        channel.setOption(StandardSocketOptions.SO_BROADCAST, true);
        channel.configureBlocking(true);

        // Bind to local port
        final InetAddress ANY_IP = null;
        channel.bind(new InetSocketAddress(ANY_IP, port));

    }

    @Override
    public void run() {

        Thread.currentThread().setPriority(Thread.MAX_PRIORITY - 1);
        final ByteBuffer rxBuffer = ByteBuffer.allocateDirect(DEFAULT_BUFFER_SIZE);
        rxBuffer.order(ByteOrder.LITTLE_ENDIAN);

        while (true) {
            try {

                // Receive timings via UDP message
                InetSocketAddress source = (InetSocketAddress) channel.receive(rxBuffer);

                // Add local meta data
                rxBuffer.putLong(System.nanoTime());
                rxBuffer.putLong(System.currentTimeMillis());
                rxBuffer.putLong(coerceToLong(source));

                // Add received data to buffer to be persistet (wait-free)
                rxBuffer.flip();
                log.put(rxBuffer);
                rxBuffer.clear();

            } catch (IOException e) {
                e.printStackTrace();
            }

        }

    }

    final DatagramChannel channel;
    final int DEFAULT_BUFFER_SIZE = 16 * 1024; // 16 KB
    final SingleWriterLog log = new SingleWriterLog(DEFAULT_BUFFER_SIZE * 1024);

}