Repository: camel Updated Branches: refs/heads/master e92581bef -> c2f424c21
Removed parameter validation in constructor. Now being handled in doStart() Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e76bc31d Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e76bc31d Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e76bc31d Branch: refs/heads/master Commit: e76bc31daccbcc3bbd1b5d652c5dfd2a9e49b81a Parents: d2b2921 Author: Jakub Korab <jakub.ko...@gmail.com> Authored: Fri Mar 3 16:25:50 2017 +0000 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Mar 3 20:03:08 2017 +0100 ---------------------------------------------------------------------- .../processor/idempotent/kafka/KafkaIdempotentRepository.java | 3 --- 1 file changed, 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/e76bc31d/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java b/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java index 5405799..cfb2ec5 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepository.java @@ -124,9 +124,6 @@ public class KafkaIdempotentRepository extends ServiceSupport implements Idempot } public KafkaIdempotentRepository(String topic, String bootstrapServers, int maxCacheSize, int pollDurationMs) { - StringHelper.notEmpty(topic, "topic"); - StringHelper.notEmpty(bootstrapServers, "bootstrapServers"); - this.topic = topic; this.bootstrapServers = bootstrapServers; this.maxCacheSize = maxCacheSize;
