in gflog-sample/src/main/java/com/epam/deltix/gflog/sample/GelfAppenderSample.java [30:56]
private static void launchServer() {
final Thread thread = new Thread("server") {
@Override
public void run() {
try (final ServerSocketChannel server = ServerSocketChannel.open()) {
server.bind(new InetSocketAddress("localhost", 5555));
try (final SocketChannel input = server.accept();) {
final WritableByteChannel output = Channels.newChannel(System.err);
final ByteBuffer buffer = ByteBuffer.allocateDirect(64 * 1024);
while (input.read(buffer) >= 0) {
buffer.flip();
prettify(buffer);
output.write(buffer);
buffer.clear();
}
}
} catch (final Throwable e) {
e.printStackTrace(System.err);
}
}
};
thread.start();
}