Skip to content

Commit 230a1c2

Browse files
committed
Make maximumMessageSize configurable in json config for the module
1 parent 0840f0e commit 230a1c2

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/main/scala/io/vertx/asyncsql/Starter.scala

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,10 +61,13 @@ class Starter extends Verticle {
6161
val username = config.getString("username", defaultUserFor(dbType))
6262
val password = Option(config.getString("password")).orElse(defaultPasswordFor(dbType))
6363
val database = Option(config.getString("database")).orElse(defaultDatabaseFor(dbType))
64+
val maxMessageSize = config.getInteger("maximumMessageSize", defaultMaximumMessageSize())
6465

65-
Configuration(username, host, port, password, database)
66+
Configuration(username, host, port, password, database, maximumMessageSize = maxMessageSize)
6667
}
6768

69+
private def defaultMaximumMessageSize(): Integer = 16777216 * 4
70+
6871
private def defaultPortFor(connection: String): Integer = connection match {
6972
case "postgresql" => 5432
7073
case "mysql" => 3306
@@ -83,4 +86,4 @@ class Starter extends Verticle {
8386
case "postgresql" => None
8487
case "mysql" => None
8588
}
86-
}
89+
}

0 commit comments

Comments
 (0)