org.opendaylight.controller.sal.core.api.Broker.registerProvider()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(8.3k)|赞(0)|评价(0)|浏览(61)

本文整理了Java中org.opendaylight.controller.sal.core.api.Broker.registerProvider()方法的一些代码示例,展示了Broker.registerProvider()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Broker.registerProvider()方法的具体详情如下:
包路径:org.opendaylight.controller.sal.core.api.Broker
类名称:Broker
方法名:registerProvider

Broker.registerProvider介绍

暂无

代码示例

代码示例来源:origin: org.opendaylight.netconf/netconf-topology

public void registerToSal(final Broker domRegistryDependency) {
  domRegistryDependency.registerProvider(salProvider);
}

代码示例来源:origin: org.opendaylight.netconf/sal-rest-docgen

@Override
public Broker addingService(ServiceReference<Broker> reference) {
  Broker broker = bundleContext.getService(reference);
  session = broker.registerProvider(this, bundleContext);
  return broker;
}

代码示例来源:origin: org.opendaylight.netconf/netconf-topology

protected void registerToSal(BindingAwareProvider baProvider, Provider provider) {
  domBroker.registerProvider(provider);
  bindingAwareBroker.registerProvider(baProvider);
}

代码示例来源:origin: org.opendaylight.netconf/sal-rest-docgen

@Override
public void modifiedService(ServiceReference<Broker> reference, Broker service) {
  if (session != null) {
    session.close();
  }
  Broker broker = bundleContext.getService(reference);
  session = broker.registerProvider(this, bundleContext);
}

代码示例来源:origin: org.opendaylight.controller/sal-netconf-connector

public void registerToSal(final Broker domRegistryDependency, final BindingAwareBroker bindingBroker, final BundleContext bundleContext) {
  domRegistryDependency.registerProvider(salProvider, bundleContext);
  bindingBroker.registerProvider(salProvider, bundleContext);
}

代码示例来源:origin: org.opendaylight.yang-push/yangpush-impl

@Override
public java.lang.AutoCloseable createInstance() {
  //YangpushProvider provider = new YangpushProvider();
  //getBrokerDependency().registerProvider(provider);
  
  final YangpushDomProvider provider = new YangpushDomProvider();
  getDomBrokerDependency().registerProvider(provider);
  
  return provider;
}

代码示例来源:origin: org.opendaylight.aaa/aaa-authz-service

@Override
public ProviderSession registerProvider(Provider provider) {
  ProviderSession realSession = broker.registerProvider(new ProviderWrapper(provider));
  AuthzProviderContextImpl authzProviderContext = new AuthzProviderContextImpl(realSession,
      this);
  provider.onSessionInitiated(authzProviderContext);
  return authzProviderContext;
}

代码示例来源:origin: org.opendaylight.aaa/aaa-authz-service

@Override
public ProviderSession registerProvider(Provider provider, BundleContext bundleContext) {
  // Allow the real broker to do its thing, while providing a wrapped
  // callback
  ProviderSession realSession = broker.registerProvider(new ProviderWrapper(provider),
      bundleContext);
  // Create Authz ProviderContext
  AuthzProviderContextImpl authzProviderContext = new AuthzProviderContextImpl(realSession,
      this);
  // Run onsessionInitiated on injected provider with the AuthZ provider
  // context.
  provider.onSessionInitiated(authzProviderContext);
  return authzProviderContext;
}

代码示例来源:origin: org.opendaylight.controller/sal-binding-config

@Override
public java.lang.AutoCloseable createInstance() {
  final BindingToNormalizedNodeCodec codec = getBindingMappingServiceDependency();
  final Broker.ProviderSession session = getDomAsyncBrokerDependency().registerProvider(new DummyDOMProvider());
  final DOMNotificationPublishService publishService = session.getService(DOMNotificationPublishService.class);
  return new BindingDOMNotificationPublishServiceAdapter(codec, publishService);
}

代码示例来源:origin: org.opendaylight.aaa/aaa-authz-service

