|
@ -411,7 +411,7 @@ MongoClient.connect(mongourl, OPTS, function(err, client){ |
|
|
} else { |
|
|
} else { |
|
|
const db = client.db('fluent'); |
|
|
const db = client.db('fluent'); |
|
|
//db.collection('log', onCollection);
|
|
|
//db.collection('log', onCollection);
|
|
|
var stream = db.log.find({}, { |
|
|
var stream = db.collection('log').find({}, { |
|
|
tailable: true, |
|
|
tailable: true, |
|
|
awaitdata: true |
|
|
awaitdata: true |
|
|
/* other options */ |
|
|
/* other options */ |
|
|