X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fconfig%2Fconfig-manager%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fmanager%2Fimpl%2Futil%2FOsgiRegistrationUtil.java;h=7c02019544977b8e33d4ecd08ad91d2ab6af3642;hp=fe8e30ee9ad2816a63f38365fb39c032193dd798;hb=refs%2Fchanges%2F73%2F46573%2F5;hpb=660c3e22ca97bc613ea6f6288503620bba6fb233 diff --git a/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/util/OsgiRegistrationUtil.java b/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/util/OsgiRegistrationUtil.java index fe8e30ee9a..7c02019544 100644 --- a/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/util/OsgiRegistrationUtil.java +++ b/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/util/OsgiRegistrationUtil.java @@ -9,7 +9,6 @@ package org.opendaylight.controller.config.manager.impl.util; import static com.google.common.base.Preconditions.checkNotNull; - import java.util.ArrayList; import java.util.List; import java.util.ListIterator; @@ -40,32 +39,17 @@ public class OsgiRegistrationUtil { public static AutoCloseable wrap(final ServiceRegistration reg) { checkNotNull(reg); - return new AutoCloseable() { - @Override - public void close() throws Exception { - reg.unregister(); - } - }; + return reg::unregister; } public static AutoCloseable wrap(final BundleTracker bundleTracker) { checkNotNull(bundleTracker); - return new AutoCloseable() { - @Override - public void close() throws Exception { - bundleTracker.close(); - } - }; + return bundleTracker::close; } public static AutoCloseable wrap(final ServiceTracker serviceTracker) { checkNotNull(serviceTracker); - return new AutoCloseable() { - @Override - public void close() throws Exception { - serviceTracker.close(); - } - }; + return serviceTracker::close; } /** @@ -74,26 +58,23 @@ public class OsgiRegistrationUtil { public static AutoCloseable aggregate(final List list) { checkNotNull(list); - return new AutoCloseable() { - @Override - public void close() throws Exception { - Exception firstException = null; - for (ListIterator it = list.listIterator(list.size()); it.hasPrevious();) { - AutoCloseable ac = it.previous(); - try { - ac.close(); - } catch (Exception e) { - LOG.warn("Exception while closing {}", ac, e); - if (firstException == null) { - firstException = e; - } else { - firstException.addSuppressed(e); - } + return () -> { + Exception firstException = null; + for (ListIterator it = list.listIterator(list.size()); it.hasPrevious();) { + AutoCloseable ac = it.previous(); + try { + ac.close(); + } catch (Exception e) { + LOG.warn("Exception while closing {}", ac, e); + if (firstException == null) { + firstException = e; + } else { + firstException.addSuppressed(e); } } - if (firstException != null) { - throw firstException; - } + } + if (firstException != null) { + throw firstException; } }; }