in tester/src/main/java/org/apache/james/jspf/tester/TCPListener.java [79:108]
public void run() {
try {
int inLength;
DataInputStream dataIn;
DataOutputStream dataOut;
byte[] in;
InputStream is = serverSocket.getInputStream();
dataIn = new DataInputStream(is);
inLength = dataIn.readUnsignedShort();
in = new byte[inLength];
dataIn.readFully(in);
int length = in.length;
byte[] response = responseGenerator.generateReply(in, length);
if (response == null) return;
dataOut = new DataOutputStream(serverSocket.getOutputStream());
dataOut.writeShort(response.length);
dataOut.write(response);
} catch (IOException e) {
System.out.println("TCPclient("
+ serverSocket.getLocalAddress().getHostAddress() + "#" + serverSocket.getLocalPort()
+ "): " + e);
} finally {
try {
serverSocket.close();
} catch (IOException e) {
}
}
}