assertEquals(connId, de.whichClient);
assertEquals(buf, de.data);
System.out.println(de.data.toString(Charset.defaultCharset()));
// step 3
buf = client.send("World!");
de = (DataEvent) queue.take();
assertEquals(EventSource.kBackend, de.source);
assertEquals(connId, de.whichClient);
assertEquals(buf, de.data);
System.out.println(de.data.toString(Charset.defaultCharset()));