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/11/28 10:22:53 UTC
(camel) branch main updated: (chores) removed unused code (#12219)
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 574f7b46572 (chores) removed unused code (#12219)
574f7b46572 is described below
commit 574f7b46572b26d8800ebd62843f890db42cc4df
Author: Otavio Rodolfo Piske <or...@users.noreply.github.com>
AuthorDate: Tue Nov 28 11:22:48 2023 +0100
(chores) removed unused code (#12219)
- removed unused private fields
- removed commented code
- removed unused private methods
---
.../htmlxlsx/process/CoverageResultsProcessor.java | 2 --
.../component/aws2/kinesis/Kinesis2Endpoint.java | 1 -
.../aws2/redshift/data/RedshiftData2Producer.java | 3 --
.../google/drive/GoogleDriveFilesConverter.java | 42 ----------------------
.../jgroups/raft/JGroupsRaftEndpoint.java | 4 +--
.../jgroups/raft/JGroupsRaftProducer.java | 4 +--
.../apache/camel/component/jooq/JooqConsumer.java | 2 --
.../camel/jsonpath/jackson/JacksonJsonAdapter.java | 2 --
.../kafka/consumer/CommitToOffsetManager.java | 3 --
.../camel/component/minio/MinioComponent.java | 5 ---
.../camel/component/nitrite/NitriteProducer.java | 3 --
.../camel/component/pgevent/PgEventEndpoint.java | 2 --
.../camel/component/pulsar/PulsarEndpoint.java | 3 --
.../rest/openapi/RestOpenApiEndpoint.java | 5 ---
.../rest/RestProducerBindingProcessor.java | 19 ++++------
.../component/salesforce/PubSubApiConsumer.java | 6 +---
.../internal/streaming/SubscriptionHelper.java | 1 -
.../processor/SchematronProcessorFactory.java | 4 ---
.../DefaultMessagePropertiesConverter.java | 4 +--
.../springrabbit/EndpointMessageListener.java | 5 ---
.../springrabbit/SpringRabbitMQComponent.java | 2 +-
.../component/sql/stored/SqlStoredComponent.java | 4 ---
.../camel/component/thrift/ThriftConsumer.java | 2 +-
.../thrift/server/ThriftMethodHandler.java | 4 +--
.../apache/camel/component/xmpp/XmppConsumer.java | 3 +-
.../camel/component/zeebe/ZeebeProducer.java | 5 ---
.../component/zeebe/processor/JobProcessor.java | 4 ---
.../zeebe/processor/MessageProcessor.java | 3 --
.../zeebe/processor/ProcessProcessor.java | 5 ---
.../engine/DefaultAutowiredLifecycleStrategy.java | 5 ---
.../org/apache/camel/processor/LoopProcessor.java | 2 --
.../camel/dsl/modeline/DefaultModelineFactory.java | 2 +-
.../camel/dsl/modeline/DefaultModelineParser.java | 6 +---
.../java/org/apache/camel/main/KameletMain.java | 4 +--
.../DependencyDownloaderDataFormatResolver.java | 2 --
.../DependencyDownloaderLanguageResolver.java | 2 --
...ependencyDownloaderPropertyBindingListener.java | 2 --
.../DependencyDownloaderUriFactoryResolver.java | 2 --
.../main/download/DownloadModelineParser.java | 2 +-
.../camel/main/download/KameletMainInjector.java | 2 --
.../camel/main/download/KnownReposResolver.java | 6 +---
.../maven/dsl/yaml/support/YamlProperties.java | 1 -
42 files changed, 21 insertions(+), 169 deletions(-)
diff --git a/catalog/camel-report-maven-plugin/src/main/java/org/apache/camel/maven/htmlxlsx/process/CoverageResultsProcessor.java b/catalog/camel-report-maven-plugin/src/main/java/org/apache/camel/maven/htmlxlsx/process/CoverageResultsProcessor.java
index 5f377269934..5a84f224576 100644
--- a/catalog/camel-report-maven-plugin/src/main/java/org/apache/camel/maven/htmlxlsx/process/CoverageResultsProcessor.java
+++ b/catalog/camel-report-maven-plugin/src/main/java/org/apache/camel/maven/htmlxlsx/process/CoverageResultsProcessor.java
@@ -67,8 +67,6 @@ public class CoverageResultsProcessor {
private final XmlToCamelRouteCoverageConverter xmlToCamelRouteCoverageConverter = new XmlToCamelRouteCoverageConverter();
- private Log log;
-
public String generateReport(MavenProject project, final File xmlPath, final File htmlPath) throws IOException {
String out;
diff --git a/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Endpoint.java b/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Endpoint.java
index 9fad0a83d25..8619e3679b8 100644
--- a/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Endpoint.java
+++ b/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Endpoint.java
@@ -44,7 +44,6 @@ public class Kinesis2Endpoint extends ScheduledPollEndpoint {
private KinesisClient kinesisClient;
private KinesisAsyncClient kinesisAsyncClient;
- private static final String CONNECTION_CHECKER_EXECUTOR_NAME = "Kinesis_Streaming_Connection_Checker";
public Kinesis2Endpoint(String uri, Kinesis2Configuration configuration, Kinesis2Component component) {
super(uri, component);
diff --git a/components/camel-aws/camel-aws2-redshift/src/main/java/org/apache/camel/component/aws2/redshift/data/RedshiftData2Producer.java b/components/camel-aws/camel-aws2-redshift/src/main/java/org/apache/camel/component/aws2/redshift/data/RedshiftData2Producer.java
index d98a94124cf..477a3c77f20 100644
--- a/components/camel-aws/camel-aws2-redshift/src/main/java/org/apache/camel/component/aws2/redshift/data/RedshiftData2Producer.java
+++ b/components/camel-aws/camel-aws2-redshift/src/main/java/org/apache/camel/component/aws2/redshift/data/RedshiftData2Producer.java
@@ -43,9 +43,6 @@ public class RedshiftData2Producer extends DefaultProducer {
private transient String redshiftDataProducerToString;
- private HealthCheck producerHealthCheck;
- private WritableHealthCheckRepository healthCheckRepository;
-
public RedshiftData2Producer(final Endpoint endpoint) {
super(endpoint);
}
diff --git a/components/camel-google/camel-google-drive/src/main/java/org/apache/camel/component/google/drive/GoogleDriveFilesConverter.java b/components/camel-google/camel-google-drive/src/main/java/org/apache/camel/component/google/drive/GoogleDriveFilesConverter.java
index 0c7a327850b..811bba0678f 100644
--- a/components/camel-google/camel-google-drive/src/main/java/org/apache/camel/component/google/drive/GoogleDriveFilesConverter.java
+++ b/components/camel-google/camel-google-drive/src/main/java/org/apache/camel/component/google/drive/GoogleDriveFilesConverter.java
@@ -21,17 +21,12 @@ import java.io.InputStream;
import com.google.api.client.http.FileContent;
import com.google.api.client.http.InputStreamContent;
-import com.google.api.services.drive.Drive;
import org.apache.camel.Converter;
import org.apache.camel.Exchange;
import org.apache.camel.component.file.GenericFile;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
@Converter(generateLoader = true)
public final class GoogleDriveFilesConverter {
- private static final Logger LOG = LoggerFactory.getLogger(GoogleDriveFilesConverter.class);
-
private GoogleDriveFilesConverter() {
}
@@ -64,41 +59,4 @@ public final class GoogleDriveFilesConverter {
}
return null;
}
-
- // TODO: how to download the file
-
- // convenience method that takes google file metadata and converts that to an inputstream
- // @Converter(allowNull = true)
- // public static InputStream download(com.google.api.services.drive.model.File fileMetadata, Exchange exchange)
- // throws Exception {
- // if (fileMetadata.getDownloadUrl() != null && fileMetadata.getDownloadUrl().length() > 0) {
- // try {
- // TODO maybe separate this out as custom drive API ex. google-drive://download...
- // HttpResponse resp = getClient(exchange).getRequestFactory()
- // .buildGetRequest(new GenericUrl(fileMetadata.getDownloadUrl())).execute();
- // return resp.getContent();
- // } catch (IOException e) {
- // LOG.debug("Could not download file.", e);
- // return null;
- // }
- // } else {
- // The file doesn't have any content stored on Drive.
- // return null;
- // }
- // }
-
- // @Converter
- // public static String downloadContentAsString(com.google.api.services.drive.model.File fileMetadata, Exchange exchange)
- // throws Exception {
- // InputStream is = download(fileMetadata, exchange);
- // if (is != null) {
- // return exchange.getContext().getTypeConverter().convertTo(String.class, exchange, is);
- // }
- // return null;
- // }
-
- private static Drive getClient(Exchange exchange) {
- GoogleDriveComponent component = exchange.getContext().getComponent("google-drive", GoogleDriveComponent.class);
- return component.getClient(component.getConfiguration());
- }
}
diff --git a/components/camel-jgroups-raft/src/main/java/org/apache/camel/component/jgroups/raft/JGroupsRaftEndpoint.java b/components/camel-jgroups-raft/src/main/java/org/apache/camel/component/jgroups/raft/JGroupsRaftEndpoint.java
index 22ec8b5ba4f..7d713a275a3 100644
--- a/components/camel-jgroups-raft/src/main/java/org/apache/camel/component/jgroups/raft/JGroupsRaftEndpoint.java
+++ b/components/camel-jgroups-raft/src/main/java/org/apache/camel/component/jgroups/raft/JGroupsRaftEndpoint.java
@@ -69,8 +69,8 @@ public class JGroupsRaftEndpoint extends DefaultEndpoint {
}
@Override
- public Producer createProducer() throws Exception {
- return new JGroupsRaftProducer(this, clusterName);
+ public Producer createProducer() {
+ return new JGroupsRaftProducer(this);
}
@Override
diff --git a/components/camel-jgroups-raft/src/main/java/org/apache/camel/component/jgroups/raft/JGroupsRaftProducer.java b/components/camel-jgroups-raft/src/main/java/org/apache/camel/component/jgroups/raft/JGroupsRaftProducer.java
index 9b40bb59bfa..dca07dfc7b9 100644
--- a/components/camel-jgroups-raft/src/main/java/org/apache/camel/component/jgroups/raft/JGroupsRaftProducer.java
+++ b/components/camel-jgroups-raft/src/main/java/org/apache/camel/component/jgroups/raft/JGroupsRaftProducer.java
@@ -32,14 +32,12 @@ public class JGroupsRaftProducer extends DefaultProducer {
// Producer settings
private final JGroupsRaftEndpoint endpoint;
- private final String clusterName;
// Constructor
- public JGroupsRaftProducer(JGroupsRaftEndpoint endpoint, String clusterName) {
+ public JGroupsRaftProducer(JGroupsRaftEndpoint endpoint) {
super(endpoint);
this.endpoint = endpoint;
- this.clusterName = clusterName;
}
// Life cycle callbacks
diff --git a/components/camel-jooq/src/main/java/org/apache/camel/component/jooq/JooqConsumer.java b/components/camel-jooq/src/main/java/org/apache/camel/component/jooq/JooqConsumer.java
index 25e1659f623..82e7a59f376 100644
--- a/components/camel-jooq/src/main/java/org/apache/camel/component/jooq/JooqConsumer.java
+++ b/components/camel-jooq/src/main/java/org/apache/camel/component/jooq/JooqConsumer.java
@@ -35,7 +35,6 @@ public class JooqConsumer extends ScheduledBatchPollingConsumer {
private static final class DataHolder {
private Exchange exchange;
- private Object result;
private DataHolder() {
}
@@ -63,7 +62,6 @@ public class JooqConsumer extends ScheduledBatchPollingConsumer {
for (UpdatableRecord result : results) {
DataHolder holder = new DataHolder();
- holder.result = result;
holder.exchange = createExchange(result);
answer.add(holder);
}
diff --git a/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/jackson/JacksonJsonAdapter.java b/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/jackson/JacksonJsonAdapter.java
index 58f600525aa..cee4cff2d43 100644
--- a/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/jackson/JacksonJsonAdapter.java
+++ b/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/jackson/JacksonJsonAdapter.java
@@ -35,7 +35,6 @@ public class JacksonJsonAdapter implements JsonPathAdapter {
private static final String JACKSON_JAXB_MODULE = "com.fasterxml.jackson.module.jaxb.JaxbAnnotationModule";
private final ObjectMapper defaultMapper;
- private CamelContext camelContext;
public JacksonJsonAdapter() {
defaultMapper = new ObjectMapper();
@@ -43,7 +42,6 @@ public class JacksonJsonAdapter implements JsonPathAdapter {
@Override
public void init(CamelContext camelContext) {
- this.camelContext = camelContext;
// Attempt to enables JAXB processing so we can easily convert JAXB annotated pojos also
Class<?> clazz = camelContext.getClassResolver().resolveClass(JACKSON_JAXB_MODULE);
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitToOffsetManager.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitToOffsetManager.java
index ba709e82a7e..37f8a13ff15 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitToOffsetManager.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitToOffsetManager.java
@@ -21,11 +21,8 @@ import org.apache.camel.component.kafka.KafkaConsumer;
import org.apache.camel.spi.StateRepository;
import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.common.TopicPartition;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
public class CommitToOffsetManager extends AbstractCommitManager {
- private static final Logger LOG = LoggerFactory.getLogger(CommitToOffsetManager.class);
private final OffsetCache offsetCache = new OffsetCache();
private final StateRepository<String, String> offsetRepository;
diff --git a/components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioComponent.java b/components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioComponent.java
index dc0fc69fd66..8c694eea98c 100644
--- a/components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioComponent.java
+++ b/components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioComponent.java
@@ -22,17 +22,12 @@ import org.apache.camel.CamelContext;
import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.annotations.Component;
import org.apache.camel.support.HealthCheckComponent;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
import static org.apache.camel.util.ObjectHelper.isEmpty;
import static org.apache.camel.util.ObjectHelper.isNotEmpty;
@Component("minio")
public class MinioComponent extends HealthCheckComponent {
-
- private static final Logger LOG = LoggerFactory.getLogger(MinioComponent.class);
-
@Metadata
private MinioConfiguration configuration = new MinioConfiguration();
diff --git a/components/camel-nitrite/src/main/java/org/apache/camel/component/nitrite/NitriteProducer.java b/components/camel-nitrite/src/main/java/org/apache/camel/component/nitrite/NitriteProducer.java
index 030b1bbdcfc..e39be9b7055 100644
--- a/components/camel-nitrite/src/main/java/org/apache/camel/component/nitrite/NitriteProducer.java
+++ b/components/camel-nitrite/src/main/java/org/apache/camel/component/nitrite/NitriteProducer.java
@@ -25,14 +25,11 @@ import org.apache.camel.component.nitrite.operation.common.UpsertOperation;
import org.apache.camel.support.DefaultProducer;
import org.dizitart.no2.NitriteCollection;
import org.dizitart.no2.objects.ObjectRepository;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
/**
* The Nitrite producer.
*/
public class NitriteProducer extends DefaultProducer {
- private static final Logger LOG = LoggerFactory.getLogger(NitriteProducer.class);
private NitriteEndpoint endpoint;
private Consumer<AbstractNitriteOperation> operationValidator = noop -> {
};
diff --git a/components/camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventEndpoint.java b/components/camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventEndpoint.java
index c9757840617..d84675dfbfe 100644
--- a/components/camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventEndpoint.java
+++ b/components/camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventEndpoint.java
@@ -71,8 +71,6 @@ public class PgEventEndpoint extends DefaultEndpoint {
private final String uri;
- private PGConnection dbConnection;
-
public PgEventEndpoint(String uri, PgEventComponent component) {
super(uri, component);
this.uri = uri;
diff --git a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
index 131cece023c..5a113317ca1 100644
--- a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
+++ b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
@@ -39,7 +39,6 @@ import org.apache.pulsar.client.api.PulsarClient;
public class PulsarEndpoint extends DefaultEndpoint {
private PulsarClient pulsarClient;
- private String uri; // TODO this field is reported unread
@UriPath(enums = "persistent,non-persistent")
@Metadata(required = true)
@@ -148,8 +147,6 @@ public class PulsarEndpoint extends DefaultEndpoint {
ObjectHelper.notNull(tenant, "tenant", this);
ObjectHelper.notNull(namespace, "namespace", this);
ObjectHelper.notNull(topic, "topic", this);
-
- uri = persistence + "://" + tenant + "/" + namespace + "/" + topic;
}
@Override
diff --git a/components/camel-rest-openapi/src/main/java/org/apache/camel/component/rest/openapi/RestOpenApiEndpoint.java b/components/camel-rest-openapi/src/main/java/org/apache/camel/component/rest/openapi/RestOpenApiEndpoint.java
index b6b20d75891..9a04ed39ef5 100644
--- a/components/camel-rest-openapi/src/main/java/org/apache/camel/component/rest/openapi/RestOpenApiEndpoint.java
+++ b/components/camel-rest-openapi/src/main/java/org/apache/camel/component/rest/openapi/RestOpenApiEndpoint.java
@@ -96,11 +96,6 @@ import static org.apache.camel.util.StringHelper.notEmpty;
producerOnly = true)
public final class RestOpenApiEndpoint extends DefaultEndpoint {
- /**
- * Regex pattern used to extract path parts from OpenApi specification paths
- */
- private static final Pattern PATH_EXTRACTOR = Pattern.compile("/([^{}/]+)");
-
/**
* Remaining parameters specified in the Endpoint URI.
*/
diff --git a/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestProducerBindingProcessor.java b/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestProducerBindingProcessor.java
index 32db587dea3..3703917668d 100644
--- a/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestProducerBindingProcessor.java
+++ b/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestProducerBindingProcessor.java
@@ -128,7 +128,7 @@ public class RestProducerBindingProcessor extends DelegateAsyncProcessor {
if (ObjectHelper.isEmpty(body)) {
if (outType != null) {
// wrap callback to add reverse operation if we know the output type from the REST service
- callback = new RestProducerBindingUnmarshalCallback(exchange, callback, jsonMarshal, xmlMarshal, false);
+ callback = new RestProducerBindingUnmarshalCallback(exchange, callback, false);
}
// okay now we can continue routing to the producer
return getProcessor().process(exchange, callback);
@@ -139,7 +139,7 @@ public class RestProducerBindingProcessor extends DelegateAsyncProcessor {
// the body is text based and thus not POJO so no binding needed
if (outType != null) {
// wrap callback to add reverse operation if we know the output type from the REST service
- callback = new RestProducerBindingUnmarshalCallback(exchange, callback, jsonMarshal, xmlMarshal, false);
+ callback = new RestProducerBindingUnmarshalCallback(exchange, callback, false);
}
// okay now we can continue routing to the producer
return getProcessor().process(exchange, callback);
@@ -150,7 +150,7 @@ public class RestProducerBindingProcessor extends DelegateAsyncProcessor {
exchange.getIn().setBody(is);
if (outType != null) {
// wrap callback to add reverse operation if we know the output type from the REST service
- callback = new RestProducerBindingUnmarshalCallback(exchange, callback, jsonMarshal, xmlMarshal, false);
+ callback = new RestProducerBindingUnmarshalCallback(exchange, callback, false);
}
// okay now we can continue routing to the producer
return getProcessor().process(exchange, callback);
@@ -189,7 +189,7 @@ public class RestProducerBindingProcessor extends DelegateAsyncProcessor {
ExchangeHelper.prepareOutToIn(exchange);
if (outType != null) {
// wrap callback to add reverse operation if we know the output type from the REST service
- callback = new RestProducerBindingUnmarshalCallback(exchange, callback, jsonMarshal, xmlMarshal, false);
+ callback = new RestProducerBindingUnmarshalCallback(exchange, callback, false);
}
// okay now we can continue routing to the producer
return getProcessor().process(exchange, callback);
@@ -206,7 +206,7 @@ public class RestProducerBindingProcessor extends DelegateAsyncProcessor {
ExchangeHelper.prepareOutToIn(exchange);
if (outType != null) {
// wrap callback to add reverse operation if we know the output type from the REST service
- callback = new RestProducerBindingUnmarshalCallback(exchange, callback, jsonMarshal, xmlMarshal, true);
+ callback = new RestProducerBindingUnmarshalCallback(exchange, callback, true);
}
// okay now we can continue routing to the producer
return getProcessor().process(exchange, callback);
@@ -216,7 +216,7 @@ public class RestProducerBindingProcessor extends DelegateAsyncProcessor {
if ("off".equals(bindingMode) || bindingMode.equals("auto")) {
if (outType != null) {
// wrap callback to add reverse operation if we know the output type from the REST service
- callback = new RestProducerBindingUnmarshalCallback(exchange, callback, jsonMarshal, xmlMarshal, false);
+ callback = new RestProducerBindingUnmarshalCallback(exchange, callback, false);
}
// okay now we can continue routing to the producer
return getProcessor().process(exchange, callback);
@@ -238,16 +238,11 @@ public class RestProducerBindingProcessor extends DelegateAsyncProcessor {
private final Exchange exchange;
private final AsyncCallback callback;
- private final AsyncProcessor jsonMarshal;
- private final AsyncProcessor xmlMarshal;
private boolean wasXml;
- private RestProducerBindingUnmarshalCallback(Exchange exchange, AsyncCallback callback,
- AsyncProcessor jsonMarshal, AsyncProcessor xmlMarshal, boolean wasXml) {
+ private RestProducerBindingUnmarshalCallback(Exchange exchange, AsyncCallback callback, boolean wasXml) {
this.exchange = exchange;
this.callback = callback;
- this.jsonMarshal = jsonMarshal;
- this.xmlMarshal = xmlMarshal;
this.wasXml = wasXml;
}
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/PubSubApiConsumer.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/PubSubApiConsumer.java
index e71d3eec75c..983003e0b93 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/PubSubApiConsumer.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/PubSubApiConsumer.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.salesforce;
-import java.io.IOException;
import java.util.Map;
import com.salesforce.eventbus.protobuf.ReplayPreset;
@@ -28,14 +27,11 @@ import org.apache.camel.component.salesforce.api.SalesforceException;
import org.apache.camel.component.salesforce.internal.client.PubSubApiClient;
import org.apache.camel.support.DefaultConsumer;
import org.apache.camel.support.service.ServiceHelper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
import static org.apache.camel.component.salesforce.SalesforceConstants.HEADER_SALESFORCE_PUBSUB_REPLAY_ID;
public class PubSubApiConsumer extends DefaultConsumer {
- private static final Logger LOG = LoggerFactory.getLogger(PubSubApiConsumer.class);
private final String topic;
private final ReplayPreset initialReplayPreset;
private String initialReplayId;
@@ -66,7 +62,7 @@ public class PubSubApiConsumer extends DefaultConsumer {
}
}
- public void processEvent(Object recordObj, String replayId) throws IOException {
+ public void processEvent(Object recordObj, String replayId) {
final Exchange exchange = createExchange(true);
final Message in = exchange.getIn();
in.setBody(recordObj);
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java
index 57f3ff6298f..e8b3ec1f5e3 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java
@@ -89,7 +89,6 @@ public class SubscriptionHelper extends ServiceSupport {
private volatile boolean reconnecting;
private final AtomicLong handshakeBackoff;
private final AtomicBoolean handshaking = new AtomicBoolean();
- private final AtomicBoolean loggingIn = new AtomicBoolean();
public SubscriptionHelper(final SalesforceComponent component) {
this.component = component;
diff --git a/components/camel-schematron/src/main/java/org/apache/camel/component/schematron/processor/SchematronProcessorFactory.java b/components/camel-schematron/src/main/java/org/apache/camel/component/schematron/processor/SchematronProcessorFactory.java
index 8575c38ca1b..e8861841a15 100644
--- a/components/camel-schematron/src/main/java/org/apache/camel/component/schematron/processor/SchematronProcessorFactory.java
+++ b/components/camel-schematron/src/main/java/org/apache/camel/component/schematron/processor/SchematronProcessorFactory.java
@@ -25,8 +25,6 @@ import org.xml.sax.SAXException;
import org.xml.sax.XMLReader;
import org.apache.camel.component.schematron.exception.SchematronConfigException;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
/**
* Schematron Engine Factory
@@ -34,8 +32,6 @@ import org.slf4j.LoggerFactory;
*/
public final class SchematronProcessorFactory {
- private static final Logger LOG = LoggerFactory.getLogger(SchematronProcessorFactory.class);
-
/**
* Private constructor.
*/
diff --git a/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/DefaultMessagePropertiesConverter.java b/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/DefaultMessagePropertiesConverter.java
index 2087339ca37..4ec4eb62832 100644
--- a/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/DefaultMessagePropertiesConverter.java
+++ b/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/DefaultMessagePropertiesConverter.java
@@ -30,11 +30,9 @@ import org.springframework.amqp.core.MessageProperties;
public class DefaultMessagePropertiesConverter implements MessagePropertiesConverter {
- private final CamelContext camelContext;
private HeaderFilterStrategy headerFilterStrategy;
- public DefaultMessagePropertiesConverter(CamelContext camelContext) {
- this.camelContext = camelContext;
+ public DefaultMessagePropertiesConverter() {
}
@Override
diff --git a/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/EndpointMessageListener.java b/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/EndpointMessageListener.java
index 81a974100c0..2dda0bd9ec2 100644
--- a/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/EndpointMessageListener.java
+++ b/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/EndpointMessageListener.java
@@ -34,7 +34,6 @@ import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageProperties;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
-import org.springframework.amqp.support.converter.MessageConverter;
import static org.apache.camel.RuntimeCamelException.wrapRuntimeCamelException;
@@ -45,8 +44,6 @@ public class EndpointMessageListener implements ChannelAwareMessageListener {
private final SpringRabbitMQConsumer consumer;
private final SpringRabbitMQEndpoint endpoint;
private final AsyncProcessor processor;
- private final MessagePropertiesConverter messagePropertiesConverter;
- private final MessageConverter messageConverter;
private RabbitTemplate template;
private boolean disableReplyTo;
private boolean async;
@@ -55,8 +52,6 @@ public class EndpointMessageListener implements ChannelAwareMessageListener {
this.consumer = consumer;
this.endpoint = endpoint;
this.processor = AsyncProcessorConverterHelper.convert(processor);
- this.messagePropertiesConverter = endpoint.getMessagePropertiesConverter();
- this.messageConverter = endpoint.getMessageConverter();
}
public boolean isAsync() {
diff --git a/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/SpringRabbitMQComponent.java b/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/SpringRabbitMQComponent.java
index e54d3789ef7..6cf816a9b37 100644
--- a/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/SpringRabbitMQComponent.java
+++ b/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/SpringRabbitMQComponent.java
@@ -124,7 +124,7 @@ public class SpringRabbitMQComponent extends HeaderFilterStrategyComponent {
messageConverter = new DefaultMessageConverter(getCamelContext());
}
if (messagePropertiesConverter == null) {
- messagePropertiesConverter = new DefaultMessagePropertiesConverter(getCamelContext());
+ messagePropertiesConverter = new DefaultMessagePropertiesConverter();
}
}
diff --git a/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/SqlStoredComponent.java b/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/SqlStoredComponent.java
index 1a4f329c8d8..fea5a377605 100644
--- a/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/SqlStoredComponent.java
+++ b/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/SqlStoredComponent.java
@@ -26,15 +26,11 @@ import org.apache.camel.spi.annotations.Component;
import org.apache.camel.support.DefaultComponent;
import org.apache.camel.support.PropertyBindingSupport;
import org.apache.camel.util.PropertiesHelper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
import org.springframework.jdbc.core.JdbcTemplate;
@Component("sql-stored")
public class SqlStoredComponent extends DefaultComponent {
- private static final Logger LOG = LoggerFactory.getLogger(SqlStoredComponent.class);
-
@Metadata(autowired = true)
private DataSource dataSource;
diff --git a/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftConsumer.java b/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftConsumer.java
index 28173b9159e..67dbf49eff6 100644
--- a/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftConsumer.java
+++ b/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftConsumer.java
@@ -105,7 +105,7 @@ public class ThriftConsumer extends DefaultConsumer {
Object serverImplementationInstance;
Object serverProcessor;
ProxyFactory serviceProxy = new ProxyFactory();
- MethodHandler methodHandler = new ThriftMethodHandler(endpoint, this);
+ MethodHandler methodHandler = new ThriftMethodHandler(this);
try {
Class serverInterface = ThriftUtils.getServerInterface(endpoint.getServicePackage(), endpoint.getServiceName(),
diff --git a/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/server/ThriftMethodHandler.java b/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/server/ThriftMethodHandler.java
index 4ad70951d24..1154a41a0ad 100644
--- a/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/server/ThriftMethodHandler.java
+++ b/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/server/ThriftMethodHandler.java
@@ -34,11 +34,9 @@ import org.apache.thrift.async.AsyncMethodCallback;
* Thrift server methods invocation handler
*/
public class ThriftMethodHandler implements MethodHandler {
- private final ThriftEndpoint endpoint;
private final ThriftConsumer consumer;
- public ThriftMethodHandler(ThriftEndpoint endpoint, ThriftConsumer consumer) {
- this.endpoint = endpoint;
+ public ThriftMethodHandler(ThriftConsumer consumer) {
this.consumer = consumer;
}
diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java
index eafbd9c65d3..bd4b9906a15 100644
--- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java
+++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java
@@ -57,7 +57,6 @@ public class XmppConsumer extends DefaultConsumer implements IncomingChatMessage
private final XmppEndpoint endpoint;
private MultiUserChat muc;
- private Chat privateChat;
private ChatManager chatManager;
private XMPPTCPConnection connection;
private ScheduledExecutorService scheduledExecutor;
@@ -96,7 +95,7 @@ public class XmppConsumer extends DefaultConsumer implements IncomingChatMessage
}
if (endpoint.getRoom() == null) {
- privateChat = chatManager.chatWith(JidCreate.entityBareFrom(endpoint.resolveParticipant(connection)));
+ chatManager.chatWith(JidCreate.entityBareFrom(endpoint.resolveParticipant(connection)));
} else {
// add the presence packet listener to the connection so we only get packets that concerns us
// we must add the listener before creating the muc
diff --git a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/ZeebeProducer.java b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/ZeebeProducer.java
index a20e36fd185..70cb9cc1875 100644
--- a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/ZeebeProducer.java
+++ b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/ZeebeProducer.java
@@ -26,17 +26,12 @@ import org.apache.camel.component.zeebe.processor.MessageProcessor;
import org.apache.camel.component.zeebe.processor.ProcessProcessor;
import org.apache.camel.component.zeebe.processor.ZeebeProcessor;
import org.apache.camel.support.DefaultProducer;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
public class ZeebeProducer extends DefaultProducer {
- private static final Logger LOG = LoggerFactory.getLogger(ZeebeProducer.class);
- private ZeebeEndpoint endpoint;
private ZeebeProcessor processor;
public ZeebeProducer(ZeebeEndpoint endpoint) {
super(endpoint);
- this.endpoint = endpoint;
final OperationName operationName = endpoint.getOperationName();
if (isProcessOperation(operationName)) {
diff --git a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/processor/JobProcessor.java b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/processor/JobProcessor.java
index 0d984017aa8..d5a95ca2488 100644
--- a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/processor/JobProcessor.java
+++ b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/processor/JobProcessor.java
@@ -26,12 +26,8 @@ import org.apache.camel.component.zeebe.internal.ZeebeService;
import org.apache.camel.component.zeebe.model.JobRequest;
import org.apache.camel.component.zeebe.model.JobResponse;
import org.apache.camel.component.zeebe.model.JobWorkerMessage;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
public class JobProcessor extends AbstractBaseProcessor {
- private static final Logger LOG = LoggerFactory.getLogger(JobProcessor.class);
-
public JobProcessor(ZeebeEndpoint endpoint) {
super(endpoint);
}
diff --git a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/processor/MessageProcessor.java b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/processor/MessageProcessor.java
index 013c0efc49a..71526d8347c 100644
--- a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/processor/MessageProcessor.java
+++ b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/processor/MessageProcessor.java
@@ -24,11 +24,8 @@ import org.apache.camel.component.zeebe.ZeebeEndpoint;
import org.apache.camel.component.zeebe.internal.ZeebeService;
import org.apache.camel.component.zeebe.model.MessageRequest;
import org.apache.camel.component.zeebe.model.MessageResponse;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
public class MessageProcessor extends AbstractBaseProcessor {
- private static final Logger LOG = LoggerFactory.getLogger(MessageProcessor.class);
public MessageProcessor(ZeebeEndpoint endpoint) {
super(endpoint);
diff --git a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/processor/ProcessProcessor.java b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/processor/ProcessProcessor.java
index 1e541cc7b82..cf41d42c465 100644
--- a/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/processor/ProcessProcessor.java
+++ b/components/camel-zeebe/src/main/java/org/apache/camel/component/zeebe/processor/ProcessProcessor.java
@@ -24,13 +24,8 @@ import org.apache.camel.component.zeebe.ZeebeEndpoint;
import org.apache.camel.component.zeebe.internal.ZeebeService;
import org.apache.camel.component.zeebe.model.ProcessRequest;
import org.apache.camel.component.zeebe.model.ProcessResponse;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
public class ProcessProcessor extends AbstractBaseProcessor {
-
- private static final Logger LOG = LoggerFactory.getLogger(ProcessProcessor.class);
-
public ProcessProcessor(ZeebeEndpoint endpoint) {
super(endpoint);
}
diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultAutowiredLifecycleStrategy.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultAutowiredLifecycleStrategy.java
index 02f74565a70..89ec35d1927 100644
--- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultAutowiredLifecycleStrategy.java
+++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultAutowiredLifecycleStrategy.java
@@ -23,13 +23,8 @@ import org.apache.camel.spi.AutowiredLifecycleStrategy;
import org.apache.camel.spi.DataFormat;
import org.apache.camel.spi.Language;
import org.apache.camel.support.LifecycleStrategySupport;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
class DefaultAutowiredLifecycleStrategy extends LifecycleStrategySupport implements AutowiredLifecycleStrategy, Ordered {
-
- private static final Logger LOG = LoggerFactory.getLogger(DefaultAutowiredLifecycleStrategy.class);
-
private final CamelContext camelContext;
public DefaultAutowiredLifecycleStrategy(CamelContext camelContext) {
diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/LoopProcessor.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/LoopProcessor.java
index 9ed496f0e1e..776ef59184e 100644
--- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/LoopProcessor.java
+++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/LoopProcessor.java
@@ -49,7 +49,6 @@ public class LoopProcessor extends DelegateAsyncProcessor implements Traceable,
private String id;
private String routeId;
private boolean shutdownPending;
- private final CamelContext camelContext;
private final ReactiveExecutor reactiveExecutor;
private final Expression expression;
private final Predicate predicate;
@@ -60,7 +59,6 @@ public class LoopProcessor extends DelegateAsyncProcessor implements Traceable,
public LoopProcessor(CamelContext camelContext, Processor processor, Expression expression, Predicate predicate,
boolean copy, boolean breakOnShutdown) {
super(processor);
- this.camelContext = camelContext;
this.reactiveExecutor = camelContext.getCamelContextExtension().getReactiveExecutor();
this.expression = expression;
this.predicate = predicate;
diff --git a/dsl/camel-dsl-modeline/src/main/java/org/apache/camel/dsl/modeline/DefaultModelineFactory.java b/dsl/camel-dsl-modeline/src/main/java/org/apache/camel/dsl/modeline/DefaultModelineFactory.java
index 21c00fc06ce..610272dd7c0 100644
--- a/dsl/camel-dsl-modeline/src/main/java/org/apache/camel/dsl/modeline/DefaultModelineFactory.java
+++ b/dsl/camel-dsl-modeline/src/main/java/org/apache/camel/dsl/modeline/DefaultModelineFactory.java
@@ -81,7 +81,7 @@ public class DefaultModelineFactory extends ServiceSupport
}
protected ModelineParser createModelineParser() {
- return new DefaultModelineParser(camelContext);
+ return new DefaultModelineParser();
}
@Override
diff --git a/dsl/camel-dsl-modeline/src/main/java/org/apache/camel/dsl/modeline/DefaultModelineParser.java b/dsl/camel-dsl-modeline/src/main/java/org/apache/camel/dsl/modeline/DefaultModelineParser.java
index d626c1da6f8..3a9e61a3448 100644
--- a/dsl/camel-dsl-modeline/src/main/java/org/apache/camel/dsl/modeline/DefaultModelineParser.java
+++ b/dsl/camel-dsl-modeline/src/main/java/org/apache/camel/dsl/modeline/DefaultModelineParser.java
@@ -23,7 +23,6 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import org.apache.camel.CamelContext;
import org.apache.camel.spi.CamelContextCustomizer;
import org.apache.camel.spi.Resource;
import org.apache.camel.util.StringHelper;
@@ -33,12 +32,9 @@ public class DefaultModelineParser implements ModelineParser {
public static final String MODELINE_START = "camel-k:";
- private final CamelContext camelContext;
private final Map<String, Trait> traits = new HashMap<>();
- public DefaultModelineParser(CamelContext camelContext) {
- this.camelContext = camelContext;
-
+ public DefaultModelineParser() {
// add known traits
Trait trait = new DependencyTrait();
this.traits.put(trait.getName(), trait);
diff --git a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/KameletMain.java b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/KameletMain.java
index 51fa8585d42..b893cdd603d 100644
--- a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/KameletMain.java
+++ b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/KameletMain.java
@@ -102,7 +102,6 @@ public class KameletMain extends MainCommandLineSupport {
private String repos;
private boolean fresh;
private boolean verbose;
- private boolean debug;
private String mavenSettings;
private String mavenSettingsSecurity;
private String stubPattern;
@@ -351,7 +350,6 @@ public class KameletMain extends MainCommandLineSupport {
@Override
protected CamelContext createCamelContext() {
this.verbose = "true".equals(getInitialProperties().get("camel.jbang.verbose"));
- this.debug = "true".equals(getInitialProperties().get("camel.jbang.debug"));
// do not build/init camel context yet
DefaultCamelContext answer = new DefaultCamelContext(false);
@@ -363,7 +361,7 @@ public class KameletMain extends MainCommandLineSupport {
PluginHelper.getPackageScanClassResolver(answer).addClassLoader(dynamicCL);
PluginHelper.getPackageScanResourceResolver(answer).addClassLoader(dynamicCL);
- KnownReposResolver known = new KnownReposResolver(camelContext);
+ KnownReposResolver known = new KnownReposResolver();
known.loadKnownDependencies();
MavenDependencyDownloader downloader = new MavenDependencyDownloader();
downloader.setKnownReposResolver(known);
diff --git a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderDataFormatResolver.java b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderDataFormatResolver.java
index 867fa5b834d..6e599f8e797 100644
--- a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderDataFormatResolver.java
+++ b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderDataFormatResolver.java
@@ -32,11 +32,9 @@ import org.apache.camel.tooling.model.DataFormatModel;
public final class DependencyDownloaderDataFormatResolver extends DefaultDataFormatResolver {
private final CamelCatalog catalog = new DefaultCamelCatalog();
- private final CamelContext camelContext;
private final DependencyDownloader downloader;
public DependencyDownloaderDataFormatResolver(CamelContext camelContext) {
- this.camelContext = camelContext;
this.downloader = camelContext.hasService(DependencyDownloader.class);
}
diff --git a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderLanguageResolver.java b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderLanguageResolver.java
index ed8d62c97d5..19a081b93b0 100644
--- a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderLanguageResolver.java
+++ b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderLanguageResolver.java
@@ -32,11 +32,9 @@ import org.apache.camel.tooling.model.LanguageModel;
public final class DependencyDownloaderLanguageResolver extends DefaultLanguageResolver {
private final CamelCatalog catalog = new DefaultCamelCatalog();
- private CamelContext camelContext;
private final DependencyDownloader downloader;
public DependencyDownloaderLanguageResolver(CamelContext camelContext) {
- this.camelContext = camelContext;
this.downloader = camelContext.hasService(DependencyDownloader.class);
}
diff --git a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderPropertyBindingListener.java b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderPropertyBindingListener.java
index 66946796818..705784e8f1e 100644
--- a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderPropertyBindingListener.java
+++ b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderPropertyBindingListener.java
@@ -22,13 +22,11 @@ import org.apache.camel.tooling.maven.MavenGav;
public class DependencyDownloaderPropertyBindingListener implements PropertyBindingListener {
- private final CamelContext camelContext;
private final KnownDependenciesResolver knownDependenciesResolver;
private final DependencyDownloader downloader;
public DependencyDownloaderPropertyBindingListener(CamelContext camelContext,
KnownDependenciesResolver knownDependenciesResolver) {
- this.camelContext = camelContext;
this.knownDependenciesResolver = knownDependenciesResolver;
this.downloader = camelContext.hasService(DependencyDownloader.class);
}
diff --git a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderUriFactoryResolver.java b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderUriFactoryResolver.java
index 5ddbe0b3768..681f7c31048 100644
--- a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderUriFactoryResolver.java
+++ b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderUriFactoryResolver.java
@@ -29,11 +29,9 @@ import org.apache.camel.tooling.model.ComponentModel;
public class DependencyDownloaderUriFactoryResolver extends DefaultUriFactoryResolver {
private final CamelCatalog catalog = new DefaultCamelCatalog();
- private final CamelContext camelContext;
private final DependencyDownloader downloader;
public DependencyDownloaderUriFactoryResolver(CamelContext camelContext) {
- this.camelContext = camelContext;
this.downloader = camelContext.hasService(DependencyDownloader.class);
}
diff --git a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DownloadModelineParser.java b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DownloadModelineParser.java
index 97555054790..340f94a38c4 100644
--- a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DownloadModelineParser.java
+++ b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DownloadModelineParser.java
@@ -26,7 +26,7 @@ public class DownloadModelineParser extends DefaultModelineParser {
private final DependencyDownloader downloader;
public DownloadModelineParser(CamelContext camelContext) {
- super(camelContext);
+ super();
this.downloader = camelContext.hasService(DependencyDownloader.class);
}
diff --git a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/KameletMainInjector.java b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/KameletMainInjector.java
index 8e8a7449bdd..2a2817cae6d 100644
--- a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/KameletMainInjector.java
+++ b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/KameletMainInjector.java
@@ -30,12 +30,10 @@ public class KameletMainInjector implements Injector {
private final Injector delegate;
private final String stubPattern;
- private final boolean silent;
public KameletMainInjector(Injector delegate, String stubPattern, boolean silent) {
this.delegate = delegate;
this.stubPattern = stubPattern;
- this.silent = silent;
}
@Override
diff --git a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/KnownReposResolver.java b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/KnownReposResolver.java
index 251bcbdd30b..20a583d4072 100644
--- a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/KnownReposResolver.java
+++ b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/KnownReposResolver.java
@@ -21,15 +21,11 @@ import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
-import org.apache.camel.CamelContext;
-
public final class KnownReposResolver {
private final Map<String, String> repos = new HashMap<>();
- private final CamelContext camelContext;
- public KnownReposResolver(CamelContext camelContext) {
- this.camelContext = camelContext;
+ public KnownReposResolver() {
}
public void loadKnownDependencies() {
diff --git a/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/support/YamlProperties.java b/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/support/YamlProperties.java
index adb2db45c80..fa962a8f64c 100644
--- a/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/support/YamlProperties.java
+++ b/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/support/YamlProperties.java
@@ -41,7 +41,6 @@ public final class YamlProperties {
private boolean required;
private boolean deprecated;
private boolean secret;
- private Schema schema;
private String oneOf;
public AnnotationBuilder withName(String name) {