This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit f6b23d4862b6190146215735a60dd77bd81023fa Author: Claus Ibsen <[email protected]> AuthorDate: Mon Jul 27 20:26:59 2026 +0200 camel-tui: Carry over activity and errors across data refresh cycles Co-Authored-By: Claude Opus 4.6 <[email protected]> Signed-off-by: Claus Ibsen <[email protected]> --- .../camel/dsl/jbang/core/commands/tui/DataRefreshService.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/DataRefreshService.java b/dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/DataRefreshService.java index efe068e5d8c5..b7332b32b0cd 100644 --- a/dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/DataRefreshService.java +++ b/dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/DataRefreshService.java @@ -252,6 +252,8 @@ class DataRefreshService { } else { refreshPids = pids; } + Map<String, IntegrationInfo> previousByPid = data.get().stream() + .collect(Collectors.toMap(i -> i.pid, i -> i, (a, b) -> a)); for (Long pid : refreshPids) { JsonObject root = loadStatus(pid); if (root != null) { @@ -261,6 +263,11 @@ class DataRefreshService { } IntegrationInfo info = StatusParser.parseIntegration(ph, root); if (info != null) { + IntegrationInfo prev = previousByPid.get(info.pid); + if (prev != null) { + info.activity = prev.activity; + info.errors = prev.errors; + } infos.add(info); metrics.updateThroughputHistory(info); metrics.updateEndpointHistory(info);
