import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
@SuppressWarnings("squid:S1149")
private void registerAsEventHandler() {
        final Hashtable filterProps = new Hashtable<String, String>();

        // Listen on Add and Remove under /etc/acs-commons/notifications

        filterProps.put(EventConstants.EVENT_TOPIC,
                new String[]{
                        SlingConstants.TOPIC_RESOURCE_ADDED,
                        SlingConstants.TOPIC_RESOURCE_REMOVED });

        filterProps.put(EventConstants.EVENT_FILTER, "(&"
                + "(" + SlingConstants.PROPERTY_PATH + "=" + SystemNotificationsImpl.PATH_NOTIFICATIONS + "/*)"
                + ")");

        this.eventHandlerRegistration =
                this.osgiComponentContext.getBundleContext().registerService(EventHandler.class.getName(), this,
                        filterProps);

        log.debug("Registered System Notifications as Event Handler");
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
private void registerWebResourceGroupListener(final String webResourceName,
		final String webResourcePath) throws RepositoryException {
	if (!webResourceServiceRegistration.containsKey(webResourceName)) {
		String[] topics = new String[] {
				SlingConstants.TOPIC_RESOURCE_ADDED,
				SlingConstants.TOPIC_RESOURCE_CHANGED,
				SlingConstants.TOPIC_RESOURCE_REMOVED };

		Dictionary<String, Object> props = new Hashtable<String, Object>();
		props.put(EventConstants.EVENT_TOPIC, topics);
		props.put(EventConstants.EVENT_FILTER, "(path=" + webResourcePath
				+ "/*)");

		this.webResourceServiceRegistration.put(webResourceName,
				bundleContext.registerService(EventHandler.class.getName(),
						new InventoryEventHandler(), props));

		log.info("Registered Inventory Event Handler for "
				+ webResourceName);
	}
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
private boolean ignoreInventoryEvent(
		org.osgi.service.event.Event event, Node resourceNode)
		throws RepositoryException {
	boolean skipSweep = false;
	
	String path = (String) event.getProperty("path");
	// We don't want to trigger a sweep if only the inventory was changed
	// Only if the inventory was deleted.
	if ((path.endsWith(WebResourceGroup.INVENTORY) && 
			!SlingConstants.TOPIC_RESOURCE_REMOVED.equals(event.getTopic()))
			|| path.endsWith(".css") || path.endsWith(".js")) {
		skipSweep = true;
	} else {
		if (resourceNode != null && !resourceNode.isNodeType(NodeType.NT_FILE)) {
			skipSweep = true;
		}
	}
	return skipSweep;
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
@Override
public synchronized JobResult process(Job job) {
	final String searchPath = job.getProperty(SlingConstants.PROPERTY_PATH).toString();
	return SlingHelper.resolveDefault(resolverFactory, new ResolveCallback<JobResult>() {
		@Override
		public JobResult resolve(ResourceResolver resolver) {
			return runReplicated(resolver, searchPath);
		}
	}, JobResult.FAILED);
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
private void processChange(ResourceChange change) {
	String path = change.getPath();
	if (isPublish() && (scriptAdded(change) || scriptChanged(change))) {
		Map<String, Object> eventProperties = ImmutableMap.<String, Object>builder()
				.put(SlingConstants.PROPERTY_PATH, path)
				.build();
		jobManager.addJob(JOB_NAME, eventProperties);
	}
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
@Override
public void activate() {
    SlingHttpServletRequest request = getRequest();
    SlingHttpServletResponse response = getResponse();
    ResourceResolver resolver = getResourceResolver();

    isAnonymous = "anonymous".equals(resolver.adaptTo(Session.class).getUserID());

    message = (String) request.getAttribute(SlingConstants.ERROR_MESSAGE);
    Integer scObject = (Integer) request.getAttribute(SlingConstants.ERROR_STATUS);

    code = (scObject != null) ? scObject.intValue() : response.SC_INTERNAL_SERVER_ERROR;

    if (message == null) {
        message = statusToString(code);
    }

    // Print stack trace only if the user is not anonymous
    if (!isAnonymous) {
        if (request.getAttribute(SlingConstants.ERROR_EXCEPTION) instanceof Throwable) {
            Throwable throwable = (Throwable) request.getAttribute(SlingConstants.ERROR_EXCEPTION);
            printStackTrace(throwable);
        }
    }

    response.setStatus(code);
    response.setContentType("text/html"); 
    response.setCharacterEncoding("utf-8");
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
@Override
public void handleEvent(final Event event) {
    boolean handleLocally = false;
    boolean handleWithLeader = !handleLocally;


    /**
     * Sling Event Properties - VERY handy
     *
     * This aren't guaranteed to have non-null values; so check before using.
     */

    // Resource path "undergoing" the event
    event.getProperty(SlingConstants.PROPERTY_PATH);

    // Resource type
    event.getProperty(SlingConstants.PROPERTY_RESOURCE_TYPE);

    // Resource super type
    event.getProperty(SlingConstants.PROPERTY_RESOURCE_SUPER_TYPE);

    // Properties names that were added/changes/removed
    event.getProperty(SlingConstants.PROPERTY_ADDED_ATTRIBUTES);
    event.getProperty(SlingConstants.PROPERTY_CHANGED_ATTRIBUTES);
    event.getProperty(SlingConstants.PROPERTY_REMOVED_ATTRIBUTES);

    // User id
    event.getProperty(SlingConstants.PROPERTY_USERID);

    // Accepts(..) should be a very fast check to see if a Job is needed.
    // Do NOT create Jobs is they arent needed as this will saturate the Sling Job queue with unneccessary work.
    if (accepts(event)) {
        // ONly create
        Map<String, Object> jobProperties = new HashMap<String, Object>();
        jobProperties.put("user", event.getProperty(SlingConstants.PROPERTY_USERID));
        jobManager.addJob("com/adobe/acs/samples/sample-job", jobProperties);
    }
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
@Override
public void handleEvent(Event event) {
    final String topic = event.getTopic();
    if (SlingConstants.TOPIC_RESOURCE_ADDED.equals(topic)) {
        metricService.meter("jcr.resource.added").mark();
    } else if (SlingConstants.TOPIC_RESOURCE_CHANGED.equals(topic)) {
        metricService.meter("jcr.resource.changed").mark();
    } else if (SlingConstants.TOPIC_RESOURCE_REMOVED.equals(topic)) {
        metricService.meter("jcr.resource.removed").mark();
    }
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
@Override
public void handleEvent(final Event event) {

    // Get the required information from the event.
    final String path = (String) event.getProperty(SlingConstants.PROPERTY_PATH);
    // Create the required payload.
    final Map<String, Object> payload = new HashMap<String, Object>();
    payload.put(CacheInvalidationJobConstants.PAYLOAD_KEY_DATA_CHANGE_PATH, path);
    // Start a job.
    jobManager.addJob(CacheInvalidationJobConstants.TOPIC_HTTP_CACHE_INVALIDATION_JOB, payload);

    log.debug("New invalidation job created with the payload path. - {}", path);
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
/**
 * Get Error Status Code from Request or Default (500) if no status code can be found.
 *
 * @param request
 * @return
 */
@Override
public int getStatusCode(SlingHttpServletRequest request) {
    Integer statusCode = (Integer) request.getAttribute(SlingConstants.ERROR_STATUS);

    if (statusCode != null) {
        return statusCode;
    } else {
        return ErrorPageHandlerService.DEFAULT_STATUS_CODE;
    }
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
/**
 * Returns the Exception Message (Stacktrace) from the Request.
 *
 * @param request
 * @return
 */
@Override
public String getException(SlingHttpServletRequest request) {
    StringWriter stringWriter = new StringWriter();
    if (request.getAttribute(SlingConstants.ERROR_EXCEPTION) instanceof Throwable) {
        Throwable throwable = (Throwable) request.getAttribute(SlingConstants.ERROR_EXCEPTION);

        if (throwable == null) {
            return "";
        }

        if (throwable instanceof ServletException) {
            ServletException se = (ServletException) throwable;
            while (se.getRootCause() != null) {
                throwable = se.getRootCause();
                if (throwable instanceof ServletException) {
                    se = (ServletException) throwable;
                } else {
                    break;
                }
            }
        }

        throwable.printStackTrace(new PrintWriter(stringWriter, true));
    }

    return stringWriter.toString();
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
@Override
public void handleEvent(final Event event) {
    final long start = System.currentTimeMillis();

    if (!this.isAuthor()) {
        log.warn("This event handler should ONLY run on AEM Author.");
        return;
    }

    /** The following code will ONLY execute on AEM Author **/

    final String path = (String) event.getProperty(SlingConstants.PROPERTY_PATH);
    if (StringUtils.endsWith(path, JcrConstants.JCR_CONTENT)) {
        // Ignore jcr:content nodes; Only handle events for cq:Page
        return;
    }

    if (this.hasNotifications()) {
        if (!this.isFilter.getAndSet(true)) {
            this.registerAsFilter();
        }
    } else {
        if (this.isFilter.getAndSet(false)) {
            this.unregisterFilter();
            log.debug("Unregistered System Notifications Sling Filter");
        }
    }

    if (System.currentTimeMillis() - start > 2500) {
        log.warn("Event handling for System notifications took [ {} ] ms. Event blacklisting occurs after 5000 ms.",
                System.currentTimeMillis() - start);
    }
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
private void registerWebResourceGroupFolderHandler() {
	String[] allSlingResourceTopics = {
			SlingConstants.TOPIC_RESOURCE_ADDED,
			SlingConstants.TOPIC_RESOURCE_REMOVED };
	Dictionary<String, Object> props = new Hashtable<String, Object>();
	props.put(EventConstants.EVENT_TOPIC, allSlingResourceTopics);
	bundleContext.registerService(EventHandler.class.getName(),
			new WebResourceGroupFolderHandler(), props);
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
public void handleEvent(final Event event) {
    logger.info("Felix EventHander: {} at: {}",
        event.getTopic(), event.getProperty(SlingConstants.PROPERTY_PATH));
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
public void handleEvent(final Event event) {
    logger.info("OSGi EventHandler: {} at: {}",
            event.getTopic(), event.getProperty(SlingConstants.PROPERTY_PATH));
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
public void  handleEvent(final Event event) {
    logger.debug("Resource event: {} at: {}", event.getTopic(), event.getProperty(SlingConstants.PROPERTY_PATH));
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
public void handleEvent(final Event event) {
    logger.debug("Resource event: {} at: {}", event.getTopic(), event.getProperty(SlingConstants.PROPERTY_PATH));
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
@Override
public void handleEvent(Event event) {
    String path = (String) event.getProperty(SlingConstants.PROPERTY_PATH);
    md5Cache.invalidate(new VersionedClientLibraryMd5CacheKey(path, LibraryType.JS));
    md5Cache.invalidate(new VersionedClientLibraryMd5CacheKey(path, LibraryType.CSS));
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
private void sendEvent() {
    notifications.handleEvent(new Event("dummy", Collections.singletonMap(SlingConstants.PROPERTY_PATH, "/etc/acs-commons/notifications")));
}
 

import org.apache.sling.api.SlingConstants; //导入依赖的package包/类
@Override
public void handleEvent(org.osgi.service.event.Event event) {

	try {

		String path = (String) event.getProperty("path");
		String eventTopic = event.getTopic();
		Dictionary<String, Object> properties = new Hashtable<String, Object>();
		properties.put("path", path);
		org.osgi.service.event.Event osgiEvent = null;
		if (eventTopic.equals(SlingConstants.TOPIC_RESOURCE_ADDED)) {

			Node addedNode = adminSession.getNode(path);
			if (addedNode.isNodeType(WebResourceGroup.NODE_TYPE)) {
				log.info("Web Resource Add/Move for path: " + path);
				osgiEvent = new org.osgi.service.event.Event(
						TOPIC_WEB_RESOURCE_CREATED, properties);
			}

		} else {
			for (Entry<String, String> webResourceNamePathEntry : webResourceNamePathMap
					.entrySet()) {
				if (webResourceNamePathEntry.getValue().equals(path)) {
					log.info("Web Resource Delete for path: " + path);
					properties.put(WebResourceGroup.NAME,
							webResourceNamePathEntry.getKey());
					osgiEvent = new org.osgi.service.event.Event(
							TOPIC_WEB_RESOURCE_DELETED, properties);
				}
			}

		}

		if (osgiEvent != null) {
			eventAdmin.postEvent(osgiEvent);
		}

	} catch (RepositoryException e) {
		log.error("Error on JCR event listener", e);
	}

}