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/04/18 06:34:28 UTC
[camel] branch main updated (a3764f4f92b -> 8dc72b6509d)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from a3764f4f92b (chores) camel-cxf: remove unused parameters
new a45f3cca370 (chores) camel-influxdb2: removed unused parameters
new 969ec6c52af (chores) camel-irc: removed unused parameters
new b687c003036 (chores) camel-jta: removed unused parameters
new 8dc72b6509d (chores) camel-tooling-maven: removed unused parameters
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/camel/component/influxdb2/InfluxDb2Producer.java | 10 +++++-----
.../java/org/apache/camel/component/irc/IrcEndpoint.java | 2 +-
.../java/org/apache/camel/component/irc/IrcProducer.java | 2 +-
.../java/org/apache/camel/component/irc/IrcEndpointTest.java | 2 +-
.../apache/camel/jta/JtaTransactionErrorHandlerReifier.java | 12 ++++++------
.../org/apache/camel/tooling/maven/MavenDownloaderImpl.java | 4 ++--
6 files changed, 16 insertions(+), 16 deletions(-)
[camel] 01/04: (chores) camel-influxdb2: removed unused parameters
Posted by or...@apache.org.
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
commit a45f3cca37060592e40faa29c8bad3006d46aa53
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 18 07:12:08 2023 +0200
(chores) camel-influxdb2: removed unused parameters
---
.../apache/camel/component/influxdb2/InfluxDb2Producer.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/components/camel-influxdb2/src/main/java/org/apache/camel/component/influxdb2/InfluxDb2Producer.java b/components/camel-influxdb2/src/main/java/org/apache/camel/component/influxdb2/InfluxDb2Producer.java
index 639b181a764..7a8abfc75f0 100644
--- a/components/camel-influxdb2/src/main/java/org/apache/camel/component/influxdb2/InfluxDb2Producer.java
+++ b/components/camel-influxdb2/src/main/java/org/apache/camel/component/influxdb2/InfluxDb2Producer.java
@@ -75,24 +75,24 @@ public class InfluxDb2Producer extends DefaultProducer {
throws InvalidPayloadException {
Object body = exchange.getIn().getBody();
if (body instanceof Point) {
- insertPoint(exchange, orgName, bucketName, writePrecision);
+ insertPoint(exchange, orgName, bucketName);
} else if (body instanceof Measurement) {
insertMeasurement(exchange, orgName, bucketName, writePrecision);
} else if (body instanceof Record) {
insertRecord(exchange, orgName, bucketName, writePrecision);
} else if (body instanceof Points) {
- insertPoints(exchange, orgName, bucketName, writePrecision);
+ insertPoints(exchange, orgName, bucketName);
} else if (body instanceof Measurements) {
insertMeasurements(exchange, orgName, bucketName, writePrecision);
} else if (body instanceof Records) {
insertRecords(exchange, orgName, bucketName, writePrecision);
} else {
// default insert as point
- insertPoint(exchange, orgName, bucketName, writePrecision);
+ insertPoint(exchange, orgName, bucketName);
}
}
- private void insertPoint(Exchange exchange, String orgName, String bucketName, WritePrecision writePrecision)
+ private void insertPoint(Exchange exchange, String orgName, String bucketName)
throws InvalidPayloadException {
Point point = exchange.getIn().getMandatoryBody(Point.class);
try {
@@ -131,7 +131,7 @@ public class InfluxDb2Producer extends DefaultProducer {
}
}
- private void insertPoints(Exchange exchange, String orgName, String bucketName, WritePrecision writePrecision)
+ private void insertPoints(Exchange exchange, String orgName, String bucketName)
throws InvalidPayloadException {
@SuppressWarnings("unchecked")
Points points = exchange.getIn().getMandatoryBody(Points.class);
[camel] 04/04: (chores) camel-tooling-maven: removed unused parameters
Posted by or...@apache.org.
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
commit 8dc72b6509d95e8a6b0d6aca40d5d424cee88f1c
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 18 07:16:17 2023 +0200
(chores) camel-tooling-maven: removed unused parameters
---
.../main/java/org/apache/camel/tooling/maven/MavenDownloaderImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/tooling/camel-tooling-maven/src/main/java/org/apache/camel/tooling/maven/MavenDownloaderImpl.java b/tooling/camel-tooling-maven/src/main/java/org/apache/camel/tooling/maven/MavenDownloaderImpl.java
index 5d16b14fdb6..3340e24fbb5 100644
--- a/tooling/camel-tooling-maven/src/main/java/org/apache/camel/tooling/maven/MavenDownloaderImpl.java
+++ b/tooling/camel-tooling-maven/src/main/java/org/apache/camel/tooling/maven/MavenDownloaderImpl.java
@@ -541,7 +541,7 @@ public class MavenDownloaderImpl extends ServiceSupport implements MavenDownload
RepositorySystem configureRepositorySystem(
DIRegistry registry,
Properties systemProperties, String settingsSecurityLocation) {
- basicRepositorySystemConfiguration(registry, systemProperties);
+ basicRepositorySystemConfiguration(registry);
transportConfiguration(registry, systemProperties);
settingsConfiguration(registry, settingsSecurityLocation);
@@ -551,7 +551,7 @@ public class MavenDownloaderImpl extends ServiceSupport implements MavenDownload
/**
* Configure the basic, necessary requirements of {@link RepositorySystem} in {@link DIRegistry}
*/
- private static void basicRepositorySystemConfiguration(DIRegistry registry, Properties systemProperties) {
+ private static void basicRepositorySystemConfiguration(DIRegistry registry) {
// this is the first one registered in DefaultServiceLocator - what follows up is BFS dependencies
registry.bind(RepositorySystem.class, DefaultRepositorySystem.class);
[camel] 03/04: (chores) camel-jta: removed unused parameters
Posted by or...@apache.org.
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
commit b687c003036767ce369d64932da2cc9216b8820b
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 18 07:12:23 2023 +0200
(chores) camel-jta: removed unused parameters
---
.../apache/camel/jta/JtaTransactionErrorHandlerReifier.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/components/camel-jta/src/main/java/org/apache/camel/jta/JtaTransactionErrorHandlerReifier.java b/components/camel-jta/src/main/java/org/apache/camel/jta/JtaTransactionErrorHandlerReifier.java
index b1aac621340..db1b75288e1 100644
--- a/components/camel-jta/src/main/java/org/apache/camel/jta/JtaTransactionErrorHandlerReifier.java
+++ b/components/camel-jta/src/main/java/org/apache/camel/jta/JtaTransactionErrorHandlerReifier.java
@@ -49,13 +49,13 @@ public class JtaTransactionErrorHandlerReifier extends ErrorHandlerReifier<JtaTr
@Override
public Processor createErrorHandler(final Processor processor) throws Exception {
- JtaTransactionPolicy transactionPolicy = resolveTransactionPolicy(definition, camelContext);
+ JtaTransactionPolicy transactionPolicy = resolveTransactionPolicy(definition);
ObjectHelper.notNull(transactionPolicy, "transactionPolicy", this);
// optimize to use shared default instance if using out of the box settings
RedeliveryPolicy redeliveryPolicy = resolveRedeliveryPolicy(definition, camelContext);
- CamelLogger logger = resolveLogger(definition, camelContext);
- LoggingLevel rollbackLoggingLevel = resolveRollbackLoggingLevel(definition, camelContext);
+ CamelLogger logger = resolveLogger(definition);
+ LoggingLevel rollbackLoggingLevel = resolveRollbackLoggingLevel(definition);
JtaTransactionErrorHandler answer = new JtaTransactionErrorHandler(
camelContext, processor, logger,
@@ -73,7 +73,7 @@ public class JtaTransactionErrorHandlerReifier extends ErrorHandlerReifier<JtaTr
}
private JtaTransactionPolicy resolveTransactionPolicy(
- JtaTransactionErrorHandlerDefinition definition, CamelContext camelContext) {
+ JtaTransactionErrorHandlerDefinition definition) {
JtaTransactionPolicy answer = (JtaTransactionPolicy) definition.getTransactedPolicy();
if (answer == null && definition.getTransactedPolicyRef() != null) {
@@ -107,7 +107,7 @@ public class JtaTransactionErrorHandlerReifier extends ErrorHandlerReifier<JtaTr
return answer;
}
- private CamelLogger resolveLogger(TransactionErrorHandlerDefinition definition, CamelContext camelContext) {
+ private CamelLogger resolveLogger(TransactionErrorHandlerDefinition definition) {
CamelLogger answer = definition.getLoggerBean();
if (answer == null && definition.getLoggerRef() != null) {
answer = mandatoryLookup(definition.getLoggerRef(), CamelLogger.class);
@@ -121,7 +121,7 @@ public class JtaTransactionErrorHandlerReifier extends ErrorHandlerReifier<JtaTr
return answer;
}
- private LoggingLevel resolveRollbackLoggingLevel(TransactionErrorHandlerDefinition definition, CamelContext camelContext) {
+ private LoggingLevel resolveRollbackLoggingLevel(TransactionErrorHandlerDefinition definition) {
LoggingLevel answer = LoggingLevel.WARN;
if (definition.getRollbackLoggingLevel() != null) {
answer = parse(LoggingLevel.class, definition.getRollbackLoggingLevel());
[camel] 02/04: (chores) camel-irc: removed unused parameters
Posted by or...@apache.org.
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
commit 969ec6c52af0299fff47d438ce287ab6b784c29c
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 18 07:12:17 2023 +0200
(chores) camel-irc: removed unused parameters
---
.../src/main/java/org/apache/camel/component/irc/IrcEndpoint.java | 2 +-
.../src/main/java/org/apache/camel/component/irc/IrcProducer.java | 2 +-
.../src/test/java/org/apache/camel/component/irc/IrcEndpointTest.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java
index 1047e416d53..81543e496b6 100644
--- a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java
+++ b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java
@@ -92,7 +92,7 @@ public class IrcEndpoint extends DefaultEndpoint {
this.configuration = configuration;
}
- public void handleIrcError(int num, String msg) {
+ public void handleIrcError(int num) {
if (IRCConstants.ERR_NICKNAMEINUSE == num) {
handleNickInUse();
}
diff --git a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java
index 2819bb50201..b9c5a3a8bb5 100644
--- a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java
+++ b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java
@@ -146,7 +146,7 @@ public class IrcProducer extends DefaultProducer {
@Override
public void onError(int num, String msg) {
- IrcProducer.this.getEndpoint().handleIrcError(num, msg);
+ IrcProducer.this.getEndpoint().handleIrcError(num);
}
}
diff --git a/components/camel-irc/src/test/java/org/apache/camel/component/irc/IrcEndpointTest.java b/components/camel-irc/src/test/java/org/apache/camel/component/irc/IrcEndpointTest.java
index f4f9abde2c0..809731010f2 100644
--- a/components/camel-irc/src/test/java/org/apache/camel/component/irc/IrcEndpointTest.java
+++ b/components/camel-irc/src/test/java/org/apache/camel/component/irc/IrcEndpointTest.java
@@ -76,7 +76,7 @@ public class IrcEndpointTest {
@Test
public void doHandleIrcErrorNickInUse() {
when(connection.getNick()).thenReturn("nick");
- endpoint.handleIrcError(IRCConstants.ERR_NICKNAMEINUSE, "foo");
+ endpoint.handleIrcError(IRCConstants.ERR_NICKNAMEINUSE);
verify(connection).doNick("nick-");
when(connection.getNick()).thenReturn("nick---");