This is an automated email from the ASF dual-hosted git repository.
marat pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-karavan.git
The following commit(s) were added to refs/heads/main by this push:
new f4076dd Fix #509
f4076dd is described below
commit f4076ddd44738148b8f85f101ac3a7b44a369af6
Author: Marat Gubaidullin <[email protected]>
AuthorDate: Mon Oct 31 18:18:15 2022 -0400
Fix #509
---
.../src/main/java/org/apache/camel/karavan/service/StatusService.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/karavan-app/src/main/java/org/apache/camel/karavan/service/StatusService.java
b/karavan-app/src/main/java/org/apache/camel/karavan/service/StatusService.java
index 06f95f2..07b9132 100644
---
a/karavan-app/src/main/java/org/apache/camel/karavan/service/StatusService.java
+++
b/karavan-app/src/main/java/org/apache/camel/karavan/service/StatusService.java
@@ -83,7 +83,7 @@ public class StatusService {
@ConsumeEvent(value = CMD_COLLECT_ALL_STATUSES, blocking = true, ordered =
true)
public void collectAllStatuses(String data) {
if ((System.currentTimeMillis() - lastCollect) > threshold) {
- infinispanService.getProjects().forEach(project ->
eventBus.publish(CMD_COLLECT_PROJECT_STATUS, project.getProjectId()));
+ infinispanService.getDeploymentStatuses().forEach(d ->
eventBus.publish(CMD_COLLECT_PROJECT_STATUS, d.getName()));
lastCollect = System.currentTimeMillis();
}
}