javax.enterprise.inject.spi.AfterBeanDiscovery.addObserverMethod()方法的使用及代码示例

x33g5p2x  于2022-01-15 转载在 其他  
字(10.9k)|赞(0)|评价(0)|浏览(79)

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

AfterBeanDiscovery.addObserverMethod介绍

[英]obtains a new ObserverMethodConfigurator to configure a new ObserverMethod and add it at the end of the observer invocation. It will then fire an event of type javax.enterprise.inject.spi.ProcessObserverMethod containing the built javax.enterprise.inject.spi.ObserverMethod from this configuration and then registers the javax.enterprise.inject.spi.ObserverMethod with the container, thereby making it available for event notifications. Each call returns a new ObserverMethodConfigurator.
[中]获取新的ObserverMethodConfigurator以配置新的ObserverMethod,并在observer调用结束时添加它。然后它将触发javax类型的事件。企业注射spi。包含内置javax的ProcessObserverMethod。企业注射spi。ObserverMethod,然后注册javax。企业注射spi。ObserverMethod,从而使其可用于事件通知。每个调用都返回一个新的ObserverMethodConfigurator。

代码示例

代码示例来源:origin: org.jboss.cdi.tck/cdi-tck-impl

void execute() {
    event.addObserverMethod();
  }
}.run();

代码示例来源:origin: org.jboss.cdi.tck/cdi-tck-impl

public void registerObservers(@Observes AfterBeanDiscovery event) {
  event.addObserverMethod(anyGiraffeObserver);
  event.addObserverMethod(fiveMeterTallGiraffeObserver);
  event.addObserverMethod(sixMeterTallAngryGiraffeObserver);
  event.addObserverMethod(angryNubianGiraffeObserver);
}

代码示例来源:origin: org.jboss.cdi.tck/cdi-tck-impl

public void registerObservers(@Observes AfterBeanDiscovery event) {
  event.addObserverMethod(anyGiraffeObserver);
}

代码示例来源:origin: org.jboss.cdi.tck/cdi-tck-impl

private void addObserverMethod(AfterBeanDiscovery event) {
  addedObserverMethod = new TestableObserverMethod<Talk>() {
    boolean observed = false;
    public void notify(Talk event) {
      observed = true;
    }
    public void notify(Talk event, Set<Annotation> qualifiers) {
      observed = true;
    }
    public boolean isObserved() {
      return observed;
    }
    public Class<?> getBeanClass() {
      return Listener.class;
    }
    public Set<Annotation> getObservedQualifiers() {
      return Collections.<Annotation> singleton(Any.Literal.INSTANCE);
    }
    public Type getObservedType() {
      return Talk.class;
    }
    public Reception getReception() {
      return Reception.ALWAYS;
    }
    public TransactionPhase getTransactionPhase() {
      return TransactionPhase.IN_PROGRESS;
    }
  };
  event.addObserverMethod(addedObserverMethod);
}

代码示例来源:origin: org.jboss.cdi.tck/cdi-tck-impl

public void afterBeanDiscovery(@Observes AfterBeanDiscovery event) {
    // add custom observer which does not override notify method - should throw exception
    event.addObserverMethod(new ObserverMethod<Foo>() {
      @Override
      public Class<?> getBeanClass() {
        return AfterBeanDiscovery.class;
      }

      @Override
      public Type getObservedType() {
        return Foo.class;
      }

      @Override
      public Set<Annotation> getObservedQualifiers() {
        return Collections.emptySet();
      }

      @Override
      public Reception getReception() {
        return Reception.ALWAYS;
      }

      @Override
      public TransactionPhase getTransactionPhase() {
        return TransactionPhase.IN_PROGRESS;
      }
    });
  }
}

代码示例来源:origin: com.github.albfernandez.richfaces/richfaces-core

/**
 * Register observer method {@link PushCDIExtension.PushObserverMethod} for each {@link Push} annotation found in annotation scanning.
 *
 * @param event
 * @param beanManager
 */
public void afterBeanDiscovery(@Observes AfterBeanDiscovery event, BeanManager beanManager) {
  for (Push pushAnnotation : pushAnnotations) {
    event.addObserverMethod(new PushObserverMethod(beanManager, pushAnnotation));
  }
}

代码示例来源:origin: org.jboss.seam.jms/seam-jms

