(camel) 03/08: (chores) camel-core: code cleanup

[orpiske]

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

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

commit 6d9fca53d70a25ebee552e3ad178646932ef9027
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Tue Apr 23 11:39:19 2024 +0200

    (chores) camel-core: code cleanup
    
    Apply proper cast when needed
---
 .../main/java/org/apache/camel/impl/console/RouteDevConsole.java    | 2 +-
 .../org/apache/camel/processor/errorhandler/RedeliveryPolicy.java   | 2 +-
 .../java/org/apache/camel/issues/SplitterParallelIssueTest.java     | 2 +-
 .../test/java/org/apache/camel/util/backoff/BackOffTimerTest.java   | 6 +++---
 4 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/core/camel-console/src/main/java/org/apache/camel/impl/console/RouteDevConsole.java
 
b/core/camel-console/src/main/java/org/apache/camel/impl/console/RouteDevConsole.java
index a593926d4b4..087357f1cb9 100644
--- 
a/core/camel-console/src/main/java/org/apache/camel/impl/console/RouteDevConsole.java
+++ 
b/core/camel-console/src/main/java/org/apache/camel/impl/console/RouteDevConsole.java
@@ -461,7 +461,7 @@ public class RouteDevConsole extends AbstractDevConsole {
         if (percent) {
             double p;
             if (total > 0) {
-                p = (covered / total) * 100;
+                p = ((double) covered / total) * 100;
             } else {
                 p = 0;
             }
diff --git 
a/core/camel-core-processor/src/main/java/org/apache/camel/processor/errorhandler/RedeliveryPolicy.java
 
b/core/camel-core-processor/src/main/java/org/apache/camel/processor/errorhandler/RedeliveryPolicy.java
index 87e5ffea40f..e0a3eef6c18 100644
--- 
a/core/camel-core-processor/src/main/java/org/apache/camel/processor/errorhandler/RedeliveryPolicy.java
+++ 
b/core/camel-core-processor/src/main/java/org/apache/camel/processor/errorhandler/RedeliveryPolicy.java
@@ -236,7 +236,7 @@ public class RedeliveryPolicy implements Cloneable, 
Serializable {
             Random random = getRandomNumberGenerator(); // NOSONAR
             double variance = (random.nextBoolean() ? collisionAvoidanceFactor 
: -collisionAvoidanceFactor)
                               * random.nextDouble();
-            redeliveryDelayResult += redeliveryDelayResult * variance;
+            redeliveryDelayResult += (long) (redeliveryDelayResult * variance);
         }
 
         // ensure the calculated result is not bigger than the max delay (if 
configured)
diff --git 
a/core/camel-core/src/test/java/org/apache/camel/issues/SplitterParallelIssueTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/issues/SplitterParallelIssueTest.java
index 50664e3bad2..ca776ac8569 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/issues/SplitterParallelIssueTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/issues/SplitterParallelIssueTest.java
@@ -61,7 +61,7 @@ public class SplitterParallelIssueTest extends 
ContextTestSupport {
                             @Override
                             public void process(Exchange exchange) throws 
Exception {
                                 int num = exchange.getIn().getBody(int.class);
-                                final long sleep = num * delay;
+                                final long sleep = (long) num * delay;
                                 log.info("Sleep for {} ms", sleep);
                                 Thread.sleep(sleep);
                             }
diff --git 
a/core/camel-util/src/test/java/org/apache/camel/util/backoff/BackOffTimerTest.java
 
b/core/camel-util/src/test/java/org/apache/camel/util/backoff/BackOffTimerTest.java
index 15bc536f94b..810a3d6e662 100644
--- 
a/core/camel-util/src/test/java/org/apache/camel/util/backoff/BackOffTimerTest.java
+++ 
b/core/camel-util/src/test/java/org/apache/camel/util/backoff/BackOffTimerTest.java
@@ -45,7 +45,7 @@ public class BackOffTimerTest {
                 context -> {
                     assertEquals(counter.incrementAndGet(), 
context.getCurrentAttempts());
                     assertEquals(100, context.getCurrentDelay());
-                    assertEquals(100 * counter.get(), 
context.getCurrentElapsedTime());
+                    assertEquals(100L * counter.get(), 
context.getCurrentElapsedTime());
                     if (first.get() == 0) {
                         first.set(context.getFirstAttemptTime());
                     } else {
@@ -78,7 +78,7 @@ public class BackOffTimerTest {
                 context -> {
                     assertEquals(counter.incrementAndGet(), 
context.getCurrentAttempts());
                     assertEquals(100, context.getCurrentDelay());
-                    assertEquals(100 * counter.get(), 
context.getCurrentElapsedTime());
+                    assertEquals(100L * counter.get(), 
context.getCurrentElapsedTime());
 
                     return true;
                 });
@@ -107,7 +107,7 @@ public class BackOffTimerTest {
                 context -> {
                     assertEquals(counter.incrementAndGet(), 
context.getCurrentAttempts());
                     assertEquals(100, context.getCurrentDelay());
-                    assertEquals(100 * counter.get(), 
context.getCurrentElapsedTime());
+                    assertEquals(100L * counter.get(), 
context.getCurrentElapsedTime());
 
                     return true;
                 });