@Override
public java.lang.AutoCloseable createInstance() {
  // Get new AuthZ Broker
  final AuthzBrokerImpl authzBrokerImpl = new AuthzBrokerImpl();
  // Provide real broker to the new Authz broker
  authzBrokerImpl.setBroker(getDomBrokerDependency());
  // Get AuthN service reference and register it with the authzBroker
  ServiceReference<AuthenticationService> authServiceReference = bundleContext
      .getServiceReference(AuthenticationService.class);
  AuthenticationService as = bundleContext.getService(authServiceReference);
  authzBrokerImpl.setAuthenticationService(as);
  // Set the policies list to authz serviceimpl
  AuthzServiceImpl.setPolicies(getPolicies());
  // Register AuthZ broker with the real Broker as a provider; triggers
  // "onSessionInitiated" in AuthzBrokerImpl
  getDomBrokerDependency().registerProvider(authzBrokerImpl);
  // TODO ActionType is of type string, not ENUM due to improper
  // serialization of ENUMs by config/netconf subsystem. This needs to be
  // fixed as soon as config/netconf fixes the problem.
  getAction();
  LOG.info("AuthZ Service Initialized from Config subsystem");
  return authzBrokerImpl;
}

代码示例来源:origin: org.opendaylight.controller/sal-binding-config

@Override
public java.lang.AutoCloseable createInstance() {
  final BindingToNormalizedNodeCodec codec = getBindingMappingServiceDependency();
  final Broker.ProviderSession session = getDomAsyncBrokerDependency().registerProvider(new DummyDOMProvider());
  final DOMNotificationService notifService = session.getService(DOMNotificationService.class);
  return new BindingDOMNotificationServiceAdapter(codec.getCodecRegistry(), notifService);
}

代码示例来源:origin: org.opendaylight.controller/sal-rest-connector

@Override
  public java.lang.AutoCloseable createInstance() {
    // Create an instance of our provider
    RestconfProviderImpl instance = new RestconfProviderImpl();
    // Set its port
    instance.setWebsocketPort(getWebsocketPort());
    // Register it with the Broker
    getDomBrokerDependency().registerProvider(instance);

    if(runtimeRegistration != null){
      runtimeRegistration.close();
    }

    runtimeRegistration =
      getRootRuntimeBeanRegistratorWrapper().register(instance);

    return instance;
  }
}

代码示例来源:origin: org.opendaylight.snbi/southplugin

@Override
public java.lang.AutoCloseable createInstance() {
  DataProviderService dataBrokerService = getDataBrokerDependency();
  //Holds references to service retrieve via the data broker.
  //DEMOSTRATES: How to get services via the config sub system (data broker).
  final MountingServiceDependencyManager dependencyManager = new MountingServiceDependencyManager();
  getDomRegistryDependency().registerProvider(dependencyManager, bundleContext);
  closeMgr.add( dependencyManager );
  //Holds references to service retrieve via the bundle context (pure OSGi)
  //DEMOSTRATES: How to get services from OSGi's bundle context when you can't get to them
  //via the BrokerService (config sub system).
  final BundleContextDependencyManager bundleContextMgr = new BundleContextDependencyManager();
  bundleContextMgr.setBundleContext( bundleContext );
  bundleContextMgr.init();
  closeMgr.add( bundleContextMgr );
  return null;
}

代码示例来源:origin: org.opendaylight.netconf/messagebus-netconf

@Override
public java.lang.AutoCloseable createInstance() {
  final BindingAwareBroker.ProviderContext bindingCtx = getBindingBrokerDependency().registerProvider(new Providers.BindingAware());
  final Broker.ProviderSession domCtx = getDomBrokerDependency().registerProvider(new Providers.BindingIndependent());
  final MountPointService mountPointService = bindingCtx.getSALService(MountPointService.class);
  final DataBroker dataBroker = bindingCtx.getSALService(DataBroker.class);
  final DOMNotificationPublishService domPublish = domCtx.getService(DOMNotificationPublishService.class);
  final DOMMountPointService domMount = domCtx.getService(DOMMountPointService.class);
  return NetconfEventSourceManager.create(dataBroker, domPublish, domMount,
    mountPointService, getEventSourceRegistryDependency(), getNamespaceToStream());
}

代码示例来源:origin: org.opendaylight.controller/sal-binding-config

@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);
  final MountProviderService legacyMount = createLegacyMountPointService(mount);
  broker.setLegacyDataBroker(getDataBrokerDependency());
  broker.setNotificationBroker(getNotificationServiceDependency());
  if (getNotificationPublishServiceDependency() != null) {
    broker.setNotificationPublishService(getNotificationPublishServiceDependency());
  }
  broker.setRpcBroker(heliumRpcBroker);
  broker.setDataBroker(getRootDataBrokerDependency());
  broker.setMountService(mount);
  broker.setLegacyMountManager(legacyMount);
  broker.start();
  return broker;
}

相关文章

微信公众号

最新文章

更多