SEARCH-538

- Review comments
This commit is contained in:
Keerthi Niranjan 2018-01-08 17:38:58 +05:30
parent 252047891e
commit 63b2fe25bd
2 changed files with 3 additions and 5 deletions

View File

@ -24,7 +24,9 @@ let makeBoundTimedCollector = function(isIndexing, timeout, callback) {
clearTimeout(timer); clearTimeout(timer);
timer = null; timer = null;
resetQueue(); resetQueue();
callback(JSON.stringify(queue)); if (queue) {
callback(JSON.stringify(queue));
}
} }
function getQueue(){ function getQueue(){

View File

@ -169,10 +169,6 @@ class Search {
* @param message * @param message
*/ */
realTimeIndexing(message) { realTimeIndexing(message) {
if (!message) {
log.send(logLevels.ERROR, 'RealTime Indexing: Messages not provided');
throw new Error('RealTime Indexing: Messages is required');
}
try { try {
let msg = JSON.parse(message); let msg = JSON.parse(message);