public void afterBeanDiscovery(@Observes AfterBeanDiscovery abd, BeanManager bm)
{
 Set<Bean<?>> configuration = bm.getBeans(JmsForwarding.class);
 
 if(configuration == null || configuration.isEmpty())
 {
   log.info("No {} registered.  Event forwarding disabled.", JmsForwarding.class.getSimpleName());
 } else
 {
   for(Bean<?> c : configuration)
   {
    log.info("Creating {} for configuration {}", BridgedObserver.class.getSimpleName(), c);
    CreationalContext<?> context = bm.createCreationalContext(c);
    // TODO Verify configuration for correctness (e.g. getQualifiers() must contain only @Qualifier annotations)
    JmsForwarding config = JmsForwarding.class.cast(bm.getReference(c, JmsForwarding.class, context));
    BridgedObserver b = new BridgedObserver(bm, config);
    abd.addObserverMethod(b);
   }
 }
}

代码示例来源:origin: org.talend.sdk.component/component-server

void addSecurityHandlerObservers(@Observes final AfterBeanDiscovery afterBeanDiscovery) {
  final ObserverMethodConfigurator<OnConnection> onConnection = afterBeanDiscovery.addObserverMethod();
  onConnection.observedType(OnConnection.class).notifyWith(this::onConnection);
  final ObserverMethodConfigurator<OnCommand> onCommand = afterBeanDiscovery.addObserverMethod();
  onCommand.observedType(OnCommand.class).notifyWith(this::onCommand);
}

代码示例来源:origin: org.jboss.cdi.tck/cdi-tck-impl

void execute() {
    event.addObserverMethod(extension.getProcessObserverMethod().getObserverMethod());
  }
}.run();

代码示例来源:origin: org.jboss.cdi.tck/cdi-tck-impl

public void afterBeanDiscovery(@Observes AfterBeanDiscovery event) {
  // not overriding notify method -> definition error
  event.<Foo>addObserverMethod().read(fooObserverMethod).async(true).priority(ObserverMethod.DEFAULT_PRIORITY);
}

代码示例来源:origin: weld/core

public void afterBeanDiscovery(@Observes AfterBeanDiscovery event, BeanManager beanManager) {
  BeanManagerImpl weldManager = BeanManagerProxy.unwrap(beanManager);
  String exclude = weldManager.getServices().get(WeldConfiguration.class).getStringProperty(ConfigurationKey.PROBE_EVENT_MONITOR_EXCLUDE_TYPE);
  event.addObserverMethod(new ProbeObserver(weldManager, exclude.isEmpty() ? null : Pattern.compile(exclude), probe));
  addContainerLifecycleEvent(event, null, beanManager);
}

代码示例来源:origin: org.jboss.weld.se/weld-se-shaded

public void afterBeanDiscovery(@Observes AfterBeanDiscovery event, BeanManager beanManager) {
  BeanManagerImpl weldManager = BeanManagerProxy.unwrap(beanManager);
  String exclude = weldManager.getServices().get(WeldConfiguration.class).getStringProperty(ConfigurationKey.PROBE_EVENT_MONITOR_EXCLUDE_TYPE);
  event.addObserverMethod(new ProbeObserver(weldManager, exclude.isEmpty() ? null : Pattern.compile(exclude), probe));
  addContainerLifecycleEvent(event, null, beanManager);
}

代码示例来源:origin: weld/core

public void afterBeanDiscovery(@Observes AfterBeanDiscovery event, BeanManager beanManager) {
  BeanManagerImpl weldManager = BeanManagerProxy.unwrap(beanManager);
  String exclude = weldManager.getServices().get(WeldConfiguration.class).getStringProperty(ConfigurationKey.PROBE_EVENT_MONITOR_EXCLUDE_TYPE);
  event.addObserverMethod(new ProbeObserver(weldManager, exclude.isEmpty() ? null : Pattern.compile(exclude), probe));
  addContainerLifecycleEvent(event, null, beanManager);
}

代码示例来源:origin: org.jboss.weld.se/weld-se

public void afterBeanDiscovery(@Observes AfterBeanDiscovery event, BeanManager beanManager) {
  BeanManagerImpl weldManager = BeanManagerProxy.unwrap(beanManager);
  String exclude = weldManager.getServices().get(WeldConfiguration.class).getStringProperty(ConfigurationKey.PROBE_EVENT_MONITOR_EXCLUDE_TYPE);
  event.addObserverMethod(new ProbeObserver(weldManager, exclude.isEmpty() ? null : Pattern.compile(exclude), probe));
  addContainerLifecycleEvent(event, null, beanManager);
}

代码示例来源:origin: org.jboss.weld.servlet/weld-servlet-shaded

public void afterBeanDiscovery(@Observes AfterBeanDiscovery event, BeanManager beanManager) {
  BeanManagerImpl weldManager = BeanManagerProxy.unwrap(beanManager);
  String exclude = weldManager.getServices().get(WeldConfiguration.class).getStringProperty(ConfigurationKey.PROBE_EVENT_MONITOR_EXCLUDE_TYPE);
  event.addObserverMethod(new ProbeObserver(weldManager, exclude.isEmpty() ? null : Pattern.compile(exclude), probe));
  addContainerLifecycleEvent(event, null, beanManager);
}

