[camel-quarkus] branch 2.7.x updated: Fix cassandraql itests failing on quarkus-platform #3621

[aldettinger]

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

aldettinger pushed a commit to branch 2.7.x
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/2.7.x by this push:
     new 96bd3a6  Fix cassandraql itests failing on quarkus-platform #3621
96bd3a6 is described below

commit 96bd3a6594a0f582ba2156dbc12c20227b855d5c
Author: aldettinger <aldettin...@gmail.com>
AuthorDate: Tue Mar 15 13:17:19 2022 +0100

    Fix cassandraql itests failing on quarkus-platform #3621
---
 .../quarkus/component/cassandraql/it/CustomLoadBalancingPolicy.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/integration-tests/cassandraql/src/main/java/org/apache/camel/quarkus/component/cassandraql/it/CustomLoadBalancingPolicy.java
 
b/integration-tests/cassandraql/src/main/java/org/apache/camel/quarkus/component/cassandraql/it/CustomLoadBalancingPolicy.java
index 466212f..192cf2e 100644
--- 
a/integration-tests/cassandraql/src/main/java/org/apache/camel/quarkus/component/cassandraql/it/CustomLoadBalancingPolicy.java
+++ 
b/integration-tests/cassandraql/src/main/java/org/apache/camel/quarkus/component/cassandraql/it/CustomLoadBalancingPolicy.java
@@ -24,19 +24,18 @@ import java.util.concurrent.TimeUnit;
 import com.datastax.oss.driver.api.core.context.DriverContext;
 import com.datastax.oss.driver.api.core.metadata.Node;
 import 
com.datastax.oss.driver.internal.core.loadbalancing.DefaultLoadBalancingPolicy;
-import edu.umd.cs.findbugs.annotations.NonNull;
 import io.quarkus.runtime.annotations.RegisterForReflection;
 
 @RegisterForReflection(fields = false, methods = false)
 public class CustomLoadBalancingPolicy extends DefaultLoadBalancingPolicy {
     private static final CountDownLatch latch = new CountDownLatch(1);
 
-    public CustomLoadBalancingPolicy(@NonNull DriverContext context, @NonNull 
String profileName) {
+    public CustomLoadBalancingPolicy(DriverContext context, String 
profileName) {
         super(context, profileName);
     }
 
     @Override
-    public void init(@NonNull Map<UUID, Node> nodes, @NonNull DistanceReporter 
distanceReporter) {
+    public void init(Map<UUID, Node> nodes, DistanceReporter distanceReporter) 
{
         super.init(nodes, distanceReporter);
         latch.countDown();
     }