org.nuxeo.ecm.core.event.Event类的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(9.4k)|赞(0)|评价(0)|浏览(130)

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

Event介绍

[英]A lightweight object used by core components to notify interested components about events in core.

These events should be used by all core components not only by the repository.

There are 2 post commit control flags:

  • INLINE - if true the event will not be recorded as part of the post commit event bundle. Defaults to false.
  • COMMIT - the event will simulate a commit so that the post commit event bundle will be fired. TYhe COMMIT flag is ignored while in a transaction.
    More flags may be added in the future.
    [中]核心组件使用的轻量级对象,用于向感兴趣的组件通知核心中的事件。
    所有核心组件都应该使用这些事件,而不仅仅是存储库。
    有2个提交后控制标志:
    *内联-如果为true,则事件不会记录为提交后事件束的一部分。默认为false。
    *提交-事件将模拟提交,以便触发提交后事件束。t在事务中忽略提交标志。
    将来可能会添加更多标志。

代码示例

代码示例来源:origin: org.nuxeo.ecm.platform/nuxeo-user-profile

protected boolean isBeforeUpdate(Event event) {
  return BEFORE_DOC_UPDATE.equals(event.getName()) && (event.getContext() instanceof DocumentEventContext);
}

代码示例来源:origin: org.nuxeo.elasticsearch/nuxeo-elasticsearch-core

@Override
public void handleEvent(Event event) {
  String eventId = event.getName();
  if (!isEnlisted.get()) {
    if (event.isCommitEvent()) {
      // manual flush on save if TxManager is not hooked
      afterCompletion(Status.STATUS_COMMITTED);
      return;
    }
    // try to enlist our listener
    isEnlisted.set(registerSynchronization(this));
  }
  if (!(event.getContext() instanceof DocumentEventContext)) {
    // don't process Events that are not tied to Documents
    return;
  }
  DocumentEventContext docCtx = (DocumentEventContext) event.getContext();
  stackCommand(docCtx, eventId);
}

代码示例来源:origin: org.nuxeo.ecm.core/nuxeo-core-event

@Override
public String getName() {
  if (events.isEmpty()) {
    return null;
  }
  return events.get(0).getContext().getRepositoryName();
}

代码示例来源:origin: opentoutatice-ecm.platform/opentoutatice-ecm-platform-core

/**
 * Accepts documentCreatedByCopy event.
 */
@Override
public boolean acceptEvent(Event event) {
  return DocumentEventTypes.DOCUMENT_CREATED_BY_COPY.equals(event.getName());
}

代码示例来源:origin: org.nuxeo.ecm.core/nuxeo-core-event