代码示例来源:origin: weld/core

public void afterBeanDiscovery(@Observes AfterBeanDiscovery event, BeanManager beanManager) {
  BeanManagerImpl weldManager = BeanManagerProxy.unwrap(beanManager);
  String exclude = weldManager.getServices().get(WeldConfiguration.class).getStringProperty(ConfigurationKey.PROBE_EVENT_MONITOR_EXCLUDE_TYPE);
  event.addObserverMethod(new ProbeObserver(weldManager, exclude.isEmpty() ? null : Pattern.compile(exclude), probe));
  addContainerLifecycleEvent(event, null, beanManager);
}

代码示例来源:origin: org.jboss.weld.probe/weld-probe-core

public void afterBeanDiscovery(@Observes AfterBeanDiscovery event, BeanManager beanManager) {
  BeanManagerImpl weldManager = BeanManagerProxy.unwrap(beanManager);
  String exclude = weldManager.getServices().get(WeldConfiguration.class).getStringProperty(ConfigurationKey.PROBE_EVENT_MONITOR_EXCLUDE_TYPE);
  event.addObserverMethod(new ProbeObserver(weldManager, exclude.isEmpty() ? null : Pattern.compile(exclude), probe));
  addContainerLifecycleEvent(event, null, beanManager);
}

代码示例来源:origin: com.tomitribe.tribestream/tribestream-container

void addBeans(@Observes final AfterBeanDiscovery abd) {
  for (final Bean<?> bean : beans) {
    abd.addBean(bean);
  }
  if (mergeContainer(abd)) {
    abd.addObserverMethod(new ChildWebAppBusPropagaterObserverBean(SystemInstance.get().getComponent(Container.class)));
  }
}

代码示例来源:origin: org.jboss.cdi.tck/cdi-tck-impl

void observesABD(@Observes AfterBeanDiscovery abd) throws NoSuchMethodException {
  abd.<Fruit>addObserverMethod().read(fruitObserverMethod).beanClass(FruitObserver.class).observedType(Banana.class)
      .addQualifiers(Ripe.RipeLiteral.INSTANCE, Any.Literal.INSTANCE)
      .notifyWith((b) -> {
  abd.addObserverMethod().read(melonMethod).observedType(Melon.class).notifyWith(m -> {
    newMelonObserverNotified.set(true);
  });
  abd.addObserverMethod().read(peachObserver).beanClass(FruitObserver.class).observedType(Peach.class).notifyWith((a) -> {
    newPeachObserverNotified.set(true);
  });
  abd.addObserverMethod(new ObserverMethod<Cherry>() {
  abd.addObserverMethod().observedType(Papaya.class).reception(Reception.ALWAYS).notifyWith(eventContext -> newPapayaObserverNotified.set(true));

代码示例来源:origin: org.jboss.errai/errai-weld-integration

@SuppressWarnings("rawtypes")
public void afterBeanDiscovery(@Observes final AfterBeanDiscovery abd, final BeanManager bm) {
 final ErraiService service = ErraiServiceSingleton.getService();
 final MessageBus bus = service.getBus();
 final EventRoutingTable eventRoutingTable = new EventRoutingTable();
 if (bus.isSubscribed(CDI.SERVER_DISPATCHER_SUBJECT)) {
  return;
 }
 final byte[] randBytes = new byte[32];
 final Random random = new Random(System.currentTimeMillis());
 random.nextBytes(randBytes);
 abd.addBean(new ErraiServiceBean(bm, SecureHashUtil.hashToHexString(randBytes)));
 for (final MessageSender ms : messageSenders) {
  abd.addBean(new SenderBean(ms.getSenderType(), ms.getQualifiers(), bus));
 }
 // Errai bus injection
 abd.addBean(new MessageBusBean(bus));
 // Support to inject the request dispatcher.
 abd.addBean(new RequestDispatcherMetaData(bm, service.getDispatcher()));
 // Register observers
 abd.addObserverMethod(new ShutdownEventObserver(managedTypes, bus));
 // subscribe service and rpc endpoints
 subscribeServices(bm, bus);
 // initialize the CDI event bridge to the client
 final EventDispatcher eventDispatcher =
     new EventDispatcher(bm, eventRoutingTable, bus, observableEvents, eventQualifiers);
 AnyEventObserver.init(eventDispatcher);
 // subscribe event dispatcher
 bus.subscribe(CDI.SERVER_DISPATCHER_SUBJECT, eventDispatcher);
}

相关文章