+ if (aRequest.getParameter("producer")!=null) {
+ String producerParam = aRequest.getParameter("producer");
+ String verbParam = aRequest.getParameter("verb");
+
+ try {
+ MirGlobal.getProducerEngine().addJob(producerParam, verbParam);
+ out.println("job added");
+ }
+ catch (Throwable t) {
+ out.println("Can't add job: " + t.getMessage());
+ }
+ }
+ }
+ catch (IOException e) {
+ throw new ServletModuleFailure(e);
+ }
+ }
+
+ /**
+ * Servlet action to propduce a preconfigured combination of producers
+ * (e.g. "generate all new")
+ */
+ public void producerecipe(HttpServletRequest aRequest, HttpServletResponse aResponse) {
+ try {
+ String recipe = aRequest.getParameter("recipe");
+ MirGlobal.localizer().producers().produceRecipe(recipe);
+
+ ServletHelper.generateInfoMessage(aRequest, aResponse,
+ new Locale[] { getLocale(aRequest), getFallbackLocale(aRequest)},
+ "bundles/admin", "etc/bundles/adminlocal", "recipeAddedToQueue", recipe, "");
+ }
+ catch (Throwable t) {
+ throw new ServletModuleFailure(t);
+ }
+ }
+
+ /**
+ * Servlet action to enqueue a producer job
+ */
+ public void enqueue(HttpServletRequest aRequest, HttpServletResponse aResponse) {
+ try {
+ if (aRequest.getParameter("producer")!=null) {
+ String producerParam = aRequest.getParameter("producer");
+ String verbParam = aRequest.getParameter("verb");
+
+ MirGlobal.getProducerEngine().addJob(producerParam, verbParam);
+
+ ServletHelper.redirect(aResponse, "Producer", "showProducerQueueStatus");
+ }
+ }
+ catch (Throwable t) {
+ throw new ServletModuleFailure(t);
+ }
+ }
+
+ public void cancel(HttpServletRequest aRequest, HttpServletResponse aResponse) {
+ try {
+ HTTPRequestParser requestParser = new HTTPRequestParser(aRequest);
+
+ if (requestParser.getParameter("cancelall") != null) {
+ MirGlobal.getProducerEngine().cancelAllJobs();
+ }
+ else {
+ List jobs = new ArrayList(requestParser.getParameterList("jobid"));
+
+ MirGlobal.getProducerEngine().cancelJobs(jobs);
+ }
+ ServletHelper.redirect(aResponse, "Producer", "showProducerQueueStatus");
+ }
+ catch (Throwable t) {
+ throw new ServletModuleFailure(t);
+ }
+ }