diff --git a/tests/io/socket/TestSocketIO.java b/tests/io/socket/TestSocketIO.java index 1b30f05..0f75c27 100644 --- a/tests/io/socket/TestSocketIO.java +++ b/tests/io/socket/TestSocketIO.java @@ -19,9 +19,9 @@ @RunWith(io.socket.RandomBlockJUnit4ClassRunner.class) public class TestSocketIO implements IOCallback { - private final static String NODE = "/opt/local/bin/node"; + private final static String NODE = "C:\\Program Files (x86)\\nodejs\\node.exe"; private static final int PORT = 10214; - private static final int TIMEOUT = 200; + private static final int TIMEOUT = 2; LinkedBlockingQueue events; LinkedBlockingQueue outputs; LinkedBlockingQueue args; @@ -205,7 +205,6 @@ public void namespaces() throws Exception { assertEquals("ns2", takeArg()); ns2_2.disconnect(); - ns2.disconnect(); assertEquals("onDisconnect", takeEvent()); assertEquals("onDisconnect", takeEvent()); @@ -215,7 +214,7 @@ public void namespaces() throws Exception { @Test public void error() throws Exception { doConnect(); - SocketIO error = new SocketIO( + new SocketIO( "http://127.0.0.1:" + (PORT + 1) + "/ns1", this); assertEquals("onError", takeEvent()); doClose(); diff --git a/node/socketio.js b/tests/io/socket/socketio.js similarity index 92% rename from node/socketio.js rename to tests/io/socket/socketio.js index 09b8dd4..853b00b 100644 --- a/node/socketio.js +++ b/tests/io/socket/socketio.js @@ -23,6 +23,9 @@ var main = io.sockets.on('connection', function(socket) { socket.send(data); } }); + socket.on('echoAck', function(data, ack) { + ack(data); + }); socket.on('message', function(m) { process.stdout.write("__:MESSAGE:"+m+"\n"); });