net.sf.xenqtt.test
Class NonBlockingTcpEchoServer

java.lang.Object
  net.sf.xenqtt.test.NonBlockingTcpEchoServer

public class NonBlockingTcpEchoServer
extends Object

Server that uses non-blocking IO to accept new connections and echo any data received back to the sender. The data must be in this format:

• First 2 bytes: big endian length of the remaining paylaod
• Remaining bytes: payload

Nested Class Summary

static class

AbstractNonBlockingConnectionManager.ChannelInfo

Method Summary

static void	main(String[] args)
void	newConnection(SocketChannel channel)
void	send(ByteBuffer buffer)
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

main

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

Throws:

Exception

start

public void start()

newConnection

public void newConnection(SocketChannel channel)
                   throws IOException

Throws:

IOException

send

public final void send(ByteBuffer buffer)