|
@ -524,8 +524,8 @@ function onCollection(err, collection) { |
|
|
|
|
|
|
|
|
setInterval(function () { |
|
|
setInterval(function () { |
|
|
console.log('itemsProcessed', itemsProcessed); |
|
|
console.log('itemsProcessed', itemsProcessed); |
|
|
// this method is also exposed by the Server instance
|
|
|
// this method is also exposed by the Server instance
|
|
|
//console.log(adapter.rooms);
|
|
|
//console.log(adapter.rooms);
|
|
|
}, 8000); |
|
|
}, 8000); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
@ -600,7 +600,7 @@ io.on('connection', s => { |
|
|
var room = usersession.SOCKET.user |
|
|
var room = usersession.SOCKET.user |
|
|
//s.on("subscribe", function (room) {
|
|
|
//s.on("subscribe", function (room) {
|
|
|
s.join(room); |
|
|
s.join(room); |
|
|
console.log("joining rooom", s.rooms); |
|
|
console.log("joining rooom", s.rooms); |
|
|
console.log(room + ' created ') |
|
|
console.log(room + ' created ') |
|
|
// });
|
|
|
// });
|
|
|
} |
|
|
} |
|
|