diff --git a/src/main/java/de/ozgcloud/xta/client/XtaClient.java b/src/main/java/de/ozgcloud/xta/client/XtaClient.java index 16216282fe7a61ddabb650ff6f8a4ff47627f8e8..08abacf101ab81fa54c2ba04a1da96d7a149d032 100644 --- a/src/main/java/de/ozgcloud/xta/client/XtaClient.java +++ b/src/main/java/de/ozgcloud/xta/client/XtaClient.java @@ -83,12 +83,12 @@ public class XtaClient { } boolean checkSomeMessageHasBeenClosed(List<XtaTransportReport> transportReports) { - var someTransportReportHasGreenStatus = transportReports.stream() - .anyMatch(t -> t.status().equals(XtaMessageStatus.GREEN)); - if (!someTransportReportHasGreenStatus) { + var someTransportReportHasClosedStatus = transportReports.stream() + .anyMatch(t -> !t.status().equals(XtaMessageStatus.OPEN)); + if (!someTransportReportHasClosedStatus) { logWarnForNoMessageClosed(); } - return someTransportReportHasGreenStatus; + return someTransportReportHasClosedStatus; } void logWarnForNoMessageClosed() {