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

Broker.registerConsumer介绍

暂无

代码示例

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