You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2023/05/19 14:18:10 UTC
[camel] branch main updated: (chores) camel-core: remove unused method parameter
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
The following commit(s) were added to refs/heads/main by this push:
new 20c2c8d7134 (chores) camel-core: remove unused method parameter
20c2c8d7134 is described below
commit 20c2c8d71345a27d53331c9457622f4143210158
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Fri May 19 13:55:51 2023 +0200
(chores) camel-core: remove unused method parameter
---
.../apache/camel/component/disruptor/AbstractSynchronizedExchange.java | 2 +-
.../src/main/java/org/apache/camel/component/seda/SedaConsumer.java | 2 +-
.../main/java/org/apache/camel/impl/engine/DefaultConsumerTemplate.java | 2 +-
.../src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java | 2 +-
.../src/test/java/org/apache/camel/builder/xml/XsltBuilderTest.java | 2 +-
.../src/main/java/org/apache/camel/support/UnitOfWorkHelper.java | 2 +-
6 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/AbstractSynchronizedExchange.java b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/AbstractSynchronizedExchange.java
index 0018aca72e2..f824cbfb312 100644
--- a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/AbstractSynchronizedExchange.java
+++ b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/AbstractSynchronizedExchange.java
@@ -53,6 +53,6 @@ public abstract class AbstractSynchronizedExchange implements SynchronizedExchan
protected void performSynchronization() {
//call synchronizations with the result
UnitOfWorkHelper.doneSynchronizations(getExchange(),
- synchronizations, AbstractSynchronizedExchange.LOG);
+ synchronizations);
}
}
diff --git a/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaConsumer.java b/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaConsumer.java
index 5d4b0941fca..ac4d7a2c70b 100644
--- a/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaConsumer.java
+++ b/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaConsumer.java
@@ -260,7 +260,7 @@ public class SedaConsumer extends DefaultConsumer implements Runnable, ShutdownA
// and use the asynchronous routing engine to support it
mp.process(exchange, doneSync -> {
// done the uow on the completions
- UnitOfWorkHelper.doneSynchronizations(exchange, completions, LOG);
+ UnitOfWorkHelper.doneSynchronizations(exchange, completions);
});
} else {
// use the regular processor and use the asynchronous routing engine to support it
diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultConsumerTemplate.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultConsumerTemplate.java
index 00914f4b8e0..fd0013ca503 100644
--- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultConsumerTemplate.java
+++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultConsumerTemplate.java
@@ -219,7 +219,7 @@ public class DefaultConsumerTemplate extends ServiceSupport implements ConsumerT
if (exchange.getUnitOfWork() == null) {
// handover completions and done them manually to ensure they are being executed
List<Synchronization> synchronizations = exchange.getExchangeExtension().handoverCompletions();
- UnitOfWorkHelper.doneSynchronizations(exchange, synchronizations, LOG);
+ UnitOfWorkHelper.doneSynchronizations(exchange, synchronizations);
} else {
// done the unit of work
exchange.getUnitOfWork().done(exchange);
diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java
index 4c33c7f75c1..aa4e27cd806 100644
--- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java
+++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java
@@ -224,7 +224,7 @@ public class DefaultUnitOfWork implements UnitOfWork {
}
// at first done the synchronizations
- UnitOfWorkHelper.doneSynchronizations(exchange, synchronizations, log);
+ UnitOfWorkHelper.doneSynchronizations(exchange, synchronizations);
// unregister from inflight registry, before signalling we are done
inflightRepository.remove(exchange);
diff --git a/core/camel-core/src/test/java/org/apache/camel/builder/xml/XsltBuilderTest.java b/core/camel-core/src/test/java/org/apache/camel/builder/xml/XsltBuilderTest.java
index 506130240d2..cd129ac2c19 100644
--- a/core/camel-core/src/test/java/org/apache/camel/builder/xml/XsltBuilderTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/builder/xml/XsltBuilderTest.java
@@ -261,7 +261,7 @@ public class XsltBuilderTest extends ContextTestSupport {
// now done the exchange
List<Synchronization> onCompletions = exchange.getExchangeExtension().handoverCompletions();
- UnitOfWorkHelper.doneSynchronizations(exchange, onCompletions, log);
+ UnitOfWorkHelper.doneSynchronizations(exchange, onCompletions);
// the file should be deleted
assertFileNotExists(testFile("xsltout.xml"));
diff --git a/core/camel-support/src/main/java/org/apache/camel/support/UnitOfWorkHelper.java b/core/camel-support/src/main/java/org/apache/camel/support/UnitOfWorkHelper.java
index 69c1be2ca3a..ff46be24560 100644
--- a/core/camel-support/src/main/java/org/apache/camel/support/UnitOfWorkHelper.java
+++ b/core/camel-support/src/main/java/org/apache/camel/support/UnitOfWorkHelper.java
@@ -57,7 +57,7 @@ public final class UnitOfWorkHelper {
}
}
- public static void doneSynchronizations(Exchange exchange, List<Synchronization> synchronizations, Logger log) {
+ public static void doneSynchronizations(Exchange exchange, List<Synchronization> synchronizations) {
if (synchronizations == null || synchronizations.isEmpty()) {
return;
}