import org.opendaylight.yangtools.concepts.Registration; //导入依赖的package包/类
@Override
public void close() {
    if (delegate != null) {
        delegate = null;
        RuntimeException potentialException = new RuntimeException(
                "Uncaught exceptions occured during unregistration");
        boolean hasSuppressed = false;
        for (Registration registration : registrations) {
            try {
                registration.close();
            } catch (Exception e) {
                potentialException.addSuppressed(e);
                hasSuppressed = true;
            }
        }
        if (hasSuppressed) {
            throw potentialException;
        }
    }
}
 

import org.opendaylight.yangtools.concepts.Registration; //导入依赖的package包/类
private List<Registration> registerDataChangeListeners() {
    Preconditions.checkNotNull(dataBroker);
    List<Registration> registrations = Lists.newArrayList();
    try {
        //Register listener for config updates and topology
        InstanceIdentifier<AclSpec> aclSpecIID = InstanceIdentifier.builder(AclSpec.class)
                .build();
        ListenerRegistration<DataChangeListener> registration = dataBroker.registerDataChangeListener(
                LogicalDatastoreType.CONFIGURATION,
                aclSpecIID, this, AsyncDataBroker.DataChangeScope.SUBTREE);
        LOG.debug("DataChangeListener registered with MD-SAL for path {}", aclSpecIID);
        registrations.add(registration);

    } catch (Exception e) {
        LOG.error("Exception reached {}", e);
    }
    return registrations;
}
 

import org.opendaylight.yangtools.concepts.Registration; //导入依赖的package包/类
private List<Registration> registerDataChangeListeners() {
    Preconditions.checkNotNull(dataBroker);
    List<Registration> registrations = Lists.newArrayList();
    try {
        //Register listener for config updates and topology
        InstanceIdentifier<TapSpec> tapSpecIID = InstanceIdentifier.builder(TapSpec.class)
                .build();
        ListenerRegistration<DataChangeListener> registration = dataBroker.registerDataChangeListener(
                LogicalDatastoreType.CONFIGURATION,
                tapSpecIID, this, AsyncDataBroker.DataChangeScope.SUBTREE);
        LOG.debug("DataChangeListener registered with MD-SAL for path {}", tapSpecIID);
        registrations.add(registration);

    } catch (Exception e) {
        LOG.error("Exception reached {}", e);
    }
    return registrations;
}
 

import org.opendaylight.yangtools.concepts.Registration; //导入依赖的package包/类
@Override
public void close() throws Exception {
    for (Registration registration : registrations) {
        registration.close();
    }
    registrations.clear();
}
 

import org.opendaylight.yangtools.concepts.Registration; //导入依赖的package包/类
@Override
public void close() throws Exception {
    for (Registration registration : registrations) {
    	registration.close();
    }
    registrations.clear();
}
 

import org.opendaylight.yangtools.concepts.Registration; //导入依赖的package包/类
protected <R extends Registration> R addRegistration(final R registration) {
    if (registration != null) {
        registrations.add(registration);
    }
    return registration;
}
 

import org.opendaylight.yangtools.concepts.Registration; //导入依赖的package包/类
public void close() throws Exception {
    for (Registration registration : registrations) {
        registration.close();
    }
    registrations.clear();
}