public static ShallowEvent create(Event event) {
  EventContext ctx = event.getContext();
  List<Object> newArgs = new ArrayList<Object>();
  for (Object arg : ctx.getArguments()) {
  return new ShallowEvent(event.getName(), newCtx, event.getFlags(), event.getTime());

代码示例来源:origin: org.nuxeo.ecm.platform/nuxeo-platform-dublincore

EventContext ctx = event.getContext();
if (!(ctx instanceof DocumentEventContext)) {
  return;
Boolean block = (Boolean) event.getContext().getProperty(DISABLE_DUBLINCORE_LISTENER);
if (Boolean.TRUE.equals(block)) {
Date eventDate = new Date(event.getTime());
Calendar cEventDate = Calendar.getInstance();
cEventDate.setTime(eventDate);
String eventId = event.getName();
    CoreSession session = event.getContext().getCoreSession();
    UnrestrictedPropertySetter setter = new UnrestrictedPropertySetter(session, doc.getRef(), "dc:issued",
        cEventDate);
Boolean resetCreator = (Boolean) event.getContext().getProperty(CoreEventConstants.RESET_CREATOR);
boolean resetCreatorProperty = Framework.getService(ConfigurationService.class)
                    .isBooleanPropertyTrue(RESET_CREATOR_PROPERTY);
Boolean dirty = (Boolean) event.getContext().getProperty(CoreEventConstants.DOCUMENT_DIRTY);
if ((eventId.equals(BEFORE_DOC_UPDATE) && Boolean.TRUE.equals(dirty))
    || (eventId.equals(TRANSITION_EVENT) && !doc.isImmutable())) {

代码示例来源:origin: org.nuxeo.template.rendering/nuxeo-template-rendering-core

@Override
  public void handleEvent(Event event) {

    EventContext ctx = event.getContext();

    if (DocumentEventTypes.ABOUT_TO_REMOVE.equals(event.getName())) {
      if (ctx instanceof DocumentEventContext) {
        DocumentEventContext docCtx = (DocumentEventContext) ctx;
        DocumentModel targetDoc = docCtx.getSourceDocument();

        TemplateSourceDocument templateDoc = targetDoc.getAdapter(TemplateSourceDocument.class);
        if (templateDoc != null && !Framework.isTestModeSet()) {
          if (templateDoc.getTemplateBasedDocuments().size() > 0) {
            TransactionHelper.setTransactionRollbackOnly();
            event.cancel();
            docCtx.newEvent(DocumentEventTypes.DOCUMENT_REMOVAL_CANCELED);
            Framework.getService(EventProducer.class).fireEvent(event);
          }
        }
      }
    }
  }
}

代码示例来源:origin: org.osivia.demo/proto-cns-nuxeo-custom

EventContext ctx = event.getContext();
log.info("Application des metadonnées ["+event.getTime()+"]");
coreSession.saveDocuments(listToSave.toArray(t));
log.info("Fin de l'appliquation des metadonnées ["+event.getTime()+"]");
  log.info("Validation en masse ["+event.getTime()+"]");
  log.info("Fin de la validation en masse ["+event.getTime()+"]");

代码示例来源:origin: org.nuxeo.ecm.platform/nuxeo-platform-notification-core

eventInfo.put(NotificationConstants.NOTIFICATION_KEY, notification);
eventInfo.put(NotificationConstants.DOCUMENT_ID_KEY, doc.getId());
eventInfo.put(NotificationConstants.DATE_TIME_KEY, new Date(event.getTime()));
eventInfo.put(NotificationConstants.AUTHOR_KEY, author);
eventInfo.put(NotificationConstants.DOCUMENT_VERSION, doc.getVersionLabel());
if (!isDeleteEvent(event.getName())) {
  if (isNotificationCodec) {
    eventInfo.put(NotificationConstants.DOCUMENT_URL_KEY,

代码示例来源:origin: toutatice-services.carto-nat/toutatice-carto-nat-ecm

/**
 * @param event
 * @param document
 */
public void setCreationInfos(CoreSession session, Event event, DocumentModel document) {
  Date eventDate = new Date(event.getTime());
  Calendar cEventDate = Calendar.getInstance();
  cEventDate.setTime(eventDate);
  document.setPropertyValue("dc:created", cEventDate);
  document.setPropertyValue("dc:modified", cEventDate);
  String[] contributors = {session.getPrincipal().getName(), (String) document.getPropertyValue(ModelConstants.AUTHOR_PROP)};
  document.setPropertyValue("dc:contributors", contributors);
  session.saveDocument(document);
}

代码示例来源:origin: org.nuxeo.ecm.core/nuxeo-core-event

protected void recordEvent(Event event) {
  CompositeEventBundle b = threadBundles.get();
  b.push(event);
  if (TransactionHelper.isTransactionActive()) {
    if (!b.registeredSynchronization) {
      // register as synchronization
      try {
        TransactionHelper.lookupTransactionManager().getTransaction().registerSynchronization(this);
      } catch (NamingException | SystemException | RollbackException e) {
        throw new RuntimeException("Cannot register Synchronization", e);
      }
      b.registeredSynchronization = true;
    }
  } else if (event.isCommitEvent()) {
    handleTxCommited();
  }
}

代码示例来源:origin: acaren-nuxeo-base/acaren-nuxeo-base-core

@Override
public void handleEvent(EventBundle events) throws ClientException {
  for (Event event : events) {
    if (event.getContext() instanceof DocumentEventContext) {
      try {
        getDataInheritanceService().runAsync(event);
      } catch (Exception e) {
        log.error("Failed to request the data inheriatnce service, error: " + e.getMessage());
      }
    }
  }
}

代码示例来源:origin: org.nuxeo.ecm.platform/nuxeo-platform-imaging-core

@Override
  public boolean acceptEvent(Event event) {
    return UPDATE_PICTURE_VIEW_EVENT.equals(event.getName());
  }
}

代码示例来源:origin: org.nuxeo.ecm.core/nuxeo-core-event

reconnectedEvents = new ArrayList<Event>();
for (Event event : sourceEventBundle) {
  EventContext ctx = event.getContext();
  String repositoryName = ctx.getRepositoryName();
  CoreSession session;
  Event newEvt = new EventImpl(event.getName(), newCtx, event.getFlags(), event.getTime());
  reconnectedEvents.add(newEvt);

代码示例来源:origin: org.nuxeo.ecm.platform/nuxeo-platform-audit-core

@Override
public LogEntry buildEntryFromEvent(Event event) {
  EventContext ctx = event.getContext();
  String eventName = event.getName();
  Date eventDate = new Date(event.getTime());

代码示例来源:origin: opentoutatice-ecm.platform/opentoutatice-ecm-platform-core

/**
 * Changes DublinCore properties.
 * 
 * @param event
 * @param docCtx
 * @param service
 * @param srcDoc
 * @return updated document
 */
public static DocumentModel changeCreationProperties(Event event, DocumentEventContext docCtx, DocumentModel srcDoc) {
  Date eventDate = new Date(event.getTime());
  Calendar cEventDate = Calendar.getInstance();
  cEventDate.setTime(eventDate);
  DublinCoreStorageService service = getDublinCoreStorageService();
  service.addContributor(srcDoc, event);
  srcDoc.setPropertyValue("dc:created", cEventDate);
  srcDoc.setPropertyValue("dc:modified", cEventDate);
  // We have to set creator cause addContributor doesn't do it if
  // this field is not empty
  return setCreator(docCtx, srcDoc);
}

代码示例来源:origin: org.nuxeo.ecm.platform/nuxeo-platform-tag-core

@Override
  public boolean acceptEvent(Event event) {
    String name = event.getName();
    return DOCUMENT_PROXY_PUBLISHED.equals(name)
        || DOCUMENT_RESTORED.equals(name)
        || DOCUMENT_REMOVED.equals(name)
        || DOCUMENT_TRASHED.equals(name)
        || (LifeCycleConstants.TRANSITION_EVENT.equals(name) && LifeCycleConstants.DELETED_STATE.equals(event.getContext().getProperty(
        LifeCycleConstants.TRANSTION_EVENT_OPTION_TO)));
  }
}

代码示例来源:origin: acaren-nuxeo-base/acaren-nuxeo-base-maintenance

private void buildSQLQueryInitTTCTable(Event event) throws ClientException {
  if (event.getContext() instanceof DocumentEventContext) {
    List<String> list = listTTCCompliantDocs(event);
    String query = String.format("SELECT ttc_create_entry(h.id) FROM hierarchy h WHERE h.primarytype IN %s;", SQLformat(list));
    log.info("Requête pour initialiser la table 'toutatice':\n'" + query +"'");
  }
}

代码示例来源:origin: org.nuxeo.ecm.core/nuxeo-core-event

@Override
public void push(Event event) {
  events.add(event);
  String eventName = event.getName();
  if (eventName != null) {
    eventNames.add(eventName);
  }
}

代码示例来源:origin: acaren-nuxeo-base/acaren-nuxeo-base-core

@Override
public void run() throws ClientException {
  DocumentEventContext eventContext = (DocumentEventContext) this.event.getContext();
  String eventName = this.event.getName();
  DocumentModel document = eventContext.getSourceDocument();
  
  run(eventContext, document, eventName);
}

相关文章

微信公众号

最新文章

更多