in src/main/java/org/apache/sling/event/impl/jobs/console/WebConsolePlugin.java [110:159]
protected void doPost(final HttpServletRequest req, final HttpServletResponse resp)
throws ServletException, IOException {
String msg = null;
final String cmd = req.getParameter("action");
if ( "suspend".equals(cmd) ) {
final Queue q = this.getQueue(req);
if ( q != null ) {
q.suspend();
} else {
msg = this.getQueueErrorMessage(req, "suspend");
}
} else if ( "resume".equals(cmd) ) {
final Queue q = this.getQueue(req);
if ( q != null ) {
q.resume();
} else {
msg = this.getQueueErrorMessage(req, "resume");
}
} else if ( "reset".equals(cmd) ) {
if ( req.getParameter(PAR_QUEUE) == null || req.getParameter(PAR_QUEUE).length() == 0 ) {
this.jobManager.getStatistics().reset();
} else {
final Queue q = this.getQueue(req);
if ( q != null ) {
q.getStatistics().reset();
} else {
msg = this.getQueueErrorMessage(req, "reset");
}
}
} else if ( "test".equals(cmd) ) {
this.startTestJob();
} else if ( "dropall".equals(cmd) ) {
final Queue q = this.getQueue(req);
if ( q != null ) {
q.removeAll();
} else {
msg = this.getQueueErrorMessage(req, "drop all");
}
} else {
msg = "Unknown command";
}
final String path = req.getContextPath() + req.getServletPath() + req.getPathInfo();
final String redirectTo;
if ( msg == null ) {
redirectTo = path;
} else {
redirectTo = path + "?message=" + URLEncoder.encode(msg, "UTF-8");
}
resp.sendRedirect(resp.encodeRedirectURL(redirectTo));
}