You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2016/06/17 12:34:27 UTC
camel git commit: Camel-Kafka: Camel 2.17.x is still Java 7 so we
need to implement the method remove in our Iterator of ProducerRecord Objects
Repository: camel
Updated Branches:
refs/heads/camel-2.17.x 5f69d6267 -> a2665ae8b
Camel-Kafka: Camel 2.17.x is still Java 7 so we need to implement the method remove in our Iterator of ProducerRecord Objects
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a2665ae8
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a2665ae8
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a2665ae8
Branch: refs/heads/camel-2.17.x
Commit: a2665ae8b6bdd2eb1560c4a08fff081839b474a4
Parents: 5f69d62
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Jun 17 14:32:24 2016 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Jun 17 14:32:24 2016 +0200
----------------------------------------------------------------------
.../java/org/apache/camel/component/kafka/KafkaProducer.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/a2665ae8/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java
----------------------------------------------------------------------
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 e2f25fb..37cc920 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
@@ -141,6 +141,11 @@ public class KafkaProducer extends DefaultAsyncProducer {
}
return new ProducerRecord(msgTopic, msgList.next());
}
+
+ @Override
+ public void remove() {
+ msgList.remove();
+ }
};
}
ProducerRecord record;