diff --git a/src/index.js b/src/index.js index 8c5a827..a1dd460 100644 --- a/src/index.js +++ b/src/index.js @@ -11,7 +11,7 @@ const init = ({ app, server, options }) => { const realm = new Realm(); const messageHandler = require('./messageHandler')({ realm }); 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); diff --git a/src/services/messagesExpire/index.js b/src/services/messagesExpire/index.js index d8ca7d5..b4d2b8c 100644 --- a/src/services/messagesExpire/index.js +++ b/src/services/messagesExpire/index.js @@ -1,7 +1,6 @@ -const messageHandler = require('../../messageHandler'); const { MessageType } = require('../../enums'); -module.exports = ({ realm, config }) => { +module.exports = ({ realm, config, messageHandler }) => { const pruneOutstanding = () => { const destinationClientsIds = realm._messageQueues.keys();