From f35ac72d532994b4182a17d7d1ec3151961e373c Mon Sep 17 00:00:00 2001 From: ppatierno Date: Sat, 28 Jan 2017 14:06:24 +0100 Subject: [PATCH] Fixed verticle class name and added deployment options with instances number --- .../java/io/vertx/example/mqtt/MqttServerVerticleApp.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/mqtt-server-examples/src/main/java/io/vertx/example/mqtt/MqttServerVerticleApp.java b/mqtt-server-examples/src/main/java/io/vertx/example/mqtt/MqttServerVerticleApp.java index 87bc8ea16..935f04835 100644 --- a/mqtt-server-examples/src/main/java/io/vertx/example/mqtt/MqttServerVerticleApp.java +++ b/mqtt-server-examples/src/main/java/io/vertx/example/mqtt/MqttServerVerticleApp.java @@ -16,6 +16,7 @@ package io.vertx.example.mqtt; +import io.vertx.core.DeploymentOptions; import io.vertx.core.Vertx; import io.vertx.core.logging.Logger; import io.vertx.core.logging.LoggerFactory; @@ -33,7 +34,10 @@ public static void main(String[] args) { Vertx vertx = Vertx.vertx(); - vertx.deployVerticle("io.vertx.mqtt.examples.verticle.MqttServerVerticle"); + DeploymentOptions options = new DeploymentOptions(); + options.setInstances(5); + + vertx.deployVerticle("io.vertx.example.mqtt.MqttServerVerticle", options); try { System.in.read();