fix messageHandler null deconstruction
This commit is contained in:
parent
0d85c45f47
commit
b9bc327eda
@ -11,7 +11,7 @@ const init = ({ app, server, options }) => {
|
|||||||
const realm = new Realm();
|
const realm = new Realm();
|
||||||
const messageHandler = require('./messageHandler')({ realm });
|
const messageHandler = require('./messageHandler')({ realm });
|
||||||
const api = require('./api')({ config, realm, messageHandler });
|
const api = require('./api')({ config, realm, messageHandler });
|
||||||
const { startMessagesExpiration } = require('./services/messagesExpire')({ realm, config });
|
const { startMessagesExpiration } = require('./services/messagesExpire')({ realm, config, messageHandler });
|
||||||
|
|
||||||
app.use(options.path, api);
|
app.use(options.path, api);
|
||||||
|
|
||||||
|
@ -1,7 +1,6 @@
|
|||||||
const messageHandler = require('../../messageHandler');
|
|
||||||
const { MessageType } = require('../../enums');
|
const { MessageType } = require('../../enums');
|
||||||
|
|
||||||
module.exports = ({ realm, config }) => {
|
module.exports = ({ realm, config, messageHandler }) => {
|
||||||
const pruneOutstanding = () => {
|
const pruneOutstanding = () => {
|
||||||
const destinationClientsIds = realm._messageQueues.keys();
|
const destinationClientsIds = realm._messageQueues.keys();
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user