You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2022/01/03 21:21:48 UTC
[camel] branch main updated: (chores) add missing @Override annotations (#6626)
This is an automated email from the ASF dual-hosted git repository.
davsclaus 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 26904ba (chores) add missing @Override annotations (#6626)
26904ba is described below
commit 26904ba9d6aa09326c282ab063bfe1ba51dcf2f6
Author: Otavio Rodolfo Piske <or...@users.noreply.github.com>
AuthorDate: Mon Jan 3 22:21:00 2022 +0100
(chores) add missing @Override annotations (#6626)
---
.../apache/camel/catalog/DefaultCamelCatalog.java | 1 +
.../camel/converter/crypto/CryptoDataFormat.java | 4 +++
.../org/apache/camel/component/cxf/CxfPayload.java | 4 +++
.../org/apache/camel/component/cxf/DataFormat.java | 1 +
.../component/cxf/HybridSourceDataBinding.java | 1 +
.../camel/component/cxf/jaxrs/CxfRsEndpoint.java | 1 +
.../camel/component/file/GenericFileEndpoint.java | 1 +
.../camel/component/flatpack/DataSetList.java | 1 +
.../hazelcast/topic/HazelcastTopicConsumer.java | 1 +
.../ReplicatedHazelcastAggregationRepository.java | 1 +
.../camel/component/jetty/JettyHttpComponent.java | 2 ++
.../apache/camel/component/jpa/JpaEndpoint.java | 1 +
.../camel/component/mail/MailAuthenticator.java | 1 +
.../apache/camel/component/mail/MailConsumer.java | 2 ++
.../health/CamelMicroProfileLivenessCheck.java | 1 +
.../health/CamelMicroProfileReadinessCheck.java | 1 +
.../camel/component/mock/MockExpressionClause.java | 12 +++++++
.../camel/component/resteasy/ResteasyEndpoint.java | 2 ++
.../resteasy/servlet/ResteasyCamelServlet.java | 2 ++
.../camel/component/undertow/UndertowConsumer.java | 3 ++
.../org/apache/camel/component/xj/XJComponent.java | 1 +
.../component/xslt/saxon/XsltSaxonComponent.java | 1 +
.../component/xslt/saxon/XsltSaxonEndpoint.java | 2 ++
.../camel/catalog/EndpointValidationResult.java | 1 +
.../catalog/impl/DefaultRuntimeCamelCatalog.java | 2 ++
.../org/apache/camel/language/ref/RefLanguage.java | 1 +
.../language/simple/SimpleExpressionBuilder.java | 31 ++++++++++++++++++
.../org/apache/camel/builder/ExpressionClause.java | 6 ++++
.../camel/builder/RouteConfigurationBuilder.java | 1 +
.../apache/camel/model/AggregateDefinition.java | 1 +
.../org/apache/camel/model/ChoiceDefinition.java | 4 +++
.../camel/model/RouteTemplatesDefinition.java | 2 ++
.../org/apache/camel/model/RoutesDefinition.java | 2 ++
.../cloud/ServiceCallExpressionConfiguration.java | 1 +
.../ServiceCallServiceChooserConfiguration.java | 1 +
.../ServiceCallServiceDiscoveryConfiguration.java | 1 +
.../ServiceCallServiceFilterConfiguration.java | 1 +
...erviceCallServiceLoadBalancerConfiguration.java | 1 +
.../apache/camel/model/rest/RestsDefinition.java | 2 ++
.../java/org/apache/camel/processor/Splitter.java | 1 +
.../management/mbean/ManagedRouteController.java | 1 +
.../converter/stream/FileInputStreamCache.java | 2 ++
.../org/apache/camel/support/DefaultComponent.java | 1 +
.../org/apache/camel/support/ObjectHelper.java | 3 ++
.../camel/support/builder/ExpressionBuilder.java | 37 ++++++++++++++++++++++
.../startup/LoggingStartupStepRecorder.java | 1 +
.../apache/camel/util/SkipLastByteInputStream.java | 1 +
.../EndpointRouteConfigurationBuilder.java | 1 +
.../common/YamlDeserializerEndpointAwareBase.java | 1 +
.../packaging/EndpointSchemaGeneratorMojo.java | 1 +
50 files changed, 155 insertions(+)
diff --git a/catalog/camel-catalog/src/main/java/org/apache/camel/catalog/DefaultCamelCatalog.java b/catalog/camel-catalog/src/main/java/org/apache/camel/catalog/DefaultCamelCatalog.java
index 9934ffe..bfe16c9 100644
--- a/catalog/camel-catalog/src/main/java/org/apache/camel/catalog/DefaultCamelCatalog.java
+++ b/catalog/camel-catalog/src/main/java/org/apache/camel/catalog/DefaultCamelCatalog.java
@@ -342,6 +342,7 @@ public class DefaultCamelCatalog extends AbstractCamelCatalog implements CamelCa
return cache("other-model-" + name, name, super::otherModel);
}
+ @Override
public String mainJSonSchema() {
return cache("main", "main", k -> super.mainJSonSchema());
}
diff --git a/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/CryptoDataFormat.java b/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/CryptoDataFormat.java
index 08350a6..d744a35 100644
--- a/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/CryptoDataFormat.java
+++ b/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/CryptoDataFormat.java
@@ -227,16 +227,20 @@ public class CryptoDataFormat extends ServiceSupport implements DataFormat, Data
return shouldAppendHMAC ? new HMACAccumulator(key, macAlgorithm, cryptoProvider, bufferSize) : new HMACAccumulator() {
byte[] empty = new byte[0];
+ @Override
public void encryptUpdate(byte[] buffer, int read) {
}
+ @Override
public void decryptUpdate(byte[] buffer, int read) throws IOException {
outputStream.write(buffer, 0, read);
}
+ @Override
public void validate() {
}
+ @Override
public byte[] getCalculatedMac() {
return empty;
}
diff --git a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfPayload.java b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfPayload.java
index 973543b..3d66431 100644
--- a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfPayload.java
+++ b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfPayload.java
@@ -62,10 +62,12 @@ public class CxfPayload<T> {
*/
public List<Element> getBody() {
return new AbstractList<Element>() {
+ @Override
public boolean add(Element e) {
return body.add(new DOMSource(e));
}
+ @Override
public Element set(int index, Element element) {
Source s = body.set(index, new DOMSource(element));
try {
@@ -75,10 +77,12 @@ public class CxfPayload<T> {
}
}
+ @Override
public void add(int index, Element element) {
body.add(index, new DOMSource(element));
}
+ @Override
public Element remove(int index) {
Source s = body.remove(index);
try {
diff --git a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/DataFormat.java b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/DataFormat.java
index 66e9eec..e3f916c 100644
--- a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/DataFormat.java
+++ b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/DataFormat.java
@@ -53,6 +53,7 @@ public enum DataFormat {
*/
@Deprecated
MESSAGE {
+ @Override
public DataFormat dealias() {
return RAW;
}
diff --git a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/HybridSourceDataBinding.java b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/HybridSourceDataBinding.java
index 88b91c4..8a40c81 100644
--- a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/HybridSourceDataBinding.java
+++ b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/HybridSourceDataBinding.java
@@ -71,6 +71,7 @@ public class HybridSourceDataBinding extends JAXBDataBinding {
if (cls == XMLStreamWriter.class) {
return (DataWriter<T>) new XMLStreamDataWriter() {
+ @Override
public void write(Object obj, MessagePartInfo part, XMLStreamWriter output) {
if (obj == null) {
return;
diff --git a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java
index db1ff13..8a3f46d 100644
--- a/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java
+++ b/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java
@@ -381,6 +381,7 @@ public class CxfRsEndpoint extends DefaultEndpoint implements HeaderFilterStrate
protected JAXRSServerFactoryBean newJAXRSServerFactoryBean() {
return new JAXRSServerFactoryBean() {
+ @Override
protected boolean isValidClassResourceInfo(ClassResourceInfo cri) {
// CXF will consider interfaces created for managing model resources
// invalid - however it is fine with Camel processors if no service invocation
diff --git a/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java b/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java
index 02826b1..d787023 100644
--- a/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java
+++ b/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java
@@ -1545,6 +1545,7 @@ public abstract class GenericFileEndpoint<T> extends ScheduledPollEndpoint imple
/**
* Set up the exchange properties with the options of the file endpoint
*/
+ @Override
public void configureExchange(Exchange exchange) {
// Now we just set the charset property here
if (getCharset() != null) {
diff --git a/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/DataSetList.java b/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/DataSetList.java
index c4bf86f..745b763 100644
--- a/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/DataSetList.java
+++ b/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/DataSetList.java
@@ -78,6 +78,7 @@ public class DataSetList extends AbstractList<Map<String, Object>> implements Da
return result;
}
+ @Override
public void remove() {
throw new UnsupportedOperationException("remove() not supported");
}
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicConsumer.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicConsumer.java
index 67a1a2a..b3354f4 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicConsumer.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicConsumer.java
@@ -48,6 +48,7 @@ public class HazelcastTopicConsumer extends HazelcastDefaultConsumer {
listener = topic.addMessageListener(new CamelMessageListener(this, cacheName));
}
+ @Override
protected void doStop() throws Exception {
topic.removeMessageListener(listener);
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/ReplicatedHazelcastAggregationRepository.java b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/ReplicatedHazelcastAggregationRepository.java
index 021e5c6..b041d2c 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/ReplicatedHazelcastAggregationRepository.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/ReplicatedHazelcastAggregationRepository.java
@@ -233,6 +233,7 @@ public class ReplicatedHazelcastAggregationRepository extends HazelcastAggregati
*
* @param key Object - key in question
*/
+ @Override
public boolean containsKey(Object key) {
if (replicatedCache != null) {
return replicatedCache.containsKey(key);
diff --git a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
index 4daaf0f..389966f 100644
--- a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
+++ b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
@@ -1270,6 +1270,7 @@ public abstract class JettyHttpComponent extends HttpCommonComponent
} else {
//need an error handler that won't leak information about the exception back to the client.
ErrorHandler eh = new ErrorHandler() {
+ @Override
public void handle(
String target, Request baseRequest,
HttpServletRequest request, HttpServletResponse response)
@@ -1279,6 +1280,7 @@ public abstract class JettyHttpComponent extends HttpCommonComponent
super.handle(target, baseRequest, request, response);
}
+ @Override
protected void writeErrorPage(
HttpServletRequest request, Writer writer, int code,
String message, boolean showStacks)
diff --git a/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java b/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
index d2697fc..46c941b 100644
--- a/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
+++ b/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
@@ -570,6 +570,7 @@ public class JpaEndpoint extends ScheduledPollEndpoint {
protected Expression createProducerExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
Object answer;
diff --git a/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailAuthenticator.java b/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailAuthenticator.java
index eaa9f8c..6d0d771 100644
--- a/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailAuthenticator.java
+++ b/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailAuthenticator.java
@@ -25,6 +25,7 @@ public class MailAuthenticator extends javax.mail.Authenticator {
// makes the method public
/** Override this method in your implementation. */
+ @Override
public PasswordAuthentication getPasswordAuthentication() {
return super.getPasswordAuthentication();
}
diff --git a/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailConsumer.java b/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailConsumer.java
index 41443b8..0cfa090 100644
--- a/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailConsumer.java
+++ b/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailConsumer.java
@@ -242,10 +242,12 @@ public class MailConsumer extends ScheduledBatchPollingConsumer {
// add on completion to handle after work when the exchange is done
exchange.adapt(ExtendedExchange.class).addOnCompletion(new SynchronizationAdapter() {
+ @Override
public void onComplete(Exchange exchange) {
processCommit(mail, exchange);
}
+ @Override
public void onFailure(Exchange exchange) {
processRollback(mail, exchange);
}
diff --git a/components/camel-microprofile/camel-microprofile-health/src/main/java/org/apache/camel/microprofile/health/CamelMicroProfileLivenessCheck.java b/components/camel-microprofile/camel-microprofile-health/src/main/java/org/apache/camel/microprofile/health/CamelMicroProfileLivenessCheck.java
index 95335d8..61ef1c4 100644
--- a/components/camel-microprofile/camel-microprofile-health/src/main/java/org/apache/camel/microprofile/health/CamelMicroProfileLivenessCheck.java
+++ b/components/camel-microprofile/camel-microprofile-health/src/main/java/org/apache/camel/microprofile/health/CamelMicroProfileLivenessCheck.java
@@ -25,6 +25,7 @@ import org.eclipse.microprofile.health.Liveness;
@Liveness
public class CamelMicroProfileLivenessCheck extends AbstractCamelMicroProfileHealthCheck {
+ @Override
public boolean isReadiness() {
return false;
}
diff --git a/components/camel-microprofile/camel-microprofile-health/src/main/java/org/apache/camel/microprofile/health/CamelMicroProfileReadinessCheck.java b/components/camel-microprofile/camel-microprofile-health/src/main/java/org/apache/camel/microprofile/health/CamelMicroProfileReadinessCheck.java
index 7c1514a..0ff301c 100644
--- a/components/camel-microprofile/camel-microprofile-health/src/main/java/org/apache/camel/microprofile/health/CamelMicroProfileReadinessCheck.java
+++ b/components/camel-microprofile/camel-microprofile-health/src/main/java/org/apache/camel/microprofile/health/CamelMicroProfileReadinessCheck.java
@@ -25,6 +25,7 @@ import org.eclipse.microprofile.health.Readiness;
@Readiness
public class CamelMicroProfileReadinessCheck extends AbstractCamelMicroProfileHealthCheck {
+ @Override
public boolean isLiveness() {
return false;
}
diff --git a/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockExpressionClause.java b/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockExpressionClause.java
index 2f51376..b51c88d 100644
--- a/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockExpressionClause.java
+++ b/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockExpressionClause.java
@@ -78,6 +78,7 @@ public class MockExpressionClause<T> implements Expression, Predicate {
*/
public T exchange(final Function<Exchange, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange);
}
@@ -110,6 +111,7 @@ public class MockExpressionClause<T> implements Expression, Predicate {
*/
public T inMessage(final Function<Message, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange.getIn());
}
@@ -121,6 +123,7 @@ public class MockExpressionClause<T> implements Expression, Predicate {
*/
public T outMessage(final Function<Message, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange.getOut());
}
@@ -139,6 +142,7 @@ public class MockExpressionClause<T> implements Expression, Predicate {
*/
public T body(final Function<Object, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange.getIn().getBody());
}
@@ -150,6 +154,7 @@ public class MockExpressionClause<T> implements Expression, Predicate {
*/
public T body(final Supplier<Object> supplier) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return supplier.get();
}
@@ -161,6 +166,7 @@ public class MockExpressionClause<T> implements Expression, Predicate {
*/
public T body(final BiFunction<Object, Map<String, Object>, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(
exchange.getIn().getBody(),
@@ -181,6 +187,7 @@ public class MockExpressionClause<T> implements Expression, Predicate {
*/
public <B> T body(Class<B> expectedType, final Function<B, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange.getIn().getBody(expectedType));
}
@@ -192,6 +199,7 @@ public class MockExpressionClause<T> implements Expression, Predicate {
*/
public <B> T body(Class<B> expectedType, final BiFunction<B, Map<String, Object>, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(
exchange.getIn().getBody(expectedType),
@@ -205,6 +213,7 @@ public class MockExpressionClause<T> implements Expression, Predicate {
*/
public T outBody(final Function<Object, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange.getOut().getBody());
}
@@ -216,6 +225,7 @@ public class MockExpressionClause<T> implements Expression, Predicate {
*/
public T outBody(final BiFunction<Object, Map<String, Object>, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(
exchange.getOut().getBody(),
@@ -229,6 +239,7 @@ public class MockExpressionClause<T> implements Expression, Predicate {
*/
public <B> T outBody(Class<B> expectedType, final Function<B, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange.getOut().getBody(expectedType));
}
@@ -240,6 +251,7 @@ public class MockExpressionClause<T> implements Expression, Predicate {
*/
public <B> T outBody(Class<B> expectedType, final BiFunction<B, Map<String, Object>, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(
exchange.getOut().getBody(expectedType),
diff --git a/components/camel-resteasy/src/main/java/org/apache/camel/component/resteasy/ResteasyEndpoint.java b/components/camel-resteasy/src/main/java/org/apache/camel/component/resteasy/ResteasyEndpoint.java
index 68e58ad..4798ff4 100644
--- a/components/camel-resteasy/src/main/java/org/apache/camel/component/resteasy/ResteasyEndpoint.java
+++ b/components/camel-resteasy/src/main/java/org/apache/camel/component/resteasy/ResteasyEndpoint.java
@@ -167,6 +167,7 @@ public class ResteasyEndpoint extends HttpEndpoint {
this.resteasyMethod = resteasyMethod;
}
+ @Override
public String getProtocol() {
return protocol;
}
@@ -189,6 +190,7 @@ public class ResteasyEndpoint extends HttpEndpoint {
this.host = host;
}
+ @Override
public int getPort() {
return port;
}
diff --git a/components/camel-resteasy/src/main/java/org/apache/camel/component/resteasy/servlet/ResteasyCamelServlet.java b/components/camel-resteasy/src/main/java/org/apache/camel/component/resteasy/servlet/ResteasyCamelServlet.java
index a8291b7..419251c 100644
--- a/components/camel-resteasy/src/main/java/org/apache/camel/component/resteasy/servlet/ResteasyCamelServlet.java
+++ b/components/camel-resteasy/src/main/java/org/apache/camel/component/resteasy/servlet/ResteasyCamelServlet.java
@@ -293,6 +293,7 @@ public class ResteasyCamelServlet extends HttpServletDispatcher implements HttpR
/**
* Destroy ResteasyCamelServlet and delete registry created by it
*/
+ @Override
public void destroy() {
DefaultHttpRegistry.removeHttpRegistry(getServletName());
if (httpRegistry != null) {
@@ -351,6 +352,7 @@ public class ResteasyCamelServlet extends HttpServletDispatcher implements HttpR
return answer;
}
+ @Override
public String getServletName() {
return servletName;
}
diff --git a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConsumer.java b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConsumer.java
index 89f1ffc..87a8243 100644
--- a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConsumer.java
+++ b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConsumer.java
@@ -144,16 +144,19 @@ public class UndertowConsumer extends DefaultConsumer implements HttpHandler, Su
endpoint.getComponent().unregisterEndpoint(this, endpoint.getHttpHandlerRegistrationInfo(), endpoint.getSslContext());
}
+ @Override
protected void doSuspend() throws Exception {
this.suspended = true;
super.doSuspend();
}
+ @Override
protected void doResume() throws Exception {
this.suspended = false;
super.doResume();
}
+ @Override
public boolean isSuspended() {
return this.suspended;
}
diff --git a/components/camel-xj/src/main/java/org/apache/camel/component/xj/XJComponent.java b/components/camel-xj/src/main/java/org/apache/camel/component/xj/XJComponent.java
index 7981282..c685c09 100644
--- a/components/camel-xj/src/main/java/org/apache/camel/component/xj/XJComponent.java
+++ b/components/camel-xj/src/main/java/org/apache/camel/component/xj/XJComponent.java
@@ -29,6 +29,7 @@ public class XJComponent extends XsltSaxonComponent {
public XJComponent() {
}
+ @Override
protected XJEndpoint createXsltEndpoint(String uri) {
return new XJEndpoint(uri, this);
}
diff --git a/components/camel-xslt-saxon/src/main/java/org/apache/camel/component/xslt/saxon/XsltSaxonComponent.java b/components/camel-xslt-saxon/src/main/java/org/apache/camel/component/xslt/saxon/XsltSaxonComponent.java
index 027a518..c25b1fc 100644
--- a/components/camel-xslt-saxon/src/main/java/org/apache/camel/component/xslt/saxon/XsltSaxonComponent.java
+++ b/components/camel-xslt-saxon/src/main/java/org/apache/camel/component/xslt/saxon/XsltSaxonComponent.java
@@ -85,6 +85,7 @@ public class XsltSaxonComponent extends XsltComponent {
this.saxonConfigurationProperties = configurationProperties;
}
+ @Override
protected XsltSaxonEndpoint createXsltEndpoint(String uri) {
return new XsltSaxonEndpoint(uri, this);
}
diff --git a/components/camel-xslt-saxon/src/main/java/org/apache/camel/component/xslt/saxon/XsltSaxonEndpoint.java b/components/camel-xslt-saxon/src/main/java/org/apache/camel/component/xslt/saxon/XsltSaxonEndpoint.java
index bb207eb..2928754 100644
--- a/components/camel-xslt-saxon/src/main/java/org/apache/camel/component/xslt/saxon/XsltSaxonEndpoint.java
+++ b/components/camel-xslt-saxon/src/main/java/org/apache/camel/component/xslt/saxon/XsltSaxonEndpoint.java
@@ -171,6 +171,7 @@ public class XsltSaxonEndpoint extends XsltEndpoint {
}
}
+ @Override
protected XsltSaxonBuilder createXsltBuilder() throws Exception {
final CamelContext ctx = getCamelContext();
final ClassResolver resolver = ctx.getClassResolver();
@@ -236,6 +237,7 @@ public class XsltSaxonEndpoint extends XsltEndpoint {
* @throws TransformerException is thrown if error loading resource
* @throws IOException is thrown if error loading resource
*/
+ @Override
protected void loadResource(String resourceUri, XsltBuilder xslt) throws TransformerException, IOException {
LOG.trace("{} loading schema resource: {}", this, resourceUri);
Source source = xslt.getUriResolver().resolve(resourceUri, null);
diff --git a/core/camel-api/src/main/java/org/apache/camel/catalog/EndpointValidationResult.java b/core/camel-api/src/main/java/org/apache/camel/catalog/EndpointValidationResult.java
index 32bbe13..c674f91 100644
--- a/core/camel-api/src/main/java/org/apache/camel/catalog/EndpointValidationResult.java
+++ b/core/camel-api/src/main/java/org/apache/camel/catalog/EndpointValidationResult.java
@@ -46,6 +46,7 @@ public class EndpointValidationResult extends PropertiesValidationResult impleme
return uri;
}
+ @Override
public boolean isSuccess() {
boolean ok = super.isSuccess();
if (ok) {
diff --git a/core/camel-core-catalog/src/main/java/org/apache/camel/catalog/impl/DefaultRuntimeCamelCatalog.java b/core/camel-core-catalog/src/main/java/org/apache/camel/catalog/impl/DefaultRuntimeCamelCatalog.java
index 89c821f..8ab4630 100644
--- a/core/camel-core-catalog/src/main/java/org/apache/camel/catalog/impl/DefaultRuntimeCamelCatalog.java
+++ b/core/camel-core-catalog/src/main/java/org/apache/camel/catalog/impl/DefaultRuntimeCamelCatalog.java
@@ -112,10 +112,12 @@ public class DefaultRuntimeCamelCatalog extends AbstractCamelCatalog implements
return cache("other-model-" + name, name, super::otherModel);
}
+ @Override
public String mainJSonSchema() {
return cache("main", "main", k -> super.mainJSonSchema());
}
+ @Override
public MainModel mainModel() {
return cache("main-model", "main-model", k -> super.mainModel());
}
diff --git a/core/camel-core-languages/src/main/java/org/apache/camel/language/ref/RefLanguage.java b/core/camel-core-languages/src/main/java/org/apache/camel/language/ref/RefLanguage.java
index 0b31f1e..d9bd8cd 100644
--- a/core/camel-core-languages/src/main/java/org/apache/camel/language/ref/RefLanguage.java
+++ b/core/camel-core-languages/src/main/java/org/apache/camel/language/ref/RefLanguage.java
@@ -49,6 +49,7 @@ public class RefLanguage extends LanguageSupport {
exp.init(context);
}
+ @Override
public Object evaluate(Exchange exchange) {
Expression target = null;
diff --git a/core/camel-core-languages/src/main/java/org/apache/camel/language/simple/SimpleExpressionBuilder.java b/core/camel-core-languages/src/main/java/org/apache/camel/language/simple/SimpleExpressionBuilder.java
index 9fb0a80..6393016 100644
--- a/core/camel-core-languages/src/main/java/org/apache/camel/language/simple/SimpleExpressionBuilder.java
+++ b/core/camel-core-languages/src/main/java/org/apache/camel/language/simple/SimpleExpressionBuilder.java
@@ -91,6 +91,7 @@ public final class SimpleExpressionBuilder {
}
}
+ @Override
public Object evaluate(Exchange exchange) {
return MessageHelper.dumpMessageHistoryStacktrace(exchange, formatter, false);
}
@@ -145,6 +146,7 @@ public final class SimpleExpressionBuilder {
exp.init(context);
}
+ @Override
public Object evaluate(Exchange exchange) {
return exp.evaluate(exchange, Object.class);
}
@@ -169,6 +171,7 @@ public final class SimpleExpressionBuilder {
exp.init(context);
}
+ @Override
public Object evaluate(Exchange exchange) {
return skipIteratorExpression(exp, number).evaluate(exchange, Object.class);
}
@@ -188,6 +191,7 @@ public final class SimpleExpressionBuilder {
private Expression exp1;
private Expression exp2;
+ @Override
public Object evaluate(Exchange exchange) {
int num1 = exp1.evaluate(exchange, Integer.class);
int num2 = exp2.evaluate(exchange, Integer.class);
@@ -223,6 +227,7 @@ public final class SimpleExpressionBuilder {
*/
public static Expression randomExpression(final int min, final int max) {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
Random random = new Random(); // NOSONAR
int randomNum = random.nextInt(max - min) + min;
@@ -238,6 +243,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileNameExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getIn().getHeader(Exchange.FILE_NAME, String.class);
}
@@ -251,6 +257,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileOnlyNameExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
String answer = exchange.getIn().getHeader(Exchange.FILE_NAME_ONLY, String.class);
if (answer == null) {
@@ -269,6 +276,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileNameNoExtensionExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
String name = exchange.getIn().getHeader(Exchange.FILE_NAME, String.class);
return FileUtil.stripExt(name);
@@ -283,6 +291,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileNameNoExtensionSingleExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
String name = exchange.getIn().getHeader(Exchange.FILE_NAME, String.class);
return FileUtil.stripExt(name, true);
@@ -297,6 +306,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileOnlyNameNoExtensionExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
String name = fileOnlyNameExpression().evaluate(exchange, String.class);
return FileUtil.stripExt(name);
@@ -311,6 +321,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileOnlyNameNoExtensionSingleExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
String name = fileOnlyNameExpression().evaluate(exchange, String.class);
return FileUtil.stripExt(name, true);
@@ -325,6 +336,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileExtensionExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
String name = exchange.getIn().getHeader(Exchange.FILE_NAME, String.class);
return FileUtil.onlyExt(name);
@@ -339,6 +351,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileExtensionSingleExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
String name = exchange.getIn().getHeader(Exchange.FILE_NAME, String.class);
return FileUtil.onlyExt(name, true);
@@ -353,6 +366,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileParentExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getIn().getHeader("CamelFileParent", String.class);
}
@@ -366,6 +380,7 @@ public final class SimpleExpressionBuilder {
public static Expression filePathExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getIn().getHeader("CamelFilePath", String.class);
}
@@ -379,6 +394,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileAbsolutePathExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getIn().getHeader("CamelFileAbsolutePath", String.class);
}
@@ -392,6 +408,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileAbsoluteExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getIn().getHeader("CamelFileAbsolute", Boolean.class);
}
@@ -405,6 +422,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileSizeExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getIn().getHeader(Exchange.FILE_LENGTH, Long.class);
}
@@ -418,6 +436,7 @@ public final class SimpleExpressionBuilder {
public static Expression fileLastModifiedExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getIn().getHeader(Exchange.FILE_LAST_MODIFIED, Long.class);
}
@@ -449,6 +468,7 @@ public final class SimpleExpressionBuilder {
}
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
Date date;
if ("now".equals(command)) {
@@ -524,6 +544,7 @@ public final class SimpleExpressionBuilder {
public static Expression skipIteratorExpression(final Expression expression, final int skip) {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
// evaluate expression as iterator
Iterator<?> it = expression.evaluate(exchange, Iterator.class);
@@ -544,6 +565,7 @@ public final class SimpleExpressionBuilder {
*/
public static Expression nullExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return null;
}
@@ -565,6 +587,7 @@ public final class SimpleExpressionBuilder {
private Expression exp;
private Language bean;
+ @Override
public Object evaluate(Exchange exchange) {
String text = exp.evaluate(exchange, String.class);
Class<?> type;
@@ -607,6 +630,7 @@ public final class SimpleExpressionBuilder {
private ClassResolver classResolver;
private Expression exp;
+ @Override
public Object evaluate(Exchange exchange) {
String text = exp.evaluate(exchange, String.class);
Class<?> type;
@@ -646,6 +670,7 @@ public final class SimpleExpressionBuilder {
private Expression exp;
private Language bean;
+ @Override
public Object evaluate(Exchange exchange) {
String text = exp.evaluate(exchange, String.class);
Class<?> type;
@@ -690,6 +715,7 @@ public final class SimpleExpressionBuilder {
return new ExpressionAdapter() {
private Language bean;
+ @Override
public Object evaluate(Exchange exchange) {
// ognl is able to evaluate method name if it contains nested functions
// so we should not eager evaluate ognl as a string
@@ -725,6 +751,7 @@ public final class SimpleExpressionBuilder {
exp.init(context);
}
+ @Override
public Object evaluate(Exchange exchange) {
// ognl is able to evaluate method name if it contains nested functions
// so we should not eager evaluate ognl as a string
@@ -747,6 +774,7 @@ public final class SimpleExpressionBuilder {
return new ExpressionAdapter() {
private Language bean;
+ @Override
public Object evaluate(Exchange exchange) {
Object body = exchange.getIn().getBody();
if (body == null) {
@@ -780,6 +808,7 @@ public final class SimpleExpressionBuilder {
return new ExpressionAdapter() {
private final AtomicReference<Object> cache = new AtomicReference<>();
+ @Override
public Object evaluate(Exchange exchange) {
Object answer = cache.get();
if (answer == null) {
@@ -814,6 +843,7 @@ public final class SimpleExpressionBuilder {
exp.init(context);
}
+ @Override
public Object evaluate(Exchange exchange) {
// it may refer to a class type
String text = exp.evaluate(exchange, String.class);
@@ -867,6 +897,7 @@ public final class SimpleExpressionBuilder {
return new ExpressionAdapter() {
private Language bean;
+ @Override
public Object evaluate(Exchange exchange) {
Object exception = exchange.getException();
if (exception == null) {
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/builder/ExpressionClause.java b/core/camel-core-model/src/main/java/org/apache/camel/builder/ExpressionClause.java
index 974eb3a..59f402c 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/builder/ExpressionClause.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/builder/ExpressionClause.java
@@ -90,6 +90,7 @@ public class ExpressionClause<T> implements Expression, Predicate {
*/
public T exchange(final Function<Exchange, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange);
}
@@ -122,6 +123,7 @@ public class ExpressionClause<T> implements Expression, Predicate {
*/
public T inMessage(final Function<Message, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange.getIn());
}
@@ -140,6 +142,7 @@ public class ExpressionClause<T> implements Expression, Predicate {
*/
public T body(final Function<Object, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange.getIn().getBody());
}
@@ -151,6 +154,7 @@ public class ExpressionClause<T> implements Expression, Predicate {
*/
public T body(final BiFunction<Object, Map<String, Object>, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange.getIn().getBody(), exchange.getIn().getHeaders());
}
@@ -169,6 +173,7 @@ public class ExpressionClause<T> implements Expression, Predicate {
*/
public <B> T body(Class<B> expectedType, final Function<B, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange.getIn().getBody(expectedType));
}
@@ -180,6 +185,7 @@ public class ExpressionClause<T> implements Expression, Predicate {
*/
public <B> T body(Class<B> expectedType, final BiFunction<B, Map<String, Object>, Object> function) {
return delegate.expression(new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(exchange.getIn().getBody(expectedType), exchange.getIn().getHeaders());
}
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/builder/RouteConfigurationBuilder.java b/core/camel-core-model/src/main/java/org/apache/camel/builder/RouteConfigurationBuilder.java
index a9cb26e..9b7b43e 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/builder/RouteConfigurationBuilder.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/builder/RouteConfigurationBuilder.java
@@ -37,6 +37,7 @@ public abstract class RouteConfigurationBuilder extends RouteBuilder implements
// noop
}
+ @Override
public abstract void configuration() throws Exception;
public RouteConfigurationsDefinition getRouteConfigurationCollection() {
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/AggregateDefinition.java b/core/camel-core-model/src/main/java/org/apache/camel/model/AggregateDefinition.java
index f7422ef..d1ae8bb 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/AggregateDefinition.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/AggregateDefinition.java
@@ -1149,6 +1149,7 @@ public class AggregateDefinition extends OutputDefinition<AggregateDefinition>
}
@XmlElementRef
+ @Override
public void setOutputs(List<ProcessorDefinition<?>> outputs) {
super.setOutputs(outputs);
}
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/ChoiceDefinition.java b/core/camel-core-model/src/main/java/org/apache/camel/model/ChoiceDefinition.java
index a52cc9c..5196433 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/ChoiceDefinition.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/ChoiceDefinition.java
@@ -70,6 +70,7 @@ public class ChoiceDefinition extends ProcessorDefinition<ChoiceDefinition> impl
throw new IndexOutOfBoundsException("Index " + index + " is out of bounds with size " + size());
}
+ @Override
public boolean add(ProcessorDefinition<?> def) {
if (def instanceof WhenDefinition) {
return whenClauses.add((WhenDefinition) def);
@@ -86,11 +87,13 @@ public class ChoiceDefinition extends ProcessorDefinition<ChoiceDefinition> impl
return whenClauses.size() + (otherwise == null ? 0 : 1);
}
+ @Override
public void clear() {
whenClauses.clear();
otherwise = null;
}
+ @Override
public ProcessorDefinition<?> set(int index, ProcessorDefinition<?> element) {
if (index < whenClauses.size()) {
if (element instanceof WhenDefinition) {
@@ -106,6 +109,7 @@ public class ChoiceDefinition extends ProcessorDefinition<ChoiceDefinition> impl
throw new IndexOutOfBoundsException("Index " + index + " is out of bounds with size " + size());
}
+ @Override
public ProcessorDefinition<?> remove(int index) {
if (index < whenClauses.size()) {
return whenClauses.remove(index);
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/RouteTemplatesDefinition.java b/core/camel-core-model/src/main/java/org/apache/camel/model/RouteTemplatesDefinition.java
index 0beaddd..053dc7b 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/RouteTemplatesDefinition.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/RouteTemplatesDefinition.java
@@ -78,10 +78,12 @@ public class RouteTemplatesDefinition extends OptionalIdentifiedDefinition<Route
this.routeTemplates = routeTemplates;
}
+ @Override
public CamelContext getCamelContext() {
return camelContext;
}
+ @Override
public void setCamelContext(CamelContext camelContext) {
this.camelContext = camelContext;
}
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/RoutesDefinition.java b/core/camel-core-model/src/main/java/org/apache/camel/model/RoutesDefinition.java
index 1ef0a31..d24b38a 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/RoutesDefinition.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/RoutesDefinition.java
@@ -138,10 +138,12 @@ public class RoutesDefinition extends OptionalIdentifiedDefinition<RoutesDefinit
this.onCompletions = onCompletions;
}
+ @Override
public CamelContext getCamelContext() {
return camelContext;
}
+ @Override
public void setCamelContext(CamelContext camelContext) {
this.camelContext = camelContext;
}
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallExpressionConfiguration.java b/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallExpressionConfiguration.java
index b91c1b2..4777058 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallExpressionConfiguration.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallExpressionConfiguration.java
@@ -79,6 +79,7 @@ public class ServiceCallExpressionConfiguration extends ServiceCallConfiguration
//
// *************************************************************************
+ @Override
public ServiceCallServiceChooserConfiguration property(String key, String value) {
return (ServiceCallServiceChooserConfiguration) super.property(key, value);
}
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceChooserConfiguration.java b/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceChooserConfiguration.java
index ebcf386..b65e614 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceChooserConfiguration.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceChooserConfiguration.java
@@ -66,6 +66,7 @@ public class ServiceCallServiceChooserConfiguration extends ServiceCallConfigura
//
// *************************************************************************
+ @Override
public ServiceCallServiceChooserConfiguration property(String key, String value) {
return (ServiceCallServiceChooserConfiguration) super.property(key, value);
}
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceDiscoveryConfiguration.java b/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceDiscoveryConfiguration.java
index 7300510..8f6e5aa 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceDiscoveryConfiguration.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceDiscoveryConfiguration.java
@@ -68,6 +68,7 @@ public class ServiceCallServiceDiscoveryConfiguration extends ServiceCallConfigu
//
// *************************************************************************
+ @Override
public ServiceCallServiceDiscoveryConfiguration property(String key, String value) {
return (ServiceCallServiceDiscoveryConfiguration) super.property(key, value);
}
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceFilterConfiguration.java b/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceFilterConfiguration.java
index c806db6..241720f 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceFilterConfiguration.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceFilterConfiguration.java
@@ -72,6 +72,7 @@ public class ServiceCallServiceFilterConfiguration extends ServiceCallConfigurat
* These properties are specific to what service call implementation are in use. For example if using ribbon, then
* the client properties are define in com.netflix.client.config.CommonClientConfigKey.
*/
+ @Override
public ServiceCallServiceFilterConfiguration property(String key, String value) {
return (ServiceCallServiceFilterConfiguration) super.property(key, value);
}
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceLoadBalancerConfiguration.java b/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceLoadBalancerConfiguration.java
index 36008ad..a1f6721 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceLoadBalancerConfiguration.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/cloud/ServiceCallServiceLoadBalancerConfiguration.java
@@ -73,6 +73,7 @@ public class ServiceCallServiceLoadBalancerConfiguration extends ServiceCallConf
* These properties are specific to what service call implementation are in use. For example if using ribbon, then
* the client properties are define in com.netflix.client.config.CommonClientConfigKey.
*/
+ @Override
public ServiceCallServiceLoadBalancerConfiguration property(String key, String value) {
return (ServiceCallServiceLoadBalancerConfiguration) super.property(key, value);
}
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/rest/RestsDefinition.java b/core/camel-core-model/src/main/java/org/apache/camel/model/rest/RestsDefinition.java
index 3b8b150..f051889 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/rest/RestsDefinition.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/rest/RestsDefinition.java
@@ -76,10 +76,12 @@ public class RestsDefinition extends OptionalIdentifiedDefinition<RestsDefinitio
this.rests = rests;
}
+ @Override
public CamelContext getCamelContext() {
return camelContext;
}
+ @Override
public void setCamelContext(CamelContext camelContext) {
this.camelContext = camelContext;
}
diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/Splitter.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/Splitter.java
index b87adce..49be665 100644
--- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/Splitter.java
+++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/Splitter.java
@@ -251,6 +251,7 @@ public class Splitter extends MulticastProcessor implements AsyncProcessor, Trac
}
}
+ @Override
public void remove() {
throw new UnsupportedOperationException("Remove is not supported by this iterator");
}
diff --git a/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedRouteController.java b/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedRouteController.java
index 7a040a1..0245c43 100644
--- a/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedRouteController.java
+++ b/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedRouteController.java
@@ -41,6 +41,7 @@ public class ManagedRouteController extends ManagedService implements ManagedRou
return controller;
}
+ @Override
public void init(ManagementStrategy strategy) {
// do nothing
}
diff --git a/core/camel-support/src/main/java/org/apache/camel/converter/stream/FileInputStreamCache.java b/core/camel-support/src/main/java/org/apache/camel/converter/stream/FileInputStreamCache.java
index 8eb6bc9..5cb3fbb 100644
--- a/core/camel-support/src/main/java/org/apache/camel/converter/stream/FileInputStreamCache.java
+++ b/core/camel-support/src/main/java/org/apache/camel/converter/stream/FileInputStreamCache.java
@@ -140,6 +140,7 @@ public final class FileInputStreamCache extends InputStream implements StreamCac
in = new CipherInputStream(in, ciphers.createDecryptor()) {
boolean closed;
+ @Override
public void close() throws IOException {
if (!closed) {
super.close();
@@ -280,6 +281,7 @@ public final class FileInputStreamCache extends InputStream implements StreamCac
out = new CipherOutputStream(out, ciphers.getEncryptor()) {
boolean closed;
+ @Override
public void close() throws IOException {
if (!closed) {
super.close();
diff --git a/core/camel-support/src/main/java/org/apache/camel/support/DefaultComponent.java b/core/camel-support/src/main/java/org/apache/camel/support/DefaultComponent.java
index e7e1982..2b518b7 100644
--- a/core/camel-support/src/main/java/org/apache/camel/support/DefaultComponent.java
+++ b/core/camel-support/src/main/java/org/apache/camel/support/DefaultComponent.java
@@ -244,6 +244,7 @@ public abstract class DefaultComponent extends ServiceSupport implements Compone
this.bridgeErrorHandler = bridgeErrorHandler;
}
+ @Override
public boolean isAutowiredEnabled() {
return autowiredEnabled;
}
diff --git a/core/camel-support/src/main/java/org/apache/camel/support/ObjectHelper.java b/core/camel-support/src/main/java/org/apache/camel/support/ObjectHelper.java
index 3d21f38..4b19be8 100644
--- a/core/camel-support/src/main/java/org/apache/camel/support/ObjectHelper.java
+++ b/core/camel-support/src/main/java/org/apache/camel/support/ObjectHelper.java
@@ -712,6 +712,7 @@ public final class ObjectHelper {
return Array.get(array, idx++);
}
+ @Override
public void remove() {
throw new UnsupportedOperationException();
}
@@ -738,6 +739,7 @@ public final class ObjectHelper {
return nodeList.item(idx++);
}
+ @Override
public void remove() {
throw new UnsupportedOperationException();
}
@@ -791,6 +793,7 @@ public final class ObjectHelper {
return s;
}
+ @Override
public void remove() {
throw new UnsupportedOperationException();
}
diff --git a/core/camel-support/src/main/java/org/apache/camel/support/builder/ExpressionBuilder.java b/core/camel-support/src/main/java/org/apache/camel/support/builder/ExpressionBuilder.java
index 008c1b4..551e2d2 100644
--- a/core/camel-support/src/main/java/org/apache/camel/support/builder/ExpressionBuilder.java
+++ b/core/camel-support/src/main/java/org/apache/camel/support/builder/ExpressionBuilder.java
@@ -185,6 +185,7 @@ public class ExpressionBuilder {
*/
public static Expression headersExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getIn().getHeaders();
}
@@ -204,6 +205,7 @@ public class ExpressionBuilder {
*/
public static Expression exchangePatternExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getPattern();
}
@@ -223,6 +225,7 @@ public class ExpressionBuilder {
*/
public static Expression exchangeExceptionExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
Exception exception = exchange.getException();
if (exception == null) {
@@ -249,6 +252,7 @@ public class ExpressionBuilder {
*/
public static Expression exchangeExceptionExpression(final Class<Exception> type) {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
Exception exception = exchange.getException(type);
if (exception == null) {
@@ -274,6 +278,7 @@ public class ExpressionBuilder {
return new ExpressionAdapter() {
private TypeConverter typeConverter;
+ @Override
public Object evaluate(Exchange exchange) {
return typeConverter;
}
@@ -299,6 +304,7 @@ public class ExpressionBuilder {
return new ExpressionAdapter() {
private Registry registry;
+ @Override
public Object evaluate(Exchange exchange) {
return registry;
}
@@ -365,6 +371,7 @@ public class ExpressionBuilder {
return new ExpressionAdapter() {
private CamelContext context;
+ @Override
public Object evaluate(Exchange exchange) {
return context;
}
@@ -390,6 +397,7 @@ public class ExpressionBuilder {
return new ConstantExpressionAdapter() {
private String name;
+ @Override
public Object evaluate(Exchange exchange) {
return name;
}
@@ -414,6 +422,7 @@ public class ExpressionBuilder {
*/
public static Expression exchangeExceptionMessageExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
Exception exception = exchange.getException();
if (exception == null) {
@@ -436,6 +445,7 @@ public class ExpressionBuilder {
*/
public static Expression exchangeExceptionStackTraceExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
Exception exception = exchange.getException();
if (exception == null) {
@@ -502,6 +512,7 @@ public class ExpressionBuilder {
*/
public static Expression exchangePropertiesExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getProperties();
}
@@ -522,6 +533,7 @@ public class ExpressionBuilder {
return new ExpressionAdapter() {
private Map<String, String> globalOptions;
+ @Override
public Object evaluate(Exchange exchange) {
return globalOptions;
}
@@ -704,6 +716,7 @@ public class ExpressionBuilder {
*/
public static Expression constantExpression(final Object value) {
return new ConstantExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return value;
}
@@ -738,6 +751,7 @@ public class ExpressionBuilder {
exp.init(context);
}
+ @Override
public Object evaluate(Exchange exchange) {
return exp.evaluate(exchange, Object.class);
}
@@ -760,6 +774,7 @@ public class ExpressionBuilder {
private Expression expr;
private Predicate pred;
+ @Override
public Object evaluate(Exchange exchange) {
return expr.evaluate(exchange, Object.class);
}
@@ -794,6 +809,7 @@ public class ExpressionBuilder {
*/
public static Expression bodyExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getIn().getBody();
}
@@ -810,6 +826,7 @@ public class ExpressionBuilder {
*/
public static Expression bodyExpression(final Function<Object, Object> function) {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(
exchange.getIn().getBody()
@@ -828,6 +845,7 @@ public class ExpressionBuilder {
*/
public static Expression bodyExpression(final BiFunction<Object, Map<String, Object>, Object> function) {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(
exchange.getIn().getBody(),
@@ -847,6 +865,7 @@ public class ExpressionBuilder {
*/
public static <T> Expression bodyExpression(final Class<T> bodyType, final Function<T, Object> function) {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(
exchange.getIn().getBody(bodyType)
@@ -865,6 +884,7 @@ public class ExpressionBuilder {
*/
public static <T> Expression bodyExpression(final Class<T> bodyType, final BiFunction<T, Map<String, Object>, Object> function) {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return function.apply(
exchange.getIn().getBody(bodyType),
@@ -885,6 +905,7 @@ public class ExpressionBuilder {
*/
public static <T> Expression bodyExpression(final Class<T> type) {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getIn().getBody(type);
}
@@ -1327,6 +1348,7 @@ public class ExpressionBuilder {
return new ExpressionAdapter() {
private Expression groupExp;
+ @Override
public Object evaluate(Exchange exchange) {
// evaluate expression as iterator
Iterator<?> it = expression.evaluate(exchange, Iterator.class);
@@ -1367,6 +1389,7 @@ public class ExpressionBuilder {
@SuppressWarnings({"unchecked", "rawtypes"})
public static Expression sortExpression(final Expression expression, final Comparator comparator) {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
List<?> list = expression.evaluate(exchange, List.class);
list.sort(comparator);
@@ -1393,6 +1416,7 @@ public class ExpressionBuilder {
final String regex, final String replacement) {
final Pattern pattern = Pattern.compile(regex);
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
String text = expression.evaluate(exchange, String.class);
if (text == null) {
@@ -1450,6 +1474,7 @@ public class ExpressionBuilder {
*/
public static Expression append(final Expression left, final Expression right) {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return left.evaluate(exchange, String.class) + right.evaluate(exchange, String.class);
}
@@ -1472,6 +1497,7 @@ public class ExpressionBuilder {
*/
public static Expression prepend(final Expression left, final Expression right) {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return right.evaluate(exchange, String.class) + left.evaluate(exchange, String.class);
}
@@ -1513,6 +1539,7 @@ public class ExpressionBuilder {
private Collection<Object> col;
+ @Override
public Object evaluate(Exchange exchange) {
StringBuilder buffer = new StringBuilder();
if (col != null) {
@@ -1579,6 +1606,7 @@ public class ExpressionBuilder {
*/
public static Expression messageIdExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getIn().getMessageId();
}
@@ -1595,6 +1623,7 @@ public class ExpressionBuilder {
*/
public static Expression messageTimestampExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getIn().getMessageTimestamp();
}
@@ -1611,6 +1640,7 @@ public class ExpressionBuilder {
*/
public static Expression exchangeIdExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return exchange.getExchangeId();
}
@@ -1627,6 +1657,7 @@ public class ExpressionBuilder {
*/
public static Expression routeIdExpression() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
return ExchangeHelper.getRouteId(exchange);
}
@@ -1644,6 +1675,7 @@ public class ExpressionBuilder {
private Expression exp;
private Language language;
+ @Override
public Object evaluate(Exchange exchange) {
return exp.evaluate(exchange, Object.class);
}
@@ -1670,6 +1702,7 @@ public class ExpressionBuilder {
private Expression exp;
private Language language;
+ @Override
public Object evaluate(Exchange exchange) {
// bean is able to evaluate method name if it contains nested functions
// so we should not eager evaluate expression as a string
@@ -1695,6 +1728,7 @@ public class ExpressionBuilder {
private Language language;
private Expression exp;
+ @Override
public Object evaluate(Exchange exchange) {
return exp.evaluate(exchange, Object.class);
}
@@ -1717,6 +1751,7 @@ public class ExpressionBuilder {
private Expression exp;
private PropertiesComponent pc;
+ @Override
public Object evaluate(Exchange exchange) {
String text = exp.evaluate(exchange, String.class);
try {
@@ -1778,6 +1813,7 @@ public class ExpressionBuilder {
private Language language;
private Expression exp;
+ @Override
public Object evaluate(Exchange exchange) {
return exp.evaluate(exchange, Object.class);
}
@@ -1801,6 +1837,7 @@ public class ExpressionBuilder {
*/
public static Expression bodyOneLine() {
return new ExpressionAdapter() {
+ @Override
public Object evaluate(Exchange exchange) {
String body = exchange.getIn().getBody(String.class);
if (body == null) {
diff --git a/core/camel-support/src/main/java/org/apache/camel/support/startup/LoggingStartupStepRecorder.java b/core/camel-support/src/main/java/org/apache/camel/support/startup/LoggingStartupStepRecorder.java
index 3c73db0..9938087 100644
--- a/core/camel-support/src/main/java/org/apache/camel/support/startup/LoggingStartupStepRecorder.java
+++ b/core/camel-support/src/main/java/org/apache/camel/support/startup/LoggingStartupStepRecorder.java
@@ -33,6 +33,7 @@ public class LoggingStartupStepRecorder extends DefaultStartupStepRecorder {
setEnabled(true);
}
+ @Override
protected void onEndStep(StartupStep step) {
if (LOG.isInfoEnabled()) {
long delta = System.currentTimeMillis() - step.getBeginTime();
diff --git a/core/camel-util/src/main/java/org/apache/camel/util/SkipLastByteInputStream.java b/core/camel-util/src/main/java/org/apache/camel/util/SkipLastByteInputStream.java
index c68233c..b219a32 100644
--- a/core/camel-util/src/main/java/org/apache/camel/util/SkipLastByteInputStream.java
+++ b/core/camel-util/src/main/java/org/apache/camel/util/SkipLastByteInputStream.java
@@ -85,6 +85,7 @@ public class SkipLastByteInputStream extends BufferedInputStream {
return count;
}
+ @Override
public boolean markSupported() {
/* we do not want callers to mess with mark() and reset() because we use it ourselves */
return false;
diff --git a/dsl/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/EndpointRouteConfigurationBuilder.java b/dsl/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/EndpointRouteConfigurationBuilder.java
index 7122067..8ea37c5 100644
--- a/dsl/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/EndpointRouteConfigurationBuilder.java
+++ b/dsl/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/EndpointRouteConfigurationBuilder.java
@@ -37,6 +37,7 @@ public abstract class EndpointRouteConfigurationBuilder extends EndpointRouteBui
// noop
}
+ @Override
public abstract void configuration() throws Exception;
public RouteConfigurationsDefinition getRouteConfigurationCollection() {
diff --git a/dsl/camel-yaml-dsl/camel-yaml-dsl-common/src/main/java/org/apache/camel/dsl/yaml/common/YamlDeserializerEndpointAwareBase.java b/dsl/camel-yaml-dsl/camel-yaml-dsl-common/src/main/java/org/apache/camel/dsl/yaml/common/YamlDeserializerEndpointAwareBase.java
index c5ce979..d79d739 100644
--- a/dsl/camel-yaml-dsl/camel-yaml-dsl-common/src/main/java/org/apache/camel/dsl/yaml/common/YamlDeserializerEndpointAwareBase.java
+++ b/dsl/camel-yaml-dsl/camel-yaml-dsl-common/src/main/java/org/apache/camel/dsl/yaml/common/YamlDeserializerEndpointAwareBase.java
@@ -38,6 +38,7 @@ public abstract class YamlDeserializerEndpointAwareBase<T> extends YamlDeseriali
* @param node the node
* @param target the target object
*/
+ @Override
protected void setProperties(T target, MappingNode node) {
YamlDeserializationContext dc = getDeserializationContext(node);
diff --git a/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/EndpointSchemaGeneratorMojo.java b/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/EndpointSchemaGeneratorMojo.java
index 88a3296..e70d556 100644
--- a/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/EndpointSchemaGeneratorMojo.java
+++ b/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/EndpointSchemaGeneratorMojo.java
@@ -305,6 +305,7 @@ public class EndpointSchemaGeneratorMojo extends AbstractGeneratorMojo {
}
}
+ @Override
protected boolean updateResource(Path dir, String file, String data) {
resources.put(file, data);
return super.updateResource(dir, file, data);