You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@aries.apache.org by cs...@apache.org on 2017/08/03 12:36:50 UTC
svn commit: r1803991 -
/aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/DistributeOSGi.java
Author: csierra
Date: Thu Aug 3 12:36:50 2017
New Revision: 1803991
URL: http://svn.apache.org/viewvc?rev=1803991&view=rev
Log:
Close all results even if one fails
Otherwise a failure in one result will leave the application in an
inconsistent state
Modified:
aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/DistributeOSGi.java
Modified: aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/DistributeOSGi.java
URL: http://svn.apache.org/viewvc/aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/DistributeOSGi.java?rev=1803991&r1=1803990&r2=1803991&view=diff
==============================================================================
--- aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/DistributeOSGi.java (original)
+++ aries/trunk/component-dsl/component-dsl/src/main/java/org/apache/aries/osgi/functional/internal/DistributeOSGi.java Thu Aug 3 12:36:50 2017
@@ -56,7 +56,14 @@ public class DistributeOSGi extends OSGi
() -> {
removedSource.accept(Tuple.create(null));
- results.forEach(OSGiResult::close);
+ for (OSGiResult<?> result : results) {
+ try {
+ result.close();
+ }
+ catch (Exception ignored) {
+ }
+ }
+
}
);
});