Element elt = doc.createElement("Collector");
elt.setAttribute("address", "localhost");
elt.setAttribute("port", "10000");
ServerSocketCollector collector = new ServerSocketCollector(elt);
assertTrue(collector.isRunning());
collector.addListener(this);
// Send a packet
line = null;
String test = "This is a test\n";
InetAddress addr = InetAddress.getLocalHost();
InetSocketAddress sockaddr = new InetSocketAddress(addr, 10000);
Socket sock = new Socket();
sock.connect(sockaddr, 2000); // 2 seconds to connect
BufferedWriter wr = new BufferedWriter(new OutputStreamWriter(sock.getOutputStream()));
wr.write(test);
wr.flush();
try {
Thread.sleep(500);
} catch (InterruptedException e) {}
assertEquals(line, test.trim());
collector.close();
}