diff --git a/lib/update-device.coffee b/lib/update-device.coffee index c399e10..4b2a6ce 100644 --- a/lib/update-device.coffee +++ b/lib/update-device.coffee @@ -116,7 +116,7 @@ commitUpdates = (deviceId, deviceUpdates, commitQueue, callback) -> update['$set']["_customCommands.#{commandName}._timestamp"] = now processBatches = (cb) -> - if not commitQueue? + if not commitQueue processBatch(deviceUpdates) if deviceUpdates? return cb()