[camel] branch master updated: (chore) camel-vertx: fixed usage of deprecated vertx APIs (#4831)

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new f8cd8ec  (chore) camel-vertx: fixed usage of deprecated vertx APIs 
(#4831)
f8cd8ec is described below

commit f8cd8eced9d930f69d86ec477d225f949cb47de5
Author: Otavio Rodolfo Piske <orpi...@users.noreply.github.com>
AuthorDate: Tue Jan 5 17:09:16 2021 +0100

    (chore) camel-vertx: fixed usage of deprecated vertx APIs (#4831)
---
 .../org/apache/camel/component/vertx/VertxComponent.java    | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git 
a/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxComponent.java
 
b/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxComponent.java
index 0e17d25..ec24f3a 100644
--- 
a/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxComponent.java
+++ 
b/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxComponent.java
@@ -150,12 +150,12 @@ public class VertxComponent extends DefaultComponent {
             if (vertxOptions == null) {
                 vertxOptions = new VertxOptions();
                 if (ObjectHelper.isNotEmpty(host)) {
-                    vertxOptions.setClusterHost(host);
-                    vertxOptions.setClustered(true);
+                    vertxOptions.getEventBusOptions().setHost(host);
+                    vertxOptions.getEventBusOptions().setClustered(true);
                 }
                 if (port > 0) {
-                    vertxOptions.setClusterPort(port);
-                    vertxOptions.setClustered(true);
+                    vertxOptions.getEventBusOptions().setPort(port);
+                    vertxOptions.getEventBusOptions().setClustered(true);
                 }
             }
 
@@ -165,8 +165,9 @@ public class VertxComponent extends DefaultComponent {
             final CountDownLatch latch = new CountDownLatch(1);
 
             // lets using a host / port if a host name is specified
-            if (vertxOptions.isClustered()) {
-                LOG.info("Creating Clustered Vertx {}:{}", 
vertxOptions.getClusterHost(), vertxOptions.getClusterPort());
+            if (vertxOptions.getEventBusOptions().isClustered()) {
+                LOG.info("Creating Clustered Vertx {}:{}", 
vertxOptions.getEventBusOptions().getHost(),
+                        vertxOptions.getEventBusOptions().getPort());
                 // use the async api as we want to wait for the eventbus to be 
ready before we are in started state
                 vertxFactory.clusteredVertx(vertxOptions, new 
Handler<AsyncResult<Vertx>>() {
                     @Override