При запуске 20 экземпляров Vertx для запуска 20 Mqtt брокеров - PullRequest
Новая
       13

При запуске 20 экземпляров Vertx для запуска 20 Mqtt брокеров

0 голосов
/ 20 июня 2019

Когда я запускаю 20 новых экземпляров Vertx для запуска 20 брокеров MQTT, я получаю сообщение об ошибке в одном из брокеров mqtt и не могу его запустить.

Код для запуска 20 экземпляров: 

          "com.abc.abc",
          new DeploymentOptions().setWorkerPoolName("coffee-making-pool")
              .setWorkerPoolSize(100).setInstances(20).setWorker(true));```

Произошло событие exceptionCaught (), и оно достигло конца конвейера.Обычно это означает, что последний обработчик в конвейере не обработал исключение[vertx-mqtt-3.6.2.jar: 3.6.2] в io.vertx.mqtt.impl.MqttServerImpl.lambda $ null $ 3 (MqttServerImpl.java:94) ~ [vertx-mqtt-3.6.2.jar: 3.6.2] в io.vertx.core.streams.impl.InboundBuffer.handleEvent (InboundBuffer.java:225) ~ [vertx-core-3.6.2.jar: 3.6.2] в io.vertx.core.streams.impl.InboundBuffer.write (InboundBuffer.java:123) ~ [vertx-core-3.6.2.jar: 3.6.2] в io.vertx.core.net.impl.NetSocketImpl.handleMessage (NetSocketImpl.java:370) ~ [vertx-core-3.6.2.jar: 3.6.2] в io.vertx.core.net.impl.ConnectionBase.handleRead (ConnectionBase.java:386) ~ [vertx-core-3.6.2.jar: 3.6.2] в io.vertx.core.impl.ContextImpl.executeTask (ContextImpl.java:320) ~ [vertx-core-3.6.2.jar: 3.6.2] в io.vertx.core.impl.WorkerContext.lambda $ wrapTask$ 0 (WorkerContext.java:34) ~ [vertx-core-3.6.2.jar: 3.6.2] в io.vertx.core.impl.TaskQueue.run (TaskQueue.java:76) ~ [vertx-core-3.6.2.jar: 3.6.2] в java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1149) ~ [?: 1.8.0_192] в java.util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java:624) ~ [?: 1.8.0_192].netty.util.concurrent.FastThreadLocalRunnable.run (FastThreadLocalRunnable.java:30) [netty-common-4.1.30.Final.jar: 4.1.30.Final] в java.lang.Thread.run (Thread.java:748).) [?: 1.8.0_192] `` `

...