• 如果您觉得本站非常有看点，那么赶紧使用Ctrl+D 收藏吧
> java > Java ProviderSession类的典型用法和代码示例

Java ProviderSession类的典型用法和代码示例

java 2次浏览

本文整理汇总了Java中org.opendaylight.controller.sal.core.api.Broker.ProviderSession类的典型用法代码示例。如果您正苦于以下问题：Java ProviderSession类的具体用法？Java ProviderSession怎么用？Java ProviderSession使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ProviderSession类属于org.opendaylight.controller.sal.core.api.Broker包，在下文中一共展示了ProviderSession类的12个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: createInstance

​ 点赞 3 ​ 

import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; //导入依赖的package包/类
@Override
public RootBindingAwareBroker createInstance() {
    final Broker domBroker = getDomAsyncBrokerDependency();
    final BindingToNormalizedNodeCodec codec = getBindingMappingServiceDependency();
    final ProviderSession session = domBroker.registerProvider(new DummyDOMProvider());

    final MountPointService mount = createMountPointAdapter(codec,session);
    final BindingDOMRpcServiceAdapter rpcConsumer = createRpcConsumer(codec,session);
    final BindingDOMRpcProviderServiceAdapter rpcProvider = createRpcProvider(codec,session);
    final RootBindingAwareBroker broker = new RootBindingAwareBroker(getIdentifier().getInstanceName());
    final RpcProviderRegistry heliumRpcBroker = new HeliumRpcProviderRegistry(rpcConsumer, rpcProvider);

    broker.setNotificationBroker(getNotificationServiceDependency());
    if (getNotificationPublishServiceDependency() != null) {
        broker.setNotificationPublishService(getNotificationPublishServiceDependency());
    }
    broker.setRpcBroker(heliumRpcBroker);
    broker.setDataBroker(getRootDataBrokerDependency());
    broker.setMountService(mount);
    broker.start();
    return broker;
}

开发者ID:hashsdn，
项目名称:hashsdn-controller，
代码行数:23，
代码来源:BindingBrokerImplModule.java

示例2: createRpcProvider

​ 点赞 2 ​ 

import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; //导入依赖的package包/类
private BindingDOMRpcProviderServiceAdapter createRpcProvider(final BindingToNormalizedNodeCodec codec,
        final ProviderSession session) {
    final DOMRpcProviderService domService = session.getService(DOMRpcProviderService.class);
    if(domService != null) {
        return new BindingDOMRpcProviderServiceAdapter(domService, codec);
    }
    return null;
}

开发者ID:hashsdn，
项目名称:hashsdn-controller，
代码行数:9，
代码来源:BindingBrokerImplModule.java

示例3: createRpcConsumer

​ 点赞 2 ​ 

import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; //导入依赖的package包/类
private BindingDOMRpcServiceAdapter createRpcConsumer(final BindingToNormalizedNodeCodec codec, final ProviderSession session) {
    final DOMRpcService domService = session.getService(DOMRpcService.class);
    if(domService != null) {
        return new BindingDOMRpcServiceAdapter(domService, codec);
    }
    return null;
}

开发者ID:hashsdn，
项目名称:hashsdn-controller，
代码行数:8，
代码来源:BindingBrokerImplModule.java

示例4: createMountPointAdapter

​ 点赞 2 ​ 

import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; //导入依赖的package包/类
private MountPointService createMountPointAdapter(final BindingToNormalizedNodeCodec codec, final ProviderSession session) {
    final DOMMountPointService domService = session.getService(DOMMountPointService.class);
    if(domService != null) {
        return new BindingDOMMountPointServiceAdapter(domService, codec);
    }
    return null;
}

开发者ID:hashsdn，
项目名称:hashsdn-controller，
代码行数:8，
代码来源:BindingBrokerImplModule.java

示例5: onSessionInitiated

​ 点赞 2 ​ 

import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; //导入依赖的package包/类
@Override
public void onSessionInitiated(final ProviderSession session) {
    String initiationSuccessful = "Messaging4TransportProviderImpl Session Initiated";
    LOG.info(initiationSuccessful);
    AmqpPublisher.publish(initiationSuccessful);

    final DOMDataBroker domDataBroker = session.getService(DOMDataBroker.class);
    final SchemaService schemaService = session.getService(SchemaService.class);

    listenerRegistration = schemaService.registerSchemaContextListener(ControllerContext.getInstance());

    ControllerContext.getInstance().setSchemas(schemaService.getGlobalContext());
    ControllerContext.getInstance().setMountService(session.getService(DOMMountPointService.class));
}

开发者ID:opendaylight，
项目名称:messaging4transport，
代码行数:15，
代码来源:Messaging4TransportProviderImpl.java

示例6: onBISessionAvailable

​ 点赞 2 ​ 

import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; //导入依赖的package包/类
@Override
public void onBISessionAvailable(ProviderSession session) {
    biSession = session;
    if (biSession != null) {
        biNotifyService = session
                .getService(org.opendaylight.controller.sal.core.api.notify.NotificationProviderService.class);
    }
}

开发者ID:lbchen，
项目名称:ODL，
代码行数:9，
代码来源:NotificationModule.java

示例7: onSessionInitiated

​ 点赞 2 ​ 

import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderSession session) {
    // NOOP
}

开发者ID:hashsdn，
项目名称:hashsdn-controller，
代码行数:5，
代码来源:DummyNoopProvider.java

示例8: onSessionInitiated

​ 点赞 2 ​ 

import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderSession session) {
    this.session = session;
    notifier = session.getService(NotificationProviderService.class);
}

开发者ID:lbchen，
项目名称:ODL，
代码行数:6，
代码来源:DemoProviderImpl.java

示例9: onSessionInitiated

​ 点赞 1 ​ 

import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; //导入依赖的package包/类
/**
 * Callback signaling initialization of the provider session to the SAL.
 *
 * <p>
 * The provider <b>MUST use the session</b> for all communication with SAL
 * or retrieving SAL infrastructure services.
 *
 * <p>
 * This method is invoked by {@link Broker#registerConsumer(Consumer)}
 *
 * @param session
 *            Unique session between provider and SAL.
 */
void onSessionInitiated(ProviderSession session);

开发者ID:hashsdn，
项目名称:hashsdn-controller，
代码行数:15，
代码来源:Provider.java

示例10: onSessionInitiated

​ 点赞 1 ​ 

import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; //导入依赖的package包/类
/**
 * Callback signaling initialization of the provider session to the SAL.
 * 
 * <p>
 * The provider <b>MUST use the session</b> for all communication with SAL
 * or retrieving SAL infrastructure services.
 * 
 * <p>
 * This method is invoked by {@link Broker#registerConsumer(Consumer)}
 * 
 * @param session
 *            Unique session between provider and SAL.
 */
public void onSessionInitiated(ProviderSession session);

开发者ID:lbchen，
项目名称:ODL，
代码行数:15，
代码来源:Provider.java

示例11: delegate

​ 点赞 1 ​ 

import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; //导入依赖的package包/类
protected abstract ProviderSession delegate();

开发者ID:hashsdn，
项目名称:hashsdn-controller，
代码行数:2，
代码来源:ForwardingProviderSession.java

示例12: onBISessionAvailable

​ 点赞 1 ​ 

import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; //导入依赖的package包/类
void onBISessionAvailable(ProviderSession session);

开发者ID:lbchen，
项目名称:ODL，
代码行数:2，
代码来源:SALBindingModule.java

版权声明：本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系管理员进行删除。
喜欢 (0)