diff --git a/src/main/scala/io/vertx/asyncsql/Starter.scala b/src/main/scala/io/vertx/asyncsql/Starter.scala index 193c94b..f629a44 100644 --- a/src/main/scala/io/vertx/asyncsql/Starter.scala +++ b/src/main/scala/io/vertx/asyncsql/Starter.scala @@ -61,10 +61,13 @@ class Starter extends Verticle { val username = config.getString("username", defaultUserFor(dbType)) val password = Option(config.getString("password")).orElse(defaultPasswordFor(dbType)) val database = Option(config.getString("database")).orElse(defaultDatabaseFor(dbType)) + val maxMessageSize = config.getInteger("maximumMessageSize", defaultMaximumMessageSize()) - Configuration(username, host, port, password, database) + Configuration(username, host, port, password, database, maximumMessageSize = maxMessageSize) } + private def defaultMaximumMessageSize(): Integer = 16777216 * 4 + private def defaultPortFor(connection: String): Integer = connection match { case "postgresql" => 5432 case "mysql" => 3306 @@ -83,4 +86,4 @@ class Starter extends Verticle { case "postgresql" => None case "mysql" => None } -} \ No newline at end of file +}