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

Broker介绍

暂无

代码示例

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

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

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

@Override
public ConsumerSession registerConsumer(Consumer consumer) {
  ConsumerSession realSession = broker.registerConsumer(new ConsumerWrapper(consumer));
  AuthzConsumerContextImpl authzConsumerContext = new AuthzConsumerContextImpl(realSession,
      this);
  consumer.onSessionInitiated(authzConsumerContext);
  return authzConsumerContext;
}

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

@Override
public ConsumerSession registerConsumer(Consumer consumer, BundleContext bundleContext) {
  ConsumerSession realSession = broker.registerConsumer(new ConsumerWrapper(consumer),
      bundleContext);
  AuthzConsumerContextImpl authzConsumerContext = new AuthzConsumerContextImpl(realSession,
      this);
  consumer.onSessionInitiated(authzConsumerContext);
  return authzConsumerContext;
}

代码示例来源：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.messaging4transport/messaging4transport-impl

@Override
  public java.lang.AutoCloseable createInstance() {
    final DOMDataBroker dataBroker = getDomBrokerDependency()
        .registerConsumer(new NoopDOMConsumer()).getService(DOMDataBroker.class);
    final DOMNotificationService notifyService = getDomBrokerDependency()
        .registerConsumer(new NoopDOMConsumer())
        .getService(DOMNotificationService.class);
    return new AmqpUserAgentFactory(dataBroker, notifyService);
  }
}

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

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

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

@Override
public java.lang.AutoCloseable createInstance() {
  final MdsalNetconfOperationServiceFactory mdsalNetconfOperationServiceFactory =
      new MdsalNetconfOperationServiceFactory(getRootSchemaServiceDependency()) {
        @Override
        public void close() throws Exception {
          super.close();
          getMapperAggregatorDependency().onRemoveNetconfOperationServiceFactory(this);
        }
      };
  getDomBrokerDependency().registerConsumer(mdsalNetconfOperationServiceFactory);
  getMapperAggregatorDependency().onAddNetconfOperationServiceFactory(mdsalNetconfOperationServiceFactory);
  return mdsalNetconfOperationServiceFactory;
}

代码示例来源：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.coretutorials/hweventsource-uagent

@Override
public java.lang.AutoCloseable createInstance() {
  final ProviderContext bindingCtx = getBrokerDependency().registerProvider(new Providers.BindingAware());
  final RpcProviderRegistry rpcRegistry = bindingCtx.getSALService(RpcProviderRegistry.class);
  final DOMNotificationService notifyService = getDomBrokerDependency()
      .registerConsumer(new NoopDOMConsumer())
      .getService(DOMNotificationService.class);
  final File outputFile = new File(getOutputFileName());
  UserAgent ua = UserAgent.create(notifyService,rpcRegistry, outputFile);
  if(ua != null){
    LOG.info("HweventsourceUagent has been initialized");
  } else {
    LOG.error("HweventsourceUagent has not been initialized");
  }
  return ua;
}

代码示例来源：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.netconf/mdsal-netconf-connector

@Override
public java.lang.AutoCloseable createInstance() {
  final MdsalNetconfOperationServiceFactory mdsalNetconfOperationServiceFactory =
    new MdsalNetconfOperationServiceFactory(getRootSchemaServiceDependency(), getRootSchemaSourceProviderDependency()) {
      @Override
      public void close() throws Exception {
        super.close();
        getMapperAggregatorDependency().onRemoveNetconfOperationServiceFactory(this);
      }
    };
  getDomBrokerDependency().registerConsumer(mdsalNetconfOperationServiceFactory);
  getMapperAggregatorDependency().onAddNetconfOperationServiceFactory(mdsalNetconfOperationServiceFactory);
  return mdsalNetconfOperationServiceFactory;
}

代码示例来源：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());
}