This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch ih in repository https://gitbox.apache.org/repos/asf/camel.git
commit 622efac9fe09e4657058031d4aa0fbf79d03e174 Author: Claus Ibsen <[email protected]> AuthorDate: Mon Nov 24 11:36:46 2025 +0100 CAMEL-22693: Mark up EIP and endpoint headers that are of importance to make tooling, trouble shooting and development easier. --- .../main/java/org/apache/camel/component/kafka/KafkaConstants.java | 6 ++++-- .../java/org/apache/camel/component/undertow/UndertowConstants.java | 3 ++- .../camel/dsl/jbang/core/commands/action/CamelHistoryAction.java | 2 +- 3 files changed, 7 insertions(+), 4 deletions(-) diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java index a3e854432015..2737ff371a46 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java @@ -22,13 +22,15 @@ public final class KafkaConstants { @Metadata(label = "producer", description = "Explicitly specify the partition", javaType = "Integer") public static final String PARTITION_KEY = "kafka.PARTITION_KEY"; - @Metadata(label = "consumer", description = "The partition where the message was stored", javaType = "Integer", important = true) + @Metadata(label = "consumer", description = "The partition where the message was stored", javaType = "Integer", + important = true) public static final String PARTITION = "kafka.PARTITION"; @Metadata(description = "Producer: The key of the message in order to ensure that all related message goes in the same partition. " + "Consumer: The key of the message if configured", javaType = "Object", required = true, important = true) public static final String KEY = "kafka.KEY"; - @Metadata(label = "consumer", description = "The topic from where the message originated", javaType = "String", important = true) + @Metadata(label = "consumer", description = "The topic from where the message originated", javaType = "String", + important = true) public static final String TOPIC = "kafka.TOPIC"; @Metadata(label = "producer", description = "The topic to which send the message (override and takes precedence), and the header is not preserved.", diff --git a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConstants.java b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConstants.java index 140412b2395f..e4e27339bac2 100644 --- a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConstants.java +++ b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConstants.java @@ -36,7 +36,8 @@ public final class UndertowConstants { */ @Metadata(javaType = "Boolean") public static final String SEND_TO_ALL = "websocket.sendToAll"; - @Metadata(label = "consumer", description = "The numeric identifier of the type of websocket event", javaType = "Integer", important = true) + @Metadata(label = "consumer", description = "The numeric identifier of the type of websocket event", javaType = "Integer", + important = true) public static final String EVENT_TYPE = "websocket.eventType"; @Metadata(label = "consumer", description = "The type of websocket event", javaType = "org.apache.camel.component.undertow.UndertowConstants.EventType") diff --git a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelHistoryAction.java b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelHistoryAction.java index 8ee575496188..c653f234fd06 100644 --- a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelHistoryAction.java +++ b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelHistoryAction.java @@ -338,7 +338,7 @@ public class CamelHistoryAction extends ActionWatchCommand { String uri = r.endpoint != null ? r.endpoint.getString("endpoint") : null; Row t = r.first ? r : next; // if sending to endpoint then we should find details in the next step as they are response - if (uri != null && t != null) { + if (uri != null && t != null) { StringJoiner sj = new StringJoiner(" "); var map = extractComponentModel(uri, t); // special for file / http
