import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RpcRegistration; //导入依赖的package包/类
private void constructorTestHelper(){
    aggregatorRpcReg = mock(RpcRegistration.class);
    EventSourceService eventSourceService = mock(EventSourceService.class);
    doReturn(aggregatorRpcReg).when(rpcProviderRegistryMock).addRpcImplementation(eq(EventAggregatorService.class), any(EventSourceTopology.class));
    doReturn(eventSourceService).when(rpcProviderRegistryMock).getRpcService(EventSourceService.class);
    WriteTransaction writeTransactionMock = mock(WriteTransaction.class);
    doReturn(writeTransactionMock).when(dataBrokerMock).newWriteOnlyTransaction();
    doNothing().when(writeTransactionMock).put(any(LogicalDatastoreType.class), any(InstanceIdentifier.class), any(DataObject.class),eq(true));
    CheckedFuture checkedFutureMock = mock(CheckedFuture.class);
    doReturn(checkedFutureMock).when(writeTransactionMock).submit();
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RpcRegistration; //导入依赖的package包/类
public void destroy() {
    for (RpcRegistration<RpcService> reg: rpcRegistrations) {
        reg.close();
    }
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RpcRegistration; //导入依赖的package包/类
@Override
public <T extends RpcService> RpcRegistration<T> addRpcImplementation(final Class<T> type, final T implementation)
        throws IllegalStateException {
    return getRpcRegistryChecked().addRpcImplementation(type, implementation);
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RpcRegistration; //导入依赖的package包/类
@Override
public <T extends RpcService> RpcRegistration<T> addRpcImplementation(Class<T> type, T implementation)
        throws IllegalStateException {
    return getSALService(RpcProviderRegistry.class).addRpcImplementation(type, implementation);
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RpcRegistration; //导入依赖的package包/类
@Override
public <T extends RpcService> RpcRegistration<T> addRpcImplementation(final Class<T> type, final T impl)
        throws IllegalStateException {
    final ObjectRegistration<T> reg = providerAdapter.registerRpcImplementation(type, impl);
    return new DelegatedRootRpcRegistration<>(type,reg);
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RpcRegistration; //导入依赖的package包/类
/**
 * Registers a global implementation of the provided RPC service interface.
 * All methods of the interface are required to be implemented.
 *
 * @param serviceInterface the YANG-generated interface of the RPC Service for which to register.
 * @param implementation "the implementation of the RPC service interface.
 * @return an RpcRegistration instance that should be used to unregister the RPC implementation
 *         when no longer needed by calling {@link RpcRegistration#close()}.
 *
 * @throws IllegalStateException
 *             if the supplied RPC interface is a routed RPC type.
 */
<T extends RpcService> RpcRegistration<T> addRpcImplementation(Class<T> serviceInterface, T implementation)
        throws IllegalStateException;