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

ObservationManager.setUserData介绍

[英]Sets the user data information that will be returned by Event#getUserData.
[中]设置事件#getUserData将返回的用户数据信息。

代码示例

代码示例来源：origin: org.onehippo.cms7/hippo-repository-engine

public void setUserData(String userData) throws RepositoryException {
  upstream.setUserData(userData);
}

代码示例来源：origin: apache/jackrabbit

public void call() throws RepositoryException {
    obsMgr.setUserData(data);
    c.call();
  }
}, eventTypes);

代码示例来源：origin: org.apache.sling/org.apache.sling.distribution.core

/**
   * set {@link #DO_NOT_DISTRIBUTE} on the given {@link Session}'s {@link javax.jcr.observation.ObservationManager#setUserData(String)}
   *
   * @param session a {@link javax.jcr.Session}
   * @throws RepositoryException if retrieving the {@link javax.jcr.observation.ObservationManager} fails
   */
  public static void setDoNotDistribute(@NotNull Session session) throws RepositoryException {
    session.getWorkspace().getObservationManager().setUserData(DistributionJcrUtils.DO_NOT_DISTRIBUTE);
  }
}

代码示例来源：origin: apache/jackrabbit

public void setUserData(String userData) throws RepositoryException {
    session.getWorkspace().getObservationManager().setUserData(userData);
  }
}

代码示例来源：origin: org.apache.jackrabbit/jackrabbit-spi2jcr

public void setUserData(String userData) throws RepositoryException {
    session.getWorkspace().getObservationManager().setUserData(userData);
  }
}

代码示例来源：origin: Adobe-Consulting-Services/acs-aem-commons

protected void disableWorkflowProcessing(ResourceResolver rr) throws RepositoryException {
  if (inhibitWorkflow) {
    rr.adaptTo(Session.class).getWorkspace().getObservationManager().setUserData(CHANGED_BY_WORKFLOW);
  }
}

代码示例来源：origin: org.onehippo.cms7/hippo-repository-engine

public ConfigurationServiceImpl start(final Session configurationServiceSession, final StartRepositoryServicesTask startRepositoryServicesTask)
    throws RepositoryException {
  session = configurationServiceSession;
  // set event userData to identify events coming from this HCM session
  log.debug("ConfigurationService: Setting ObservationManager userData to {} to skip change events from this session for auto-export", Constants.HCM_ROOT);
  session.getWorkspace().getObservationManager().setUserData(Constants.HCM_ROOT);
  log.info("ConfigurationService: start");
  try {
    init(startRepositoryServicesTask);
    log.info("ConfigurationService: started");
  } catch (RepositoryException e) {
    log.error("Failed to start the ConfigurationService", e);
    stop();
    throw e;
  }
  return this;
}

代码示例来源：origin: org.onehippo.cms7/hippo-repository-engine

public void logNodeTypeRegistryLastModifiedEvent(final String userData) {
  try {
    final Node autoExportConfigNode = monitorSession.getNode(autoExportConfig.getConfigPath());
    monitorSession.refresh(false);
    ObservationManager observationManager = monitorSession.getWorkspace().getObservationManager();
    observationManager.setUserData(userData);
    try {
      if (autoExportConfigNode.hasProperty(AutoExportConstants.CONFIG_NTR_LAST_MODIFIED_PROPERTY_NAME)) {
        autoExportConfigNode.getProperty(AutoExportConstants.CONFIG_NTR_LAST_MODIFIED_PROPERTY_NAME).remove();
      }
      autoExportConfigNode.setProperty(AutoExportConstants.CONFIG_NTR_LAST_MODIFIED_PROPERTY_NAME, System.currentTimeMillis());
      monitorSession.save();
      AutoExportServiceImpl.log.debug("journal logging changed nodetype prefix(es): [{}]",userData);
    } finally {
      observationManager.setUserData(null);
    }
  } catch (RepositoryException e) {
    AutoExportServiceImpl.log.error("Failed to generate journal event for NodeTypeRegistry change.", e);
  }
}

代码示例来源：origin: com.adobe.acs/acs-aem-commons-bundle

