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 2022/06/20 12:19:20 UTC
[camel] 07/09: (chores) camel-vertx-kafka-component: 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 02f74172b198ae19e7ac1434348ab3c8cec8abaa
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Jun 20 11:07:03 2022 +0200
(chores) camel-vertx-kafka-component: removed unused parameters
---
.../component/vertx/kafka/VertxKafkaConfigurationOptionsProxy.java | 4 ++--
.../vertx/kafka/operations/VertxKafkaProducerOperations.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/VertxKafkaConfigurationOptionsProxy.java b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/VertxKafkaConfigurationOptionsProxy.java
index 6ab88e9ac27..abccae5105c 100644
--- a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/VertxKafkaConfigurationOptionsProxy.java
+++ b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/VertxKafkaConfigurationOptionsProxy.java
@@ -38,11 +38,11 @@ public class VertxKafkaConfigurationOptionsProxy {
return getOption(message, VertxKafkaConstants.MESSAGE_KEY, () -> null, Object.class);
}
- public String getKeySerializer(final Message message) {
+ public String getKeySerializer() {
return configuration.getKeySerializer();
}
- public String getValueSerializer(final Message message) {
+ public String getValueSerializer() {
return configuration.getValueSerializer();
}
diff --git a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/operations/VertxKafkaProducerOperations.java b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/operations/VertxKafkaProducerOperations.java
index b27dc9e32f0..f2adffcae46 100644
--- a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/operations/VertxKafkaProducerOperations.java
+++ b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/operations/VertxKafkaProducerOperations.java
@@ -179,7 +179,7 @@ public class VertxKafkaProducerOperations {
private Object getMessageKey(final Message message) {
return VertxKafkaTypeSerializer.tryConvertToSerializedType(message,
configurationOptionsProxy.getMessageKey(message),
- configurationOptionsProxy.getKeySerializer(message));
+ configurationOptionsProxy.getKeySerializer());
}
private Integer getPartitionId(final Message message) {
@@ -188,7 +188,7 @@ public class VertxKafkaProducerOperations {
private Object getMessageValue(final Message message, final Object inputData) {
return VertxKafkaTypeSerializer.tryConvertToSerializedType(message, inputData,
- configurationOptionsProxy.getValueSerializer(message));
+ configurationOptionsProxy.getValueSerializer());
}
private Long getOverrideTimestamp(final Message message) {