Merge branch 'refs/heads/main' into feature/962-notification-model-up…

…date
eclipse-tractusx · Jun 18, 2024 · b9abe45 · b9abe45
2 parents 341d14b + 39e3f18
commit b9abe45
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/.../tractusx/traceability/notification/domain/base/service/NotificationPublisherService.java b/.../tractusx/traceability/notification/domain/base/service/NotificationPublisherService.java
@@ -64,8 +64,12 @@ public Notification startNotification(StartNotification startNotification) {
     }
 
     private void createMessages(StartNotification startNotification, BPN applicationBPN, Notification notification, AssetAsBuiltRepository assetAsBuiltRepository) {
-        Map<String, List<AssetBase>> assetsAsBuiltBPNMap = assetAsBuiltRepository.getAssetsById(startNotification.getAffectedPartIds()).stream().collect(groupingBy(AssetBase::getManufacturerId));
-        assetsAsBuiltBPNMap
+        Map<String, List<AssetBase>> assetsAsBuiltBPNMap =
+                assetAsBuiltRepository
+                        .getAssetsById(startNotification.getAffectedPartIds())
+                        .stream()
+                        .filter(asset -> Objects.nonNull(asset.getManufacturerId()))
+                        .collect(groupingBy(AssetBase::getManufacturerId));        assetsAsBuiltBPNMap
                 .entrySet()
                 .stream()
                 .map(it -> {