This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch as2doc in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5144e8cb5f3f51a3ba1de196e592280142fde0da Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Thu Aug 15 14:58:34 2024 +0200 CAMEL-21090: camel-as2 fix wrong header name prefix. --- .../camel/component/as2/internal/AS2Constants.java | 4 +- .../component/as2/AS2AsyncMDNServerManagerIT.java | 30 ++-- .../camel/component/as2/AS2ClientManagerIT.java | 158 ++++++++++----------- .../ROOT/pages/camel-4x-upgrade-guide-4_8.adoc | 5 + 4 files changed, 101 insertions(+), 96 deletions(-) diff --git a/components/camel-as2/camel-as2-component/src/main/java/org/apache/camel/component/as2/internal/AS2Constants.java b/components/camel-as2/camel-as2-component/src/main/java/org/apache/camel/component/as2/internal/AS2Constants.java index 2086e05cd65..df9793fc900 100644 --- a/components/camel-as2/camel-as2-component/src/main/java/org/apache/camel/component/as2/internal/AS2Constants.java +++ b/components/camel-as2/camel-as2-component/src/main/java/org/apache/camel/component/as2/internal/AS2Constants.java @@ -22,10 +22,10 @@ package org.apache.camel.component.as2.internal; public interface AS2Constants { // suffix for parameters when passed as exchange header properties - String PROPERTY_PREFIX = "CamelAS2."; + String PROPERTY_PREFIX = "CamelAs2."; // thread profile name for this component - String THREAD_PROFILE_NAME = "CamelAS2"; + String THREAD_PROFILE_NAME = "CamelAs2"; // header property containing the AS2 Interchange. String AS2_INTERCHANGE = PROPERTY_PREFIX + "interchange"; diff --git a/components/camel-as2/camel-as2-component/src/test/java/org/apache/camel/component/as2/AS2AsyncMDNServerManagerIT.java b/components/camel-as2/camel-as2-component/src/test/java/org/apache/camel/component/as2/AS2AsyncMDNServerManagerIT.java index 68018116e0b..00c9573fb50 100644 --- a/components/camel-as2/camel-as2-component/src/test/java/org/apache/camel/component/as2/AS2AsyncMDNServerManagerIT.java +++ b/components/camel-as2/camel-as2-component/src/test/java/org/apache/camel/component/as2/AS2AsyncMDNServerManagerIT.java @@ -299,26 +299,26 @@ public class AS2AsyncMDNServerManagerIT extends AbstractAS2ITSupport { } private void addSignedMessageHeaders(Map<String, Object> headers) { - headers.put("CamelAS2.as2MessageStructure", AS2MessageStructure.SIGNED); - headers.put("CamelAS2.signedReceiptMicAlgorithms", SIGNED_RECEIPT_MIC_ALGORITHMS); - headers.put("CamelAS2.signingCertificateChain", new Certificate[] { clientCert }); - headers.put("CamelAS2.signingPrivateKey", clientKeyPair.getPrivate()); - headers.put("CamelAS2.signingAlgorithm", AS2SignatureAlgorithm.SHA512WITHRSA); + headers.put("CamelAs2.as2MessageStructure", AS2MessageStructure.SIGNED); + headers.put("CamelAs2.signedReceiptMicAlgorithms", SIGNED_RECEIPT_MIC_ALGORITHMS); + headers.put("CamelAs2.signingCertificateChain", new Certificate[] { clientCert }); + headers.put("CamelAs2.signingPrivateKey", clientKeyPair.getPrivate()); + headers.put("CamelAs2.signingAlgorithm", AS2SignatureAlgorithm.SHA512WITHRSA); } // Headers required for a client to call the AS2 'send' api. private Map<String, Object> getAS2Headers() { final Map<String, Object> headers = new HashMap<>(); - headers.put("CamelAS2.requestUri", REQUEST_URI); - headers.put("CamelAS2.subject", SUBJECT); - headers.put("CamelAS2.from", FROM); - headers.put("CamelAS2.as2From", AS2_NAME); - headers.put("CamelAS2.as2To", AS2_NAME); - headers.put("CamelAS2.as2MessageStructure", AS2MessageStructure.PLAIN); - headers.put("CamelAS2.ediMessageContentType", + headers.put("CamelAs2.requestUri", REQUEST_URI); + headers.put("CamelAs2.subject", SUBJECT); + headers.put("CamelAs2.from", FROM); + headers.put("CamelAs2.as2From", AS2_NAME); + headers.put("CamelAs2.as2To", AS2_NAME); + headers.put("CamelAs2.as2MessageStructure", AS2MessageStructure.PLAIN); + headers.put("CamelAs2.ediMessageContentType", ContentType.create(AS2MediaType.APPLICATION_EDIFACT, StandardCharsets.US_ASCII.name())); - headers.put("CamelAS2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); - headers.put("CamelAS2.dispositionNotificationTo", "mr...@example.com"); + headers.put("CamelAs2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); + headers.put("CamelAs2.dispositionNotificationTo", "mr...@example.com"); return headers; } @@ -326,7 +326,7 @@ public class AS2AsyncMDNServerManagerIT extends AbstractAS2ITSupport { // Headers requesting that the AS2-MDN (receipt) be returned asynchronously private Map<String, Object> getAS2HeadersForAsyncReceipt() { Map<String, Object> headers = getAS2Headers(); - headers.put("CamelAS2.receiptDeliveryOption", RECIPIENT_DELIVERY_ADDRESS); + headers.put("CamelAs2.receiptDeliveryOption", RECIPIENT_DELIVERY_ADDRESS); return headers; } diff --git a/components/camel-as2/camel-as2-component/src/test/java/org/apache/camel/component/as2/AS2ClientManagerIT.java b/components/camel-as2/camel-as2-component/src/test/java/org/apache/camel/component/as2/AS2ClientManagerIT.java index 0f97d89b387..3875251f315 100644 --- a/components/camel-as2/camel-as2-component/src/test/java/org/apache/camel/component/as2/AS2ClientManagerIT.java +++ b/components/camel-as2/camel-as2-component/src/test/java/org/apache/camel/component/as2/AS2ClientManagerIT.java @@ -165,26 +165,26 @@ public class AS2ClientManagerIT extends AbstractAS2ITSupport { public void plainMessageSendTest() throws Exception { final Map<String, Object> headers = new HashMap<>(); // parameter type is String - headers.put("CamelAS2.requestUri", REQUEST_URI); + headers.put("CamelAs2.requestUri", REQUEST_URI); // parameter type is String - headers.put("CamelAS2.subject", SUBJECT); + headers.put("CamelAs2.subject", SUBJECT); // parameter type is String - headers.put("CamelAS2.from", FROM); + headers.put("CamelAs2.from", FROM); // parameter type is String - headers.put("CamelAS2.as2From", AS2_NAME); + headers.put("CamelAs2.as2From", AS2_NAME); // parameter type is String - headers.put("CamelAS2.as2To", AS2_NAME); + headers.put("CamelAs2.as2To", AS2_NAME); // parameter type is org.apache.camel.component.as2.api.AS2MessageStructure - headers.put("CamelAS2.as2MessageStructure", AS2MessageStructure.PLAIN); + headers.put("CamelAs2.as2MessageStructure", AS2MessageStructure.PLAIN); // parameter type is org.apache.http.entity.ContentType - headers.put("CamelAS2.ediMessageContentType", + headers.put("CamelAs2.ediMessageContentType", ContentType.create(AS2MediaType.APPLICATION_EDIFACT, StandardCharsets.US_ASCII.name())); // parameter type is String - headers.put("CamelAS2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); + headers.put("CamelAs2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); // parameter type is String - headers.put("CamelAS2.dispositionNotificationTo", "mr...@example.com"); + headers.put("CamelAs2.dispositionNotificationTo", "mr...@example.com"); // parameter type is String - headers.put("CamelAS2.attachedFileName", ""); + headers.put("CamelAs2.attachedFileName", ""); final Triple<HttpEntity, HttpRequest, HttpResponse> result = executeRequest(headers); HttpEntity responseEntity = result.getLeft(); @@ -248,24 +248,24 @@ public class AS2ClientManagerIT extends AbstractAS2ITSupport { public void plainMessageSendTestWhenDispositionNotificationToNotSet() throws Exception { final Map<String, Object> headers = new HashMap<>(); // parameter type is String - headers.put("CamelAS2.requestUri", REQUEST_URI); + headers.put("CamelAs2.requestUri", REQUEST_URI); // parameter type is String - headers.put("CamelAS2.subject", SUBJECT); + headers.put("CamelAs2.subject", SUBJECT); // parameter type is String - headers.put("CamelAS2.from", FROM); + headers.put("CamelAs2.from", FROM); // parameter type is String - headers.put("CamelAS2.as2From", AS2_NAME); + headers.put("CamelAs2.as2From", AS2_NAME); // parameter type is String - headers.put("CamelAS2.as2To", AS2_NAME); + headers.put("CamelAs2.as2To", AS2_NAME); // parameter type is org.apache.camel.component.as2.api.AS2MessageStructure - headers.put("CamelAS2.as2MessageStructure", AS2MessageStructure.PLAIN); + headers.put("CamelAs2.as2MessageStructure", AS2MessageStructure.PLAIN); // parameter type is org.apache.http.entity.ContentType - headers.put("CamelAS2.ediMessageContentType", + headers.put("CamelAs2.ediMessageContentType", ContentType.create(AS2MediaType.APPLICATION_EDIFACT, StandardCharsets.US_ASCII.name())); // parameter type is String - headers.put("CamelAS2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); + headers.put("CamelAs2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); // parameter type is String - headers.put("CamelAS2.attachedFileName", ""); + headers.put("CamelAs2.attachedFileName", ""); final Triple<HttpEntity, HttpRequest, HttpResponse> result = executeRequest(headers); HttpEntity responseEntity = result.getLeft(); @@ -303,22 +303,22 @@ public class AS2ClientManagerIT extends AbstractAS2ITSupport { public void plainMessageSend2Test() throws Exception { final Map<String, Object> headers = new HashMap<>(); // parameter type is String - headers.put("CamelAS2.requestUri", REQUEST_URI); + headers.put("CamelAs2.requestUri", REQUEST_URI); // parameter type is String - headers.put("CamelAS2.subject", SUBJECT); + headers.put("CamelAs2.subject", SUBJECT); // parameter type is String - headers.put("CamelAS2.from", FROM); + headers.put("CamelAs2.from", FROM); // parameter type is org.apache.camel.component.as2.api.AS2MessageStructure - headers.put("CamelAS2.as2MessageStructure", AS2MessageStructure.PLAIN); + headers.put("CamelAs2.as2MessageStructure", AS2MessageStructure.PLAIN); // parameter type is org.apache.http.entity.ContentType - headers.put("CamelAS2.ediMessageContentType", + headers.put("CamelAs2.ediMessageContentType", ContentType.create(AS2MediaType.APPLICATION_EDIFACT, StandardCharsets.US_ASCII)); // parameter type is String - headers.put("CamelAS2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); + headers.put("CamelAs2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); // parameter type is String - headers.put("CamelAS2.dispositionNotificationTo", "mr...@example.com"); + headers.put("CamelAs2.dispositionNotificationTo", "mr...@example.com"); // parameter type is String - headers.put("CamelAS2.attachedFileName", ""); + headers.put("CamelAs2.attachedFileName", ""); final Triple<HttpEntity, HttpRequest, HttpResponse> result = executeRequest2(headers); HttpEntity responseEntity = result.getLeft(); @@ -382,30 +382,30 @@ public class AS2ClientManagerIT extends AbstractAS2ITSupport { public void envelopedMessageSendTest() throws Exception { final Map<String, Object> headers = new HashMap<>(); // parameter type is String - headers.put("CamelAS2.requestUri", REQUEST_URI); + headers.put("CamelAs2.requestUri", REQUEST_URI); // parameter type is String - headers.put("CamelAS2.subject", SUBJECT); + headers.put("CamelAs2.subject", SUBJECT); // parameter type is String - headers.put("CamelAS2.from", FROM); + headers.put("CamelAs2.from", FROM); // parameter type is String - headers.put("CamelAS2.as2From", AS2_NAME); + headers.put("CamelAs2.as2From", AS2_NAME); // parameter type is String - headers.put("CamelAS2.as2To", AS2_NAME); + headers.put("CamelAs2.as2To", AS2_NAME); // parameter type is org.apache.camel.component.as2.api.AS2MessageStructure - headers.put("CamelAS2.as2MessageStructure", AS2MessageStructure.ENCRYPTED); + headers.put("CamelAs2.as2MessageStructure", AS2MessageStructure.ENCRYPTED); // parameter type is org.apache.http.entity.ContentType - headers.put("CamelAS2.ediMessageContentType", + headers.put("CamelAs2.ediMessageContentType", ContentType.create(AS2MediaType.APPLICATION_EDIFACT, StandardCharsets.US_ASCII)); // parameter type is String - headers.put("CamelAS2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); + headers.put("CamelAs2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); // parameter type is String - headers.put("CamelAS2.dispositionNotificationTo", "mr...@example.com"); + headers.put("CamelAs2.dispositionNotificationTo", "mr...@example.com"); // parameter type is org.apache.camel.component.as2.api.AS2EncryptionAlgorithm - headers.put("CamelAS2.encryptingAlgorithm", AS2EncryptionAlgorithm.AES128_CBC); + headers.put("CamelAs2.encryptingAlgorithm", AS2EncryptionAlgorithm.AES128_CBC); // parameter type is java.security.cert.Certificate[] - headers.put("CamelAS2.encryptingCertificateChain", new Certificate[] { clientCert }); + headers.put("CamelAs2.encryptingCertificateChain", new Certificate[] { clientCert }); // parameter type is String - headers.put("CamelAS2.attachedFileName", ""); + headers.put("CamelAs2.attachedFileName", ""); final Triple<HttpEntity, HttpRequest, HttpResponse> result = executeRequest(headers); HttpEntity responseEntity = result.getLeft(); @@ -474,34 +474,34 @@ public class AS2ClientManagerIT extends AbstractAS2ITSupport { public void multipartSignedMessageTest() throws Exception { final Map<String, Object> headers = new HashMap<>(); // parameter type is String - headers.put("CamelAS2.requestUri", REQUEST_URI); + headers.put("CamelAs2.requestUri", REQUEST_URI); // parameter type is String - headers.put("CamelAS2.subject", SUBJECT); + headers.put("CamelAs2.subject", SUBJECT); // parameter type is String - headers.put("CamelAS2.from", FROM); + headers.put("CamelAs2.from", FROM); // parameter type is String - headers.put("CamelAS2.as2From", AS2_NAME); + headers.put("CamelAs2.as2From", AS2_NAME); // parameter type is String - headers.put("CamelAS2.as2To", AS2_NAME); + headers.put("CamelAs2.as2To", AS2_NAME); // parameter type is org.apache.camel.component.as2.api.AS2MessageStructure - headers.put("CamelAS2.as2MessageStructure", AS2MessageStructure.SIGNED); + headers.put("CamelAs2.as2MessageStructure", AS2MessageStructure.SIGNED); // parameter type is org.apache.http.entity.ContentType - headers.put("CamelAS2.ediMessageContentType", + headers.put("CamelAs2.ediMessageContentType", ContentType.create(AS2MediaType.APPLICATION_EDIFACT, StandardCharsets.US_ASCII)); // parameter type is String - headers.put("CamelAS2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); + headers.put("CamelAs2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); // parameter type is org.apache.camel.component.as2.api.AS2SignatureAlgorithm - headers.put("CamelAS2.signingAlgorithm", AS2SignatureAlgorithm.SHA512WITHRSA); + headers.put("CamelAs2.signingAlgorithm", AS2SignatureAlgorithm.SHA512WITHRSA); // parameter type is java.security.cert.Certificate[] - headers.put("CamelAS2.signingCertificateChain", new Certificate[] { clientCert }); + headers.put("CamelAs2.signingCertificateChain", new Certificate[] { clientCert }); // parameter type is java.security.PrivateKey - headers.put("CamelAS2.signingPrivateKey", clientKeyPair.getPrivate()); + headers.put("CamelAs2.signingPrivateKey", clientKeyPair.getPrivate()); // parameter type is String - headers.put("CamelAS2.dispositionNotificationTo", "mr...@example.com"); + headers.put("CamelAs2.dispositionNotificationTo", "mr...@example.com"); // parameter type is String[] - headers.put("CamelAS2.signedReceiptMicAlgorithms", SIGNED_RECEIPT_MIC_ALGORITHMS); + headers.put("CamelAs2.signedReceiptMicAlgorithms", SIGNED_RECEIPT_MIC_ALGORITHMS); // parameter type is String - headers.put("CamelAS2.attachedFileName", ""); + headers.put("CamelAs2.attachedFileName", ""); final Triple<HttpEntity, HttpRequest, HttpResponse> result = executeRequest(headers); HttpEntity responseEntity = result.getLeft(); @@ -584,34 +584,34 @@ public class AS2ClientManagerIT extends AbstractAS2ITSupport { public void multipartSignedXMLMessageTest() throws Exception { final Map<String, Object> headers = new HashMap<>(); // parameter type is String - headers.put("CamelAS2.requestUri", REQUEST_URI); + headers.put("CamelAs2.requestUri", REQUEST_URI); // parameter type is String - headers.put("CamelAS2.subject", SUBJECT); + headers.put("CamelAs2.subject", SUBJECT); // parameter type is String - headers.put("CamelAS2.from", FROM); + headers.put("CamelAs2.from", FROM); // parameter type is String - headers.put("CamelAS2.as2From", AS2_NAME); + headers.put("CamelAs2.as2From", AS2_NAME); // parameter type is String - headers.put("CamelAS2.as2To", AS2_NAME); + headers.put("CamelAs2.as2To", AS2_NAME); // parameter type is org.apache.camel.component.as2.api.AS2MessageStructure - headers.put("CamelAS2.as2MessageStructure", AS2MessageStructure.SIGNED); + headers.put("CamelAs2.as2MessageStructure", AS2MessageStructure.SIGNED); // parameter type is org.apache.http.entity.ContentType - headers.put("CamelAS2.ediMessageContentType", + headers.put("CamelAs2.ediMessageContentType", ContentType.create(AS2MediaType.APPLICATION_XML, StandardCharsets.US_ASCII)); // this line is the difference // parameter type is String - headers.put("CamelAS2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); + headers.put("CamelAs2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); // parameter type is org.apache.camel.component.as2.api.AS2SignatureAlgorithm - headers.put("CamelAS2.signingAlgorithm", AS2SignatureAlgorithm.SHA512WITHRSA); + headers.put("CamelAs2.signingAlgorithm", AS2SignatureAlgorithm.SHA512WITHRSA); // parameter type is java.security.cert.Certificate[] - headers.put("CamelAS2.signingCertificateChain", new Certificate[] { clientCert }); + headers.put("CamelAs2.signingCertificateChain", new Certificate[] { clientCert }); // parameter type is java.security.PrivateKey - headers.put("CamelAS2.signingPrivateKey", clientKeyPair.getPrivate()); + headers.put("CamelAs2.signingPrivateKey", clientKeyPair.getPrivate()); // parameter type is String - headers.put("CamelAS2.dispositionNotificationTo", "mr...@example.com"); + headers.put("CamelAs2.dispositionNotificationTo", "mr...@example.com"); // parameter type is String[] - headers.put("CamelAS2.signedReceiptMicAlgorithms", SIGNED_RECEIPT_MIC_ALGORITHMS); + headers.put("CamelAs2.signedReceiptMicAlgorithms", SIGNED_RECEIPT_MIC_ALGORITHMS); // parameter type is String - headers.put("CamelAS2.attachedFileName", ""); + headers.put("CamelAs2.attachedFileName", ""); final Triple<HttpEntity, HttpRequest, HttpResponse> result = executeRequest(headers); HttpEntity responseEntity = result.getLeft(); @@ -693,30 +693,30 @@ public class AS2ClientManagerIT extends AbstractAS2ITSupport { public void compressedMessageTest() throws Exception { final Map<String, Object> headers = new HashMap<>(); // parameter type is String - headers.put("CamelAS2.requestUri", REQUEST_URI); + headers.put("CamelAs2.requestUri", REQUEST_URI); // parameter type is String - headers.put("CamelAS2.subject", SUBJECT); + headers.put("CamelAs2.subject", SUBJECT); // parameter type is String - headers.put("CamelAS2.from", FROM); + headers.put("CamelAs2.from", FROM); // parameter type is String - headers.put("CamelAS2.as2From", AS2_NAME); + headers.put("CamelAs2.as2From", AS2_NAME); // parameter type is String - headers.put("CamelAS2.as2To", AS2_NAME); + headers.put("CamelAs2.as2To", AS2_NAME); // parameter type is org.apache.camel.component.as2.api.AS2MessageStructure - headers.put("CamelAS2.as2MessageStructure", AS2MessageStructure.PLAIN_COMPRESSED); + headers.put("CamelAs2.as2MessageStructure", AS2MessageStructure.PLAIN_COMPRESSED); // parameter type is org.apache.http.entity.ContentType - headers.put("CamelAS2.ediMessageContentType", + headers.put("CamelAs2.ediMessageContentType", ContentType.create(AS2MediaType.APPLICATION_EDIFACT, StandardCharsets.US_ASCII)); // parameter type is String - headers.put("CamelAS2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); + headers.put("CamelAs2.ediMessageTransferEncoding", EDI_MESSAGE_CONTENT_TRANSFER_ENCODING); // parameter type is org.apache.camel.component.as2.api.AS2CompressionAlgorithm - headers.put("CamelAS2.compressionAlgorithm", AS2CompressionAlgorithm.ZLIB); + headers.put("CamelAs2.compressionAlgorithm", AS2CompressionAlgorithm.ZLIB); // parameter type is String - headers.put("CamelAS2.dispositionNotificationTo", "mr...@example.com"); + headers.put("CamelAs2.dispositionNotificationTo", "mr...@example.com"); // parameter type is String[] - headers.put("CamelAS2.signedReceiptMicAlgorithms", SIGNED_RECEIPT_MIC_ALGORITHMS); + headers.put("CamelAs2.signedReceiptMicAlgorithms", SIGNED_RECEIPT_MIC_ALGORITHMS); // parameter type is String - headers.put("CamelAS2.attachedFileName", ""); + headers.put("CamelAs2.attachedFileName", ""); final Triple<HttpEntity, HttpRequest, HttpResponse> result = executeRequest(headers); HttpEntity responseEntity = result.getLeft(); diff --git a/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_8.adoc b/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_8.adoc index ec264a71927..3775ba0a18b 100644 --- a/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_8.adoc +++ b/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_8.adoc @@ -13,6 +13,11 @@ The following components that were marked as deprecated: * camel-univocity-parsers +=== camel-as2 + +The header prefixes has been corrected from `CamelAS2.` -> `CamelAs2.` to be consistent with naming convention +used by other API based components. The documentation uses the correct naming prefix as `CamelAs2.`. + === camel-kafka The `KafkaIdempotentRepository` will now continue to sync cache updates after Camel has been started.