This is an automated email from the ASF dual-hosted git repository.
pcongiusti 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 885400c697ac chore(components): put sonar comment where expected by
the tool
885400c697ac is described below
commit 885400c697ac09149052664422dc3631baf4c389
Author: Pasquale Congiusti <[email protected]>
AuthorDate: Thu Dec 4 08:56:32 2025 +0100
chore(components): put sonar comment where expected by the tool
---
.../main/java/org/apache/camel/component/openai/OpenAIProducer.java | 4 ++--
.../java/org/apache/camel/component/jcache/policy/JCachePolicy.java | 4 ++--
.../org/apache/camel/component/opensearch/OpensearchProducer.java | 4 ++--
.../src/main/java/org/apache/camel/component/rest/RestEndpoint.java | 4 ++--
.../src/main/java/org/apache/camel/component/smb/SmbOperations.java | 4 ++--
5 files changed, 10 insertions(+), 10 deletions(-)
diff --git
a/components/camel-ai/camel-openai/src/main/java/org/apache/camel/component/openai/OpenAIProducer.java
b/components/camel-ai/camel-openai/src/main/java/org/apache/camel/component/openai/OpenAIProducer.java
index ebf0e9439cf0..3ccd26bf5611 100644
---
a/components/camel-ai/camel-openai/src/main/java/org/apache/camel/component/openai/OpenAIProducer.java
+++
b/components/camel-ai/camel-openai/src/main/java/org/apache/camel/component/openai/OpenAIProducer.java
@@ -351,8 +351,8 @@ public class OpenAIProducer extends DefaultAsyncProducer {
private void processStreaming(Exchange exchange,
ChatCompletionCreateParams params) {
// NOTE: the stream is going to be closed after the exchange completes.
- StreamResponse<ChatCompletionChunk> streamResponse =
getEndpoint().getClient().chat().completions()
- .createStreaming(params); // NOSONAR
+ StreamResponse<ChatCompletionChunk> streamResponse =
getEndpoint().getClient().chat().completions() // NOSONAR
+ .createStreaming(params);
// hand Camel an Iterator for streaming EIPs (split, recipientList,
etc.)
Iterator<ChatCompletionChunk> it = streamResponse.stream().iterator();
diff --git
a/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/policy/JCachePolicy.java
b/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/policy/JCachePolicy.java
index 4c2bc7caa524..3e03d59e8f6d 100644
---
a/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/policy/JCachePolicy.java
+++
b/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/policy/JCachePolicy.java
@@ -102,8 +102,8 @@ public class JCachePolicy implements Policy {
LOG.debug("Create cache:{}", cacheName);
// NOTE: the cache must not be closed. The closure is managed
by the client
// (the component in this case) which will close it according
to Camel lifecycle.
- cache = cacheManager.createCache(cacheName,
- cacheConfiguration != null ? this.cacheConfiguration :
(Configuration) new MutableConfiguration()); // NOSONAR
+ cache = cacheManager.createCache(cacheName, // NOSONAR
+ cacheConfiguration != null ? this.cacheConfiguration :
(Configuration) new MutableConfiguration());
}
}
diff --git
a/components/camel-opensearch/src/main/java/org/apache/camel/component/opensearch/OpensearchProducer.java
b/components/camel-opensearch/src/main/java/org/apache/camel/component/opensearch/OpensearchProducer.java
index d22248949c9e..f42423d27c22 100644
---
a/components/camel-opensearch/src/main/java/org/apache/camel/component/opensearch/OpensearchProducer.java
+++
b/components/camel-opensearch/src/main/java/org/apache/camel/component/opensearch/OpensearchProducer.java
@@ -229,9 +229,9 @@ class OpensearchProducer extends DefaultAsyncProducer {
=
message.getHeader(PARAM_SCROLL_KEEP_ALIVE_MS,
configuration.getScrollKeepAliveMs(),
Integer.class);
// NOTE: the stream must be closed by the client.
- OpensearchScrollRequestIterator<?>
scrollRequestIterator = new OpensearchScrollRequestIterator<>(
+ OpensearchScrollRequestIterator<?>
scrollRequestIterator = new OpensearchScrollRequestIterator<>( // NOSONAR
searchRequestBuilder, new
OpenSearchClient(transport), scrollKeepAliveMs, exchange,
- documentClass); // NOSONAR:
+ documentClass);
exchange.getIn().setBody(scrollRequestIterator);
cleanup(ctx);
callback.done(true);
diff --git
a/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestEndpoint.java
b/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestEndpoint.java
index 2e1338bcea06..529d4712f937 100644
---
a/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestEndpoint.java
+++
b/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestEndpoint.java
@@ -432,8 +432,8 @@ public class RestEndpoint extends DefaultEndpoint {
consumes, produces, config, parameters);
} else {
// NOTE: the stream must be closed by the client.
- producer = factory.createProducer(getCamelContext(), host,
method, path, uriTemplate, queryParameters, consumes,
- produces, config, parameters); // NOSONAR
+ producer = factory.createProducer(getCamelContext(), host,
method, path, uriTemplate, queryParameters, consumes, // NOSONAR
+ produces, config, parameters);
}
RestProducer answer = new RestProducer(this, producer, config);
diff --git
a/components/camel-smb/src/main/java/org/apache/camel/component/smb/SmbOperations.java
b/components/camel-smb/src/main/java/org/apache/camel/component/smb/SmbOperations.java
index dbb3cd168c42..ab1b6d5b389f 100644
---
a/components/camel-smb/src/main/java/org/apache/camel/component/smb/SmbOperations.java
+++
b/components/camel-smb/src/main/java/org/apache/camel/component/smb/SmbOperations.java
@@ -589,8 +589,8 @@ public class SmbOperations implements SmbFileOperations {
InputStream is;
try {
// NOTE: the streams opened must be closed byt the client.
- File shareFile = share.openFile(path,
EnumSet.of(AccessMask.GENERIC_READ), null,
- SMB2ShareAccess.ALL, SMB2CreateDisposition.FILE_OPEN,
null); // NOSONAR
+ File shareFile = share.openFile(path,
EnumSet.of(AccessMask.GENERIC_READ), null, // NOSONAR
+ SMB2ShareAccess.ALL, SMB2CreateDisposition.FILE_OPEN,
null);
is = shareFile.getInputStream();
exchange.getIn().setHeader(SmbComponent.SMB_FILE_INPUT_STREAM, is);
exchange.getIn().setHeader(SmbConstants.SMB_UNC_PATH,
shareFile.getUncPath());
