Add message routing testcases and related bugfixes
- Handle XOS sensor tasks specially to route events correctly
- Add a 'req_id' optional field to manager request API for client-side req-res mapping
- Fix several bugs related to message routing
- Rename event names for consistency
- Separate kickstart call-back event from kickstart request
- Shorten ping/pong timeout for socket.io for fast response
- Add a 'dag_id' field to tasks in essences
- Notify event arrivals to workflow run clients to let them get events as soon as possible
- Small code refinements
Change-Id: Ibc4182027eb5e2854f1603e339fffbe76e9ba621
diff --git a/src/controllers/websocket.js b/src/controllers/websocket.js
index 3f3216a..b5eaf13 100644
--- a/src/controllers/websocket.js
+++ b/src/controllers/websocket.js
@@ -26,7 +26,10 @@
let io;
const createSocketIO = (server) => {
// INSTANTIATE SOCKET.IO
- io = socketio.listen(server);
+ io = socketio.listen(server, {
+ pingInterval: 500,
+ pingTimeout: 2000,
+ });
io.use(ioWildcard());
// set io to eventrouter
@@ -89,4 +92,4 @@
// const socket = socketIo.get();
// socket.emit('eventName', data);
-})();
\ No newline at end of file
+})();