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 2020/11/24 06:48:26 UTC
[camel-kafka-connector] 07/17: Fixed CS
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-master-align-and-rebase
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit c3cf58b9ab6e6ebdb2c7fb9e7dcee8f5c916b5e2
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Nov 19 07:29:03 2020 +0100
Fixed CS
---
.../org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
index 1627a8d..bebe4a9 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
@@ -178,8 +178,8 @@ public class CamelKafkaConnectMain extends SimpleMain {
// Instantianting the idempotent Repository here and inject it in registry to be referenced
if (idempotencyEnabled) {
- IdempotentRepository idempotentRepo = MemoryIdempotentRepository.memoryIdempotentRepository(memoryDimension);
- camelMain.getCamelContext().getRegistry().bind("idempotentRepository", idempotentRepo);
+ IdempotentRepository idempotentRepo = MemoryIdempotentRepository.memoryIdempotentRepository(memoryDimension);
+ camelMain.getCamelContext().getRegistry().bind("idempotentRepository", idempotentRepo);
}
//creating the actual route