Skip to content

Commit f35ac72

Browse files
committed
Fixed verticle class name and added deployment options with instances number
1 parent b019a1c commit f35ac72

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

mqtt-server-examples/src/main/java/io/vertx/example/mqtt/MqttServerVerticleApp.java

+5-1
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616

1717
package io.vertx.example.mqtt;
1818

19+
import io.vertx.core.DeploymentOptions;
1920
import io.vertx.core.Vertx;
2021
import io.vertx.core.logging.Logger;
2122
import io.vertx.core.logging.LoggerFactory;
@@ -33,7 +34,10 @@ public static void main(String[] args) {
3334

3435
Vertx vertx = Vertx.vertx();
3536

36-
vertx.deployVerticle("io.vertx.mqtt.examples.verticle.MqttServerVerticle");
37+
DeploymentOptions options = new DeploymentOptions();
38+
options.setInstances(5);
39+
40+
vertx.deployVerticle("io.vertx.example.mqtt.MqttServerVerticle", options);
3741

3842
try {
3943
System.in.read();

0 commit comments

Comments
 (0)