import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer; //导入依赖的package包/类
/**
 *
 * Ignored this, because classes here are constructed from
 * very different class loader as MD-SAL is run into,
 * this is code is run from different classloader.
 *
 * @throws Exception
 */
@Test
public void test() throws Exception {
    BindingAwareConsumer consumer = session -> dataBroker = session.getSALService(DataBroker.class);

    broker.registerConsumer(consumer);

    assertNotNull(dataBroker);


    final WriteTransaction transaction = dataBroker.newWriteOnlyTransaction();
    assertNotNull(transaction);

    InstanceIdentifier<UnorderedList> node1 = createNodeRef("0");
    Optional<UnorderedList> node = dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.OPERATIONAL, node1)
            .checkedGet(5, TimeUnit.SECONDS);
    assertFalse(node.isPresent());
    UnorderedList nodeData1 = createNode("0");

    transaction.put(LogicalDatastoreType.OPERATIONAL, node1, nodeData1);
    transaction.submit().checkedGet(5, TimeUnit.SECONDS);

    Optional<UnorderedList> readedData = dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.OPERATIONAL,
            node1).checkedGet(5, TimeUnit.SECONDS);
    assertTrue(readedData.isPresent());
    assertEquals(nodeData1.getKey(), readedData.get().getKey());

    final WriteTransaction transaction2 = dataBroker.newWriteOnlyTransaction();
    assertNotNull(transaction2);

    transaction2.delete(LogicalDatastoreType.OPERATIONAL, node1);

    transaction2.submit().checkedGet(5, TimeUnit.SECONDS);

    Optional<UnorderedList> readedData2 = dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.OPERATIONAL,
            node1).checkedGet(5, TimeUnit.SECONDS);
    assertFalse(readedData2.isPresent());
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer; //导入依赖的package包/类
@Override
public ConsumerSession registerConsumer(BindingAwareConsumer consumer) {
    checkPredicates(consumer);
    log.info("Registering consumer " + consumer);

    ConsumerSessionImpl session = newSessionFor(consumer);
    consumer.onSessionInitialized(session);

    sessions.add(session);
    return session;
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer; //导入依赖的package包/类
private void checkPredicates(BindingAwareConsumer cons) {
    if (cons == null)
        throw new IllegalArgumentException("Consumer should not be null.");
    for (ConsumerSessionImpl session : sessions) {
        if (cons.equals(session.getConsumer()))
            throw new IllegalStateException("Consumer already registered");
    }
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer; //导入依赖的package包/类
public static ConsumerContext createConsumerContext(BindingAwareConsumer consumer,
        ClassToInstanceMap<BindingAwareService> serviceProvider) {
    checkNotNull(consumer,"Consumer should not be null");
    checkNotNull(serviceProvider,"Service map should not be null");
    return new SingleConsumerContextImpl(serviceProvider);
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer; //导入依赖的package包/类
public static ConsumerContext createConsumerContextAndInitialize(BindingAwareConsumer consumer,
        ClassToInstanceMap<BindingAwareService> serviceProvider) {
    ConsumerContext context = createConsumerContext(consumer, serviceProvider);
    consumer.onSessionInitialized(context);
    return context;
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer; //导入依赖的package包/类
@Override
public ConsumerContext registerConsumer(final BindingAwareConsumer consumer, final BundleContext ctx) {
    return registerConsumer(consumer);
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer; //导入依赖的package包/类
private ConsumerSessionImpl newSessionFor(BindingAwareConsumer cons) {
    return new ConsumerSessionImpl(cons);
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer; //导入依赖的package包/类
public ConsumerSessionImpl(BindingAwareConsumer cons) {
    this.consumer = cons;
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer; //导入依赖的package包/类
public BindingAwareConsumer getConsumer() {
    return this.consumer;
}