diff options
Diffstat (limited to 'central/src/main/java/moe/yuuta/dn42peering/asn/ASNVerticle.java')
-rw-r--r-- | central/src/main/java/moe/yuuta/dn42peering/asn/ASNVerticle.java | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/central/src/main/java/moe/yuuta/dn42peering/asn/ASNVerticle.java b/central/src/main/java/moe/yuuta/dn42peering/asn/ASNVerticle.java index aef9e1c..9e11d8e 100644 --- a/central/src/main/java/moe/yuuta/dn42peering/asn/ASNVerticle.java +++ b/central/src/main/java/moe/yuuta/dn42peering/asn/ASNVerticle.java @@ -8,22 +8,19 @@ import io.vertx.core.eventbus.MessageConsumer; import io.vertx.core.impl.logging.Logger; import io.vertx.core.impl.logging.LoggerFactory; import io.vertx.core.json.JsonObject; -import io.vertx.mysqlclient.MySQLConnectOptions; -import io.vertx.mysqlclient.MySQLPool; import io.vertx.serviceproxy.ServiceBinder; -import io.vertx.sqlclient.PoolOptions; +import io.vertx.sqlclient.Pool; +import moe.yuuta.dn42peering.database.DatabaseUtils; public class ASNVerticle extends AbstractVerticle { private final Logger logger = LoggerFactory.getLogger(getClass().getSimpleName()); private MessageConsumer<JsonObject> consumer; - private MySQLPool pool; + private Pool pool; @Override public void start(Promise<Void> startPromise) throws Exception { - final JsonObject json = vertx.getOrCreateContext().config().getJsonObject("database"); - final MySQLConnectOptions opt = new MySQLConnectOptions(json); - pool = MySQLPool.pool(vertx, opt, new PoolOptions().setMaxSize(5)); + pool = DatabaseUtils.getPool(vertx); consumer = new ServiceBinder(vertx) .setAddress(IASNService.ADDRESS) |