[camel] branch master updated: Fix interchanged method calls of HeaderFilterStrategy

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new 459273a  Fix interchanged method calls of HeaderFilterStrategy
459273a is described below

commit 459273aa356bdab408163e5cb8bb214d007c4f46
Author: Stephan Burkard <sburk...@gmail.com>
AuthorDate: Wed May 27 15:02:43 2020 +0200

    Fix interchanged method calls of HeaderFilterStrategy
---
 .../src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java   | 2 +-
 .../src/main/java/org/apache/camel/component/kafka/KafkaProducer.java   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
index 6294d82..df469b0 100644
--- 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
+++ 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
@@ -493,7 +493,7 @@ public class KafkaConsumer extends DefaultConsumer {
     }
 
     private boolean shouldBeFiltered(Header header, Exchange exchange, 
HeaderFilterStrategy headerFilterStrategy) {
-        return !headerFilterStrategy.applyFilterToCamelHeaders(header.key(), 
header.value(), exchange);
+        return 
!headerFilterStrategy.applyFilterToExternalHeaders(header.key(), 
header.value(), exchange);
     }
 
     private boolean isAutoCommitEnabled() {
diff --git 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java
 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java
index 12c5239..832ccc8 100644
--- 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java
+++ 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java
@@ -279,7 +279,7 @@ public class KafkaProducer extends DefaultAsyncProducer {
     }
 
     private boolean shouldBeFiltered(Map.Entry<String, Object> entry, Exchange 
exchange, HeaderFilterStrategy headerFilterStrategy) {
-        return 
!headerFilterStrategy.applyFilterToExternalHeaders(entry.getKey(), 
entry.getValue(), exchange);
+        return !headerFilterStrategy.applyFilterToCamelHeaders(entry.getKey(), 
entry.getValue(), exchange);
     }
 
     private RecordHeader getRecordHeader(Map.Entry<String, Object> entry, 
KafkaHeaderSerializer headerSerializer) {