import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext; //导入依赖的package包/类
/**
 * Starts the bgp router
 */
@Before
public void init() throws InterruptedException, ExecutionException {
	setupBgpRouter();
	bgpRouter.onSessionInitialized(mock(ConsumerContext.class));
	setupBgpSpeakers();
	bgpRouter.start();
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext; //导入依赖的package包/类
@Override
public void onSessionInitialized(ConsumerContext session) {
    NotificationService notificationService = session
            .getSALService(NotificationService.class);
    registration = notificationService
            .registerNotificationListener(new HelloListenerImpl());
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext; //导入依赖的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.BindingAwareBroker.ConsumerContext; //导入依赖的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.BindingAwareBroker.ConsumerContext; //导入依赖的package包/类
@Override
public void onSessionInitialized(ConsumerContext arg0) {
	LOG.info("Atrium Cli Started");
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext; //导入依赖的package包/类
@Override
public void onSessionInitialized(ConsumerContext context) {
    LOG.info("TopologyUpdateProvider onSessionInitiated");
    notificationService.registerNotificationListener(producer);
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext; //导入依赖的package包/类
/**
 * Callback signaling initialization of the consumer session to the SAL.
 *
 * The consumer MUST use the session for all communication with SAL or
 * retrieving SAL infrastructure services.
 *
 * This method is invoked by
 * {@link BindingAwareBroker#registerConsumer(BindingAwareConsumer)}
 *
 * @param session
 *            Unique session between consumer and SAL.
 */
void onSessionInitialized(ConsumerContext session);
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext; //导入依赖的package包/类
/**
 * Call back function which gets invoked on feature module initialization
 *
 * @param ctxt
 *
 *
 */
@Override
public void onSessionInitialized(ConsumerContext ctxt) {
	LOG.info("BgprouterProvider Session Initiated");
}