You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by lb...@apache.org on 2022/06/21 10:22:10 UTC

[camel] branch main updated: feat: add exchange constants related to the schema of the message payload

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 1a10579ae81 feat: add exchange constants related to the schema of the message payload
1a10579ae81 is described below

commit 1a10579ae81da9e9cd5f23529b6738b653fbadfa
Author: Luca Burgazzoli <lb...@gmail.com>
AuthorDate: Tue Jun 21 11:23:58 2022 +0200

    feat: add exchange constants related to the schema of the message payload
---
 .../java/org/apache/camel/ExchangeConstantProvider.java     |  4 +++-
 core/camel-api/src/main/java/org/apache/camel/Exchange.java | 13 +++++++++----
 2 files changed, 12 insertions(+), 5 deletions(-)

diff --git a/core/camel-api/src/generated/java/org/apache/camel/ExchangeConstantProvider.java b/core/camel-api/src/generated/java/org/apache/camel/ExchangeConstantProvider.java
index b9ff62dad1b..d495cac7f9a 100644
--- a/core/camel-api/src/generated/java/org/apache/camel/ExchangeConstantProvider.java
+++ b/core/camel-api/src/generated/java/org/apache/camel/ExchangeConstantProvider.java
@@ -11,7 +11,7 @@ public class ExchangeConstantProvider {
 
     private static final Map<String, String> MAP;
     static {
-        Map<String, String> map = new HashMap<>(152);
+        Map<String, String> map = new HashMap<>(154);
         map.put("ACCEPT_CONTENT_TYPE", "CamelAcceptContentType");
         map.put("AGGREGATED_COLLECTION_GUARD", "CamelAggregatedCollectionGuard");
         map.put("AGGREGATED_COMPLETED_BY", "CamelAggregatedCompletedBy");
@@ -37,6 +37,8 @@ public class ExchangeConstantProvider {
         map.put("COMPILE_SCRIPT", "CamelCompileScript");
         map.put("CONTENT_ENCODING", "Content-Encoding");
         map.put("CONTENT_LENGTH", "Content-Length");
+        map.put("CONTENT_SCHEMA", "CamelContentSchema");
+        map.put("CONTENT_SCHEMA_TYPE", "CamelContentSchemaType");
         map.put("CONTENT_TYPE", "Content-Type");
         map.put("COOKIE_HANDLER", "CamelCookieHandler");
         map.put("CORRELATION_ID", "CamelCorrelationId");
diff --git a/core/camel-api/src/main/java/org/apache/camel/Exchange.java b/core/camel-api/src/main/java/org/apache/camel/Exchange.java
index c44b73c3964..3ba0e4b5edb 100644
--- a/core/camel-api/src/main/java/org/apache/camel/Exchange.java
+++ b/core/camel-api/src/main/java/org/apache/camel/Exchange.java
@@ -100,6 +100,11 @@ public interface Exchange {
     String COOKIE_HANDLER = "CamelCookieHandler";
     String CORRELATION_ID = "CamelCorrelationId";
 
+    // The schema of the message payload
+    String CONTENT_SCHEMA = "CamelContentSchema";
+    // The schema type of the message payload (json schema, avro, etc)
+    String CONTENT_SCHEMA_TYPE = "CamelContentSchemaType";
+
     String DATASET_INDEX = "CamelDataSetIndex";
     String DEFAULT_CHARSET_PROPERTY = "org.apache.camel.default.charset";
     String DESTINATION_OVERRIDE_URL = "CamelDestinationOverrideUrl";
@@ -398,7 +403,7 @@ public interface Exchange {
     /**
      * Removes the properties from this exchange that match the given <tt>pattern</tt>, except for the ones matching one
      * or more <tt>excludePatterns</tt>
-     * 
+     *
      * @param  pattern         pattern of names that should be removed
      * @param  excludePatterns one or more pattern of properties names that should be excluded (= preserved)
      * @return                 boolean whether any properties matched
@@ -632,11 +637,11 @@ public interface Exchange {
     /**
      * Returns the endpoint which originated this message exchange if a consumer on an endpoint created the message
      * exchange, otherwise his property will be <tt>null</tt>.
-     * 
+     *
      * Note: In case this message exchange has been cloned through another parent message exchange (which itself has
      * been created through the consumer of it's own endpoint), then if desired one could still retrieve the consumer
      * endpoint of such a parent message exchange as the following:
-     * 
+     *
      * <pre>
      * getContext().getRoute(getFromRouteId()).getEndpoint()
      * </pre>
@@ -646,7 +651,7 @@ public interface Exchange {
     /**
      * Returns the route id which originated this message exchange if a route consumer on an endpoint created the
      * message exchange, otherwise his property will be <tt>null</tt>.
-     * 
+     *
      * Note: In case this message exchange has been cloned through another parent message exchange then this method
      * would return the <tt>fromRouteId<tt> property of that exchange.
      */