Added API for queue messages count
This commit is contained in:
parent
357b73be93
commit
2c6e667bb7
4 changed files with 18 additions and 5 deletions
|
@ -453,10 +453,6 @@ module.exports = class SpectateLevelView extends View
|
||||||
else
|
else
|
||||||
cb(null, $.parseJSON(jqxhr.responseText))
|
cb(null, $.parseJSON(jqxhr.responseText))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
destroy: ()->
|
destroy: ()->
|
||||||
@supermodel?.off 'error', @onLevelLoadError
|
@supermodel?.off 'error', @onLevelLoadError
|
||||||
@levelLoader?.off 'loaded-all', @onLevelLoaderLoaded
|
@levelLoader?.off 'loaded-all', @onLevelLoaderLoaded
|
||||||
|
|
|
@ -185,7 +185,8 @@ class MongoQueue extends events.EventEmitter
|
||||||
subscribe: (eventName, callback) -> @on eventName, callback
|
subscribe: (eventName, callback) -> @on eventName, callback
|
||||||
unsubscribe: (eventName, callback) -> @removeListener eventName, callback
|
unsubscribe: (eventName, callback) -> @removeListener eventName, callback
|
||||||
|
|
||||||
|
totalMessagesInQueue: (callback) -> @Message.count {}, callback
|
||||||
|
|
||||||
receiveMessage: (callback) ->
|
receiveMessage: (callback) ->
|
||||||
conditions =
|
conditions =
|
||||||
queue: @queueName
|
queue: @queueName
|
||||||
|
|
|
@ -24,6 +24,17 @@ connectToScoringQueue = ->
|
||||||
if error? then throw new Error "There was an error registering the scoring queue: #{error}"
|
if error? then throw new Error "There was an error registering the scoring queue: #{error}"
|
||||||
scoringTaskQueue = data
|
scoringTaskQueue = data
|
||||||
log.info "Connected to scoring task queue!"
|
log.info "Connected to scoring task queue!"
|
||||||
|
|
||||||
|
module.exports.messagesInQueueCount = (req, res) ->
|
||||||
|
scoringTaskQueue.totalMessagesInQueue (err, count) ->
|
||||||
|
if err? then return errors.serverError res, "There was an issue finding the Mongoose count:#{err}"
|
||||||
|
response =
|
||||||
|
point:
|
||||||
|
number: count
|
||||||
|
timestamp: Date.now()
|
||||||
|
res.send(response)
|
||||||
|
res.end()
|
||||||
|
|
||||||
|
|
||||||
module.exports.addPairwiseTaskToQueueFromRequest = (req, res) ->
|
module.exports.addPairwiseTaskToQueueFromRequest = (req, res) ->
|
||||||
taskPair = req.body.sessions
|
taskPair = req.body.sessions
|
||||||
|
|
|
@ -9,6 +9,11 @@ module.exports.setup = (app) ->
|
||||||
#app.post '/queue/scoring/pairwise', (req, res) ->
|
#app.post '/queue/scoring/pairwise', (req, res) ->
|
||||||
# handler = loadQueueHandler 'scoring'
|
# handler = loadQueueHandler 'scoring'
|
||||||
# handler.addPairwiseTaskToQueue req, res
|
# handler.addPairwiseTaskToQueue req, res
|
||||||
|
|
||||||
|
app.get '/queue/messagesInQueueCount', (req, res) ->
|
||||||
|
handler = loadQueueHandler 'scoring'
|
||||||
|
handler.messagesInQueueCount req, res
|
||||||
|
|
||||||
|
|
||||||
app.all '/queue/*', (req, res) ->
|
app.all '/queue/*', (req, res) ->
|
||||||
setResponseHeaderToJSONContentType res
|
setResponseHeaderToJSONContentType res
|
||||||
|
|
Reference in a new issue