• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

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)