本文整理了Java中org.springframework.context.ApplicationEventPublisher
类的一些代码示例,展示了ApplicationEventPublisher
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ApplicationEventPublisher
类的具体详情如下:
包路径:org.springframework.context.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);
}
}
内容来源于网络,如有侵权,请联系作者删除!