Removing timeout implementation for MySQL, client code should be responsible for deciding a timeout on it's futures

Author: mauricio

db-async-common/src/main/scala/com/github/mauricio/async/db/Configuration.scala

@@ -54,5 +54,4 @@ case class Configuration(username: String,
  maximumMessageSize: Int = 16777216,
  allocator: AbstractByteBufAllocator = PooledByteBufAllocator.DEFAULT,
  connectTimeout: Duration = 5.seconds,
- testTimeout: Duration = 5.seconds,
- requestTimeout: Duration = 5.seconds)
+ testTimeout: Duration = 5.seconds)

mysql-async/src/main/scala/com/github/mauricio/async/db/mysql/MySQLConnection.scala

@@ -16,7 +16,6 @@
 
 package com.github.mauricio.async.db.mysql
 
-import java.util.concurrent.TimeoutException
 import java.util.concurrent.atomic.{AtomicLong, AtomicReference}
 
 import com.github.mauricio.async.db._
@@ -189,17 +188,10 @@ class MySQLConnection(
  val promise = Promise[QueryResult]()
  this.setQueryPromise(promise)
  this.connectionHandler.write(new QueryMessage(query))
- addTimeout(promise)
 
  promise.future
  }
 
- private def addTimeout(promise: Promise[QueryResult]): Unit = {
- this.connectionHandler.schedule(
- promise.tryFailure(new TimeoutException(s"response took too long to return(${configuration.requestTimeout})")),
- configuration.requestTimeout)
- }
-
  private def failQueryPromise(t: Throwable) {
  this.clearQueryPromise.foreach {
  _.tryFailure(t)
@@ -244,7 +236,6 @@ class MySQLConnection(
  val promise = Promise[QueryResult]()
  this.setQueryPromise(promise)
  this.connectionHandler.sendPreparedStatement(query, values)
- addTimeout(promise)
 
  promise.future
  }

project/Build.scala

@@ -45,18 +45,18 @@ object ProjectBuild extends Build {
 
 object Configuration {
 
- val commonVersion = "0.2.17"
- val projectScalaVersion = "2.11.0"
+ val commonVersion = "0.2.18-SNAPSHOT"
+ val projectScalaVersion = "2.11.7"
 
  val specs2Dependency = "org.specs2" %% "specs2" % "2.3.11" % "test"
- val logbackDependency = "ch.qos.logback" % "logback-classic" % "1.0.13" % "test"
+ val logbackDependency = "ch.qos.logback" % "logback-classic" % "1.1.3" % "test"
 
  val commonDependencies = Seq(
- "org.slf4j" % "slf4j-api" % "1.7.5",
+ "org.slf4j" % "slf4j-api" % "1.7.12",
  "joda-time" % "joda-time" % "2.3",
  "org.joda" % "joda-convert" % "1.5",
- "io.netty" % "netty-all" % "4.0.25.Final",
- "org.javassist" % "javassist" % "3.18.1-GA",
+ "io.netty" % "netty-all" % "4.0.29.Final",
+ "org.javassist" % "javassist" % "3.20.0-GA",
  specs2Dependency,
  logbackDependency
  )