@@ -11,6 +11,8 @@ import org.vertx.scala.core.FunctionConverters._
11
11
trait BaseSqlTests {
12
12
this : SqlTestVerticle =>
13
13
14
+ private val timeout : Int = 15000
15
+
14
16
protected def isMysql : Boolean = false
15
17
16
18
protected def failedTest : PartialFunction [Throwable , Unit ] = {
@@ -21,7 +23,7 @@ trait BaseSqlTests {
21
23
22
24
private def sendWithTimeout (json : JsonObject ): Future [(Message [JsonObject ], JsonObject )] = {
23
25
val p = Promise [(Message [JsonObject ], JsonObject )]()
24
- vertx.eventBus.sendWithTimeout(address, json, 5000 , {
26
+ vertx.eventBus.sendWithTimeout(address, json, timeout , {
25
27
case Success (reply) => p.success(reply, reply.body())
26
28
case Failure (ex) => p.failure(ex)
27
29
}: Try [Message [JsonObject ]] => Unit )
@@ -30,7 +32,7 @@ trait BaseSqlTests {
30
32
31
33
private def replyWithTimeout (msg : Message [JsonObject ], json : JsonObject ): Future [(Message [JsonObject ], JsonObject )] = {
32
34
val p = Promise [(Message [JsonObject ], JsonObject )]()
33
- msg.replyWithTimeout(json, 5000 , {
35
+ msg.replyWithTimeout(json, timeout , {
34
36
case Success (reply) => p.success(reply, reply.body())
35
37
case Failure (ex) => p.failure(ex)
36
38
}: Try [Message [JsonObject ]] => Unit )
0 commit comments