diff --git a/packages/mongo/oplog_tailing.js b/packages/mongo/oplog_tailing.js index 7d2b2fea10..698e9ce4c0 100644 --- a/packages/mongo/oplog_tailing.js +++ b/packages/mongo/oplog_tailing.js @@ -1,7 +1,7 @@ var Future = Npm.require('fibers/future'); import { NpmModuleMongodb } from "meteor/npm-mongo"; -const { Timestamp } = NpmModuleMongodb; +const { Long } = NpmModuleMongodb; OPLOG_COLLECTION = 'oplog.rs'; @@ -278,7 +278,7 @@ _.extend(OplogHandle.prototype, { // See https://github.com/meteor/meteor/issues/10420. if (!op.ts) { op.ts = nextTimestamp; - nextTimestamp = nextTimestamp.add(Timestamp.ONE); + nextTimestamp = nextTimestamp.add(Long.ONE); } handleDoc(op); });