@Override
  public void accept(ResourceResolver r, String path) throws Exception {
    r.adaptTo(Session.class).getWorkspace().getObservationManager().setUserData("changedByWorkflowProcess");
    nameThread("synWf-" + path);
    workflowRunner.execute(r,
        path,
        model,
        false,
        false);
  }
};

代码示例来源：origin: apache/jackrabbit

session.getWorkspace().getObservationManager().setUserData(data);
} catch (UnsupportedRepositoryOperationException ignore) {

代码示例来源：origin: org.fcrepo/fcrepo-kernel-modeshape

@Override
public void commit() {
  try {
    if (jcrSession.isLive()) {
      final ObservationManager obs = jcrSession.getWorkspace().getObservationManager();
      final ObjectNode json = mapper.createObjectNode();
      sessionData.forEach(json::put);
      obs.setUserData(mapper.writeValueAsString(json));
      jcrSession.save();
    }
  } catch (final javax.jcr.AccessDeniedException ex) {
    throw new AccessDeniedException(ex);
  } catch (final RepositoryException | JsonProcessingException ex) {
    throw new RepositoryRuntimeException(ex);
  }
}

代码示例来源：origin: Adobe-Consulting-Services/acs-aem-commons

/**
 * Run nodes through synthetic workflow
 *
 * @param model Synthetic workflow model
 */
public static final CheckedBiConsumer<ResourceResolver, String> startSyntheticWorkflows(final SyntheticWorkflowModel model, SyntheticWorkflowRunner workflowRunner) {
  return (ResourceResolver r, String path) -> {
    r.adaptTo(Session.class).getWorkspace().getObservationManager().setUserData("changedByWorkflowProcess");
    nameThread("synWf-" + path);
    workflowRunner.execute(r,
        path,
        model,
        false,
        false);
  };
}

代码示例来源：origin: Adobe-Consulting-Services/acs-aem-commons

@Override
public void move(ReplicatorQueue replicatorQueue, ResourceResolver rr) throws IllegalAccessException, MovingException {
   Session session = rr.adaptTo(Session.class);
  // Inhibits some workflows
  try {
    session.getWorkspace().getObservationManager().setUserData("changedByWorkflowProcess");
    session.move(getSourcePath(), getDestinationPath());
    session.save();
    updateReferences(replicatorQueue, rr);
  } catch (RepositoryException e) {
    throw new MovingException(getSourcePath(), e);
  }
}

代码示例来源：origin: apache/jackrabbit

public void testUserData() throws RepositoryException {
  testRootNode.addNode(nodeName1);
  String data = createRandomString(5);
  obsMgr.setUserData(data);
  journal = obsMgr.getEventJournal();
  skipToNow();
  superuser.save();
  assertTrue("no more events", journal.hasNext());
  assertEquals("Wrong user data", data, journal.nextEvent().getUserData());
}

代码示例来源：origin: Adobe-Consulting-Services/acs-aem-commons

@Override
public void run() {
  try (ResourceResolver resourceResolver = resourceResolverFactory.getServiceResourceResolver(AUTH_INFO)){
    // Access data passed into the Job from the Event
    Resource resource = resourceResolver.getResource(path);
    AssetManager assetManager = resourceResolver.adaptTo(AssetManager.class);
    if (resource != null) {
      ValueMap taskProperties = resource.getValueMap();
      String contentPath = taskProperties.get(PN_CONTENT_PATH, String.class);
      if (StringUtils.startsWith(contentPath, PATH_CONTENT_DAM)) {
        try (CloseableQuery query = findAssets(resourceResolver, contentPath)) {
          log.debug("Found [ {} ] assets under [ {} ] that were reviewed and require processing.",
              query.getResult().getHits().size(),
              contentPath);
          final Iterator<Resource> assets = query.getResult().getResources();
          resourceResolver.adaptTo(Session.class).getWorkspace().getObservationManager().setUserData(USER_EVENT_TYPE);
          while (assets.hasNext()) {
            final Asset asset = assetManager.getAsset(assets.next().getPath());
            moveAsset(resourceResolver, assetManager, asset, taskProperties);
          }
        }
      }
    }
  } catch (Exception e) {
    log.error("Could not process Review Task Mover", e);
  }
}

代码示例来源：origin: Adobe-Consulting-Services/acs-aem-tools

request.getResourceResolver().adaptTo(Session.class).getWorkspace().getObservationManager().setUserData("acs-aem-tools.test-page-generator");

代码示例来源：origin: Adobe-Consulting-Services/acs-aem-tools

@Override
protected void doPost(SlingHttpServletRequest request, SlingHttpServletResponse response)
    throws ServletException, IOException {
  // Clear any previously compiled fiddle scripts as they have a tendency to execute on first executions
  this.clearCompiledFiddle(request.getResourceResolver());
  final Resource resource = getResource(request);
  final String data = request.getParameter("scriptdata");
  final String ext = request.getParameter("scriptext");
  InMemoryScript script = InMemoryScript.set(ext, data);
  // doing this as a synchronous event so we ensure that
  // the JSP has been invalidated
  fiddleRefresher.refresh(script.getPath());
  final RequestDispatcherOptions options = new RequestDispatcherOptions();
  options.setForceResourceType(Constants.PSEDUO_COMPONENT_PATH);
  options.setReplaceSelectors("");
  // Suppress ACS AEM Commons - Component Error Handler from capturing errors
  request.setAttribute("com.adobe.acs.commons.wcm.component-error-handler.suppress", true);
  try {
    request.getResourceResolver().adaptTo(Session.class).getWorkspace().getObservationManager().setUserData("acs-aem-tools.aem-fiddle");
  } catch (RepositoryException e) {
    log.warn("Unable to set [ user-event-data = acs-aem-tools.aem-fiddle ] for fiddle execution.", e);
  }
  RequestDispatcher dispatcher = request.getRequestDispatcher(resource, options);
  GetRequest getRequest = new GetRequest(request);
  dispatcher.forward(getRequest, response);
}

代码示例来源：origin: ModeShape/modeshape

@FixFor( "MODE-1370" )
@Test
public void shouldReceiveUserDataWithEventWhenObservationSessionIsSameThatMadeChange() throws Exception {
  // register listener
  SimpleListener listener = addListener(1, Event.NODE_ADDED, null, false, null, null, false);
  // add node
  Node addedNode = getRoot().addNode("node1", UNSTRUCTURED);
  // Add user-data to the observation manager ...
  String userData = "my user data";
  getRoot().getSession().getWorkspace().getObservationManager().setUserData(userData);
  save();
  // event handling
  listener.waitForEvents();
  removeListener(listener);
  // tests
  checkResults(listener);
  assertTrue("Path for added node is wrong: actual=" + listener.getEvents().get(0).getPath() + ", expected="
        + addedNode.getPath(),
        containsPath(listener, addedNode.getPath()));
  // Now check the userdata in the events ...
  for (Event event : listener.events) {
    String eventUserData = event.getUserData();
    assertThat(eventUserData, is(userData));
  }
  // Now check the userdata ...
  assertThat(listener.userData.size(), is(not(0)));
  for (String receivedUserData : listener.userData) {
    assertThat(receivedUserData, is(userData));
  }
}

代码示例来源：origin: ModeShape/modeshape

om.setUserData(userData);

代码示例来源：origin: Adobe-Consulting-Services/acs-aem-commons

@Override
public void move(ReplicatorQueue replicatorQueue, ResourceResolver rr) throws MovingException {
  try {
    Session session = rr.adaptTo(Session.class);
    session.getWorkspace().getObservationManager().setUserData("changedByWorkflowProcess");
    Resource source = rr.getResource(getSourcePath());
    createMissingTargetFolders(rr, source);
    String sourceJcrContent = getSourcePath() + "/" + JcrConstants.JCR_CONTENT;
    if (resourceExists(rr, sourceJcrContent)) {
      Actions.getCurrentActionManager().deferredWithResolver(Actions.retry(5, 50, (rrr) -> {
        if (!resourceExists(rrr, getDestinationPath() + "/" + JcrConstants.JCR_CONTENT)) {
          waitUntilResourceFound(rrr, getDestinationPath());
          rrr.copy(sourceJcrContent, getDestinationPath());
          rrr.commit();
          rrr.refresh();
        }
      }));
    }
    replicatorQueue.replicate(session, ReplicationActionType.DEACTIVATE, getSourcePath());
  } catch (RepositoryException | ReplicationException | PersistenceException e) {
    throw new MovingException(getSourcePath(), e);
  }
}