Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

updates mongo to use the new 2.7.3 driver

the signatures of the connection have changed in 2.7.3 so we have to update
the timing wrapper
  • Loading branch information...
commit 4d1c42f502308b6d580a12424f2321e6f109e3fd 1 parent 2174e1d
@steppenwells steppenwells authored
View
1  management-mongo/build.sbt
@@ -1,6 +1,7 @@
libraryDependencies ++= Seq(
"ch.qos.logback" % "logback-classic" % "0.9.27",
+ "org.mongodb" % "mongo-java-driver" % "2.7.3",
"com.mongodb.casbah" %% "casbah" % "2.1.5-1"
)
View
14 management-mongo/src/main/scala/com/mongodb/TimingDBTCPConnector.scala
@@ -54,20 +54,22 @@ class TimingDBTCPConnector(private val targetConnector: DBTCPConnector, private
targetConnector.say(db, m, concern, hostNeeded)
}
- override def call(db: DB, coll: DBCollection, m: OutMessage): Response =
+ override def call(db: DB, coll: DBCollection, m: OutMessage, hostNeeded: ServerAddress, decoder: DBDecoder): Response =
Timing.debug(logger, "mongo db call()", timingMetric) {
- targetConnector.call(db, coll, m)
+ targetConnector.call(db, coll, m, hostNeeded, decoder)
}
- override def call(db: DB, coll: DBCollection, m: OutMessage, hostNeeded: ServerAddress): Response =
+ override def call(db: DB, coll: DBCollection, m: OutMessage, hostNeeded: ServerAddress, retries: Int): Response =
Timing.debug(logger, "mongo db call()", timingMetric) {
- targetConnector.call(db, coll, m, hostNeeded)
+ targetConnector.call(db, coll, m, hostNeeded, retries)
}
- override def call(db: DB, coll: DBCollection, m: OutMessage, hostNeeded: ServerAddress, retries: Int): Response =
+ override def call(db: DB, coll: DBCollection, m: OutMessage, hostNeeded: ServerAddress, retries: Int, readPref: ReadPreference, decoder: DBDecoder): Response =
Timing.debug(logger, "mongo db call()", timingMetric) {
- targetConnector.call(db, coll, m, hostNeeded, retries)
+ targetConnector.call(db, coll, m, hostNeeded, retries, readPref, decoder)
}
+ override def start() { targetConnector.start }
+
override def isOpen: Boolean = targetConnector.isOpen
}
Please sign in to comment.
Something went wrong with that request. Please try again.