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 <[email protected]> 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);
