diff --git a/server/src/main/java/io/cettia/DefaultServer.java b/server/src/main/java/io/cettia/DefaultServer.java index 93dc5fc..79e7343 100644 --- a/server/src/main/java/io/cettia/DefaultServer.java +++ b/server/src/main/java/io/cettia/DefaultServer.java @@ -386,6 +386,7 @@ public void on() { }); Map headers = new LinkedHashMap<>(); + headers.put("cettia-version", "1.0"); headers.put("cettia-id", id); headers.put("cettia-heartbeat", options.get("heartbeat")); headers.put("cettia-_heartbeat", options.get("_heartbeat")); diff --git a/server/src/main/java/io/cettia/transport/http/HttpTransportServer.java b/server/src/main/java/io/cettia/transport/http/HttpTransportServer.java index d1fb2e4..dbbc638 100644 --- a/server/src/main/java/io/cettia/transport/http/HttpTransportServer.java +++ b/server/src/main/java/io/cettia/transport/http/HttpTransportServer.java @@ -311,6 +311,7 @@ private static class StreamTransport extends BaseTransport { public StreamTransport(ServerHttpExchange http) { super(http); Map query = new LinkedHashMap<>(); + query.put("cettia-transport-version", "1.0"); query.put("cettia-transport-id", id); http.onfinish(new VoidAction() { @Override @@ -415,6 +416,7 @@ public void on() { switch (when) { case "open": Map query = new LinkedHashMap<>(); + query.put("cettia-transport-version", "1.0"); query.put("cettia-transport-id", id); endWithMessage(http, "?" + formatQuery(query)); break; diff --git a/server/src/test/resources/package.json b/server/src/test/resources/package.json index fb6f771..fca9990 100644 --- a/server/src/test/resources/package.json +++ b/server/src/test/resources/package.json @@ -1,7 +1,7 @@ { "private": "true", "devDependencies": { - "cettia-protocol": "cettia/cettia-protocol#f2a9df19c92541215c8ee7f19d2939181ba99b22", + "cettia-protocol": "cettia/cettia-protocol#f83e99cdc202b4818c2041b1563ee8a6ac8c8f00", "mocha": "^3.2.0", "chai": "^3.5.0", "minimist": "^1.2.0"