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.
*/