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 d653bd008ce (chores): code cleanup in ExtendedExchangeExtension (#12652) d653bd008ce is described below commit d653bd008cec75917b6af82cfdafd496eb5b8f37 Author: Otavio Rodolfo Piske <orpi...@users.noreply.github.com> AuthorDate: Thu Jan 4 11:58:48 2024 +0100 (chores): code cleanup in ExtendedExchangeExtension (#12652) - Added missing @Override - Fixed formatting --- .../java/org/apache/camel/support/ExtendedExchangeExtension.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/core/camel-support/src/main/java/org/apache/camel/support/ExtendedExchangeExtension.java b/core/camel-support/src/main/java/org/apache/camel/support/ExtendedExchangeExtension.java index c7da62bee23..bb41cac492f 100644 --- a/core/camel-support/src/main/java/org/apache/camel/support/ExtendedExchangeExtension.java +++ b/core/camel-support/src/main/java/org/apache/camel/support/ExtendedExchangeExtension.java @@ -75,6 +75,7 @@ public class ExtendedExchangeExtension implements ExchangeExtension { /** * Is stream caching disabled on the given exchange */ + @Override public boolean isStreamCacheDisabled() { return this.streamCacheDisabled; } @@ -82,6 +83,7 @@ public class ExtendedExchangeExtension implements ExchangeExtension { /** * Used to force disabling stream caching which some components can do in special use-cases. */ + @Override public void setStreamCacheDisabled(boolean streamCacheDisabled) { this.streamCacheDisabled = streamCacheDisabled; } @@ -243,7 +245,7 @@ public class ExtendedExchangeExtension implements ExchangeExtension { this.transacted = transacted; } - public boolean isTransacted() { + boolean isTransacted() { return transacted; } @@ -289,6 +291,7 @@ public class ExtendedExchangeExtension implements ExchangeExtension { return this.exchange.getSafeCopyProperty(key, type); } + @Override public void copySafeCopyPropertiesTo(ExchangeExtension target) { if (exchange.safeCopyProperties != null && !exchange.safeCopyProperties.isEmpty()) { exchange.safeCopyProperties.entrySet().stream() @@ -306,7 +309,7 @@ public class ExtendedExchangeExtension implements ExchangeExtension { this.failureHandled = failureHandled; } - public UnitOfWork getUnitOfWork() { + UnitOfWork getUnitOfWork() { return unitOfWork; } @@ -319,7 +322,6 @@ public class ExtendedExchangeExtension implements ExchangeExtension { } if (this.exchange.variableRepository != null) { this.exchange.variableRepository.clear(); - ; } setHistoryNodeId(null);