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:29 UTC
[camel] 01/04: (chores) camel-influxdb2: removed unused parameters
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);