org.springframework.context.ApplicationEventPublisher类的使用及代码示例

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

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

ApplicationEventPublisher介绍

[英]Interface that encapsulates event publication functionality. Serves as super-interface for ApplicationContext.
[中]封装事件发布功能的接口。用作ApplicationContext的超级接口。

代码示例

代码示例来源:origin: spring-projects/spring-framework

/**
 * Notify all <strong>matching</strong> listeners registered with this
 * application of an application event. Events may be framework events
 * (such as RequestHandledEvent) or application-specific events.
 * @param event the event to publish
 * @see org.springframework.web.context.support.RequestHandledEvent
 */
default void publishEvent(ApplicationEvent event) {
  publishEvent((Object) event);
}

代码示例来源:origin: org.springframework/spring-context

/**
 * Notify all <strong>matching</strong> listeners registered with this
 * application of an application event. Events may be framework events
 * (such as RequestHandledEvent) or application-specific events.
 * @param event the event to publish
 * @see org.springframework.web.context.support.RequestHandledEvent
 */
default void publishEvent(ApplicationEvent event) {
  publishEvent((Object) event);
}

代码示例来源:origin: hs-web/hsweb-framework

protected void publishEvent(ApplicationEvent event) {
  if (null != eventPublisher) {
    eventPublisher.publishEvent(event);
  }
}

代码示例来源:origin: spring-projects/spring-framework

private void publishEvent(ApplicationEventPublisher publisher, ApplicationEvent event) {
  try {
    publisher.publishEvent(event);
  }
  catch (Throwable ex) {
    if (logger.isErrorEnabled()) {
      logger.error("Error publishing " + event, ex);
    }
  }
}

代码示例来源:origin: spring-projects/spring-framework

protected void publishBrokerAvailableEvent() {
  boolean shouldPublish = this.brokerAvailable.compareAndSet(false, true);
  if (this.eventPublisher != null && shouldPublish) {
    if (logger.isInfoEnabled()) {
      logger.info(this.availableEvent);
    }
    this.eventPublisher.publishEvent(this.availableEvent);
  }
}

代码示例来源:origin: spring-projects/spring-framework

protected void publishBrokerUnavailableEvent() {
  boolean shouldPublish = this.brokerAvailable.compareAndSet(true, false);
  if (this.eventPublisher != null && shouldPublish) {
    if (logger.isInfoEnabled()) {
      logger.info(this.notAvailableEvent);
    }
    this.eventPublisher.publishEvent(this.notAvailableEvent);
  }
}

代码示例来源:origin: spring-projects/spring-framework

@Override
public Object invoke(MethodInvocation invocation) throws Throwable {
  Object retVal = invocation.proceed();
  Assert.state(this.applicationEventClassConstructor != null, "No ApplicationEvent class set");
  ApplicationEvent event = (ApplicationEvent)
      this.applicationEventClassConstructor.newInstance(invocation.getThis());
  Assert.state(this.applicationEventPublisher != null, "No ApplicationEventPublisher available");
  this.applicationEventPublisher.publishEvent(event);
  return retVal;
}

代码示例来源:origin: redisson/redisson

private void publishEvent(ApplicationEvent event) {
  try {
    eventPublisher.publishEvent(event);
  } catch (Exception e) {
    log.error(e.getMessage(), e);
  }
}

代码示例来源:origin: redisson/redisson

private void publishEvent(ApplicationEvent event) {
  try {
    eventPublisher.publishEvent(event);
  } catch (Exception e) {
    log.error(e.getMessage(), e);
  }
}

代码示例来源:origin: apache/incubator-dubbo

/**
 * @since 2.6.5
 */
private void publishExportEvent() {
  ServiceBeanExportedEvent exportEvent = new ServiceBeanExportedEvent(this);
  applicationEventPublisher.publishEvent(exportEvent);
}

代码示例来源:origin: apache/incubator-dubbo

/**
 * @since 2.6.5
 */
private void publishExportEvent() {
  ServiceBeanExportedEvent exportEvent = new ServiceBeanExportedEvent(this);
  applicationEventPublisher.publishEvent(exportEvent);
}

代码示例来源:origin: org.springframework/spring-context

@Override
public Object invoke(MethodInvocation invocation) throws Throwable {
  Object retVal = invocation.proceed();
  Assert.state(this.applicationEventClassConstructor != null, "No ApplicationEvent class set");
  ApplicationEvent event = (ApplicationEvent)
      this.applicationEventClassConstructor.newInstance(invocation.getThis());
  Assert.state(this.applicationEventPublisher != null, "No ApplicationEventPublisher available");
  this.applicationEventPublisher.publishEvent(event);
  return retVal;
}

代码示例来源:origin: spring-projects/spring-framework

@PostConstruct
  public void init() {
    this.publisher.publishEvent("earlyEvent");
  }
}

代码示例来源:origin: ctripcorp/apollo

@PreAuthorize(value = "@permissionValidator.isSuperAdmin()")
@DeleteMapping("/{appId:.+}")
public void deleteApp(@PathVariable String appId) {
 App app = appService.deleteAppInLocal(appId);
 publisher.publishEvent(new AppDeletionEvent(app));
}

代码示例来源:origin: ctripcorp/apollo

@PreAuthorize(value = "@permissionValidator.isSuperAdmin()")
@DeleteMapping("/apps/{appId}/appnamespaces/{namespaceName:.+}")
public ResponseEntity<Void> deleteAppNamespace(@PathVariable String appId, @PathVariable String namespaceName) {
 AppNamespace appNamespace = appNamespaceService.deleteAppNamespace(appId, namespaceName);
 publisher.publishEvent(new AppNamespaceDeletionEvent(appNamespace));
 return ResponseEntity.ok().build();
}

代码示例来源:origin: ctripcorp/apollo

@PreAuthorize(value = "@permissionValidator.isAppAdmin(#appId)")
@PutMapping("/{appId:.+}")
public void update(@PathVariable String appId, @Valid @RequestBody AppModel appModel) {
 if (!Objects.equals(appId, appModel.getAppId())) {
  throw new BadRequestException("The App Id of path variable and request body is different");
 }
 App app = transformToApp(appModel);
 App updatedApp = appService.updateAppInLocal(app);
 publisher.publishEvent(new AppInfoChangedEvent(updatedApp));
}

代码示例来源:origin: hs-web/hsweb-framework

@Override
  public void run(String... args) throws Exception {
    if (autoParse) {
      List<AuthorizeDefinition> definitions = defaultParser.getAllParsed()
          .stream().filter(def -> !def.isEmpty()).collect(Collectors.toList());

      log.info("publish AuthorizeDefinitionInitializedEvent,definition size:{}", definitions.size());
      eventPublisher.publishEvent(new AuthorizeDefinitionInitializedEvent(definitions));

      defaultParser.destroy();
    }
  }
}

代码示例来源:origin: hs-web/hsweb-framework

@Override
public int updateByPk(String id, PermissionEntity entity) {
  int len = super.updateByPk(id, entity);
  eventPublisher.publishEvent(new ClearUserAuthorizationCacheEvent(null, true));
  return len;
}

代码示例来源:origin: hs-web/hsweb-framework

@Override
  public PermissionEntity deleteByPk(String id) {
    PermissionEntity old = super.deleteByPk(id);
    eventPublisher.publishEvent(new ClearUserAuthorizationCacheEvent(null, true));
    return old;
  }
}

代码示例来源:origin: hs-web/hsweb-framework

@Override
  public DictionaryEntity deleteByPk(String id) {
    eventPublisher.publishEvent(new ClearDictionaryCacheEvent(id));
    return super.deleteByPk(id);
  }
}

相关文章

微信公众号

最新文章

更多

ApplicationEventPublisher类方法