Example 7-1 HelloWorldImpl with Execute Method Implemented

public class HelloWorldImpl implements Executable, Cancellable
{
  public void execute(RequestExecutionContext ctx, RequestParameters params)
    throws ExecutionErrorException, ExecutionWarningException,
           ExecutionCancelledException, ExecutionPausedException
  {
      System.out.println("**** Sample Job Running, Request ID: " +
          ctx.getRequestId());
  }
 
  public void cancel()
  {
  }
}

Example 7-2 jazn-data.xml

<?xml version = '1.0' encoding = 'UTF-8' standalone = 'yes'?>
<jazn-data xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:noNamespaceSchemaLocation="http://xmlns.oracle.com/oracleas/schema/jazn-data.xsd">
  <jazn-realm default="jazn.com">
   <realm>
    <name>>Username / password is: EssUser / welcome1</name>
     <users>
      <user>
       <name>EssUser</name>
       <credentials>{903}LmqEdVs3zO0/QmP90tihXv4nRq5YqYSL</credentials>
      </user>
     </users>
    </realm>
   </jazn-realm>
   <policy-store>
    <applications>
     <application>
      <name>EssDemoApp</name>
      <app-roles>
       <app-role>
        <name>EssApplicationRole</name>                                      
        <class>oracle.security.jps.service.policystore.ApplicationRole</class>
        <members>
         <member>                                   
        <class>oracle.security.jps.internal.core.principals.JpsXmlUserImpl</class>
          <name>EssUser</name>
         </member>
        </members>
       </app-role>
      </app-roles>
     <jazn-policy>
      <grant>
       <grantee>
        <principals>
         <principal>                                    
          <class>oracle.security.jps.service.policystore.ApplicationRole</class>
          <name>EssApplicationRole</name>
         </principal>
        </principals>
       </grantee>
       <permissions>
        <permission>                            
                    <class>oracle.as.scheduler.security.MetadataPermission</class>                            
        <name>oracle.esshost.metadata.JobDefinition.HelloWorldJobDefinition</name>
         <actions>Read,Update,Delete,Execute</actions>
        </permission>
       </permissions>
      </grant>
     </jazn-policy>
    </application>
   </applications>
  </policy-store>
 <system-policy/>
</jazn-data> 

Example 7-3 adf-config.xml File for a EssDemoApp Application

<?xml version="1.0" encoding="UTF-8" ?>
<adf-config xmlns="http://xmlns.oracle.com/adf/config" xmlns:sec="http://xmlns.oracle.com/adf/security/config">
  <sec:adf-security-child xmlns="http://xmlns.oracle.com/adf/security/config">
    <CredentialStoreContext credentialStoreClass="oracle.adf.share.security.providers.jps.CSFCredentialStore"                         credentialStoreLocation="../../src/META-INF/jps-config.xml"/>
    <sec:JaasSecurityContext initialContextFactoryClass="oracle.adf.share.security.JAASInitialContextFactory"                            jaasProviderClass="oracle.adf.share.security.providers.jps.JpsSecurityContext"
    authorizationEnforce="false" authenticationRequire="true"/>
  </sec:adf-security-child>
  <adf-mds-config xmlns="http://xmlns.oracle.com/adf/mds/config">
    <mds-config version="11.1.1.000" xmlns="http://xmlns.oracle.com/mds/config">
      <persistence-config>
        <metadata-namespaces>
          <namespace path="/oracle/as/ess/core" metadata-store-usage="ess-core"/>
        </metadata-namespaces>
        <metadata-store-usages>
          <metadata-store-usage id="ess-core" deploy-target="false"                 default-cust-store="false">
            <metadata-store                class-name="oracle.mds.persistence.stores.db.DBMetadataStore">
              <property name="jndi-datasource" value="jdbc/mds-ESS_MDS_DS"/>
              <property name="repository-name" value="mds-ESS_MDS_DS"/>
              <property name="partition-name" value="essapp-internal-partition"/>
            </metadata-store>
          </metadata-store-usage>
        </metadata-store-usages>
      </persistence-config>
    </mds-config>
  </adf-mds-config>
</adf-config>

Example 7-4 HelloWorldJob Execute Method Code

StringBuilder sb = new StringBuilder(1000);
sb.append("\n==================================");
sb.append("\n= EssDemoApp request is now running");
long myRequestId = ctx.getRequestId();
sb.append("\n= Request Id = " + myRequestId);
sb.append("\n= Request Properties:");
for (String paramKey : params.getNames()) {
    Object paramValue = params.getValue(paramKey);
    sb.append("\n=\t(" + paramKey + ", " + paramValue + ")");
}
sb.append("\n=");
sb.append("\n==================================");
Logger logger = Logger.getLogger("oracle.apps.ess.howto");
logger.info(sb.toString());

Example 7-5 adf-config.xml File

<?xml version="1.0" encoding="UTF-8" ?>
<adf-config xmlns="http://xmlns.oracle.com/adf/config" xmlns:config="http://xmlns.oracle.com/bc4j/configuration">
  <adf-security-child xmlns="http://xmlns.oracle.com/adf/security/config">
    <JaasSecurityContext initialContextFactoryClass="oracle.adf.share.security.JAASInitialContextFactory"           jaasProviderClass="oracle.adf.share.security.providers.jps.JpsSecurityContext"
         authorizationEnforce="false" authenticationRequire="true"/>
  </adf-security-child>
  <adf-adfm-config xmlns="http://xmlns.oracle.com/adfm/config">
    <defaults changeEventPolicy="ppr" useBindVarsForViewCriteriaLiterals="true"            useBindValuesInFindByKey="true"/>
    <startup>
       <amconfig-overrides>
         <config:Database jbo.locking.mode="optimistic"/>
      </amconfig-overrides>
    </startup>
  </adf-adfm-config>
   <adf-mds-config xmlns="http://xmlns.oracle.com/adf/mds/config">
    <mds-config version="11.1.1.000" xmlns="http://xmlns.oracle.com/mds/config">
      <persistence-config>
        <metadata-namespaces>
          <namespace path="/oracle/as/ess/core" metadata-store-usage="ess-core"/>
        </metadata-namespaces>
        <metadata-store-usages>
          <metadata-store-usage id="ess-core" deploy-target="false"             default-cust-store="false">
            <metadata-store                     class-name="oracle.mds.persistence.stores.db.DBMetadataStore">
              <property name="jndi-datasource" value="jdbc/mds-ESS_MDS_DS"/>
              <property name="repository-name" value="mds-ESS_MDS_DS"/>
              <property name="partition-name" value="essapp-internal-partition"/>
            </metadata-store>
          </metadata-store-usage>
        </metadata-store-usages>
      </persistence-config>
    </mds-config>
  </adf-mds-config>
</adf-config>

Example 7-6 HTTP Servlet Code for the Front-End Submitter Application

package oracle.apps.ess.howto;
 
import java.io.IOException;
import java.io.PrintWriter;
import java.io.StringWriter;
 
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Enumeration;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.ListIterator;
import java.util.Map;
import java.util.Set;
import java.util.SortedSet;
import java.util.TreeSet;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.regex.Pattern;
 
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
 
import oracle.as.scheduler.MetadataObjectId;
import oracle.as.scheduler.MetadataObjectId.MetadataObjectType;
import oracle.as.scheduler.MetadataService;
import oracle.as.scheduler.MetadataService.QueryField;
import oracle.as.scheduler.MetadataServiceHandle;
import oracle.as.scheduler.RequestDetail;
import oracle.as.scheduler.RequestParameters;
import oracle.as.scheduler.RuntimeService;
import oracle.as.scheduler.RuntimeServiceHandle;
import oracle.as.scheduler.State;
import oracle.as.scheduler.core.JndiUtil;
 
 
public class EssDemoAppServlet extends HttpServlet {
    @SuppressWarnings("compatibility:4685800289380934682")
    private static final long serialVersionUID = 1L;
 
    private static final String CONTENT_TYPE = "text/html; charset=UTF-8";
    private static final String MESSAGE_KEY = "Message";
    private static final String PATH_SUBMIT = "/submitRequest";
    private static final String PATH_ALTER = "/alterRequest";
    private static final String MDO_SEP = ";";
    private static final String ACTION_CANCEL = "Cancel";
    private static final String ESS_UNAVAIL_MSG =
        "<p>Enterprise Scheduler Service is currently unavailable. Cause: %s</p>";
 
    private enum PseudoScheduleChoices {
        Immediately(0),
        InTenSeconds(10),
        InTenMinutes(10 * 60);
 
        @SuppressWarnings("compatibility:-5637079380819677366")
        private static final long serialVersionUID = 1L;
 
        private int m_seconds;
 
        private PseudoScheduleChoices(int seconds) {
            m_seconds = seconds;
        }
 
        public int getSeconds() {
            return m_seconds;
        }
    }
 
 
 
 
 
    public EssDemoAppServlet() throws ServletException {
        super();
    }
 
    @Override
    public void init(ServletConfig config) throws ServletException {
        super.init(config);
    }
 
    @Override
    public void doGet(HttpServletRequest request, HttpServletResponse response)
        throws ServletException, IOException
    {
        response.setContentType(CONTENT_TYPE);
 
        HttpSession session = request.getSession(true);
        String lastMessage = String.valueOf(session.getAttribute(MESSAGE_KEY));
 
        if ("null".equals(lastMessage)) {
            lastMessage = "";
        }
 
        try {
            RuntimeLists runtimeLists = getRuntimeLists();
            MetadataLists metadataLists = getMetadataLists();
            renderResponse(metadataLists, runtimeLists,
                           request, response, lastMessage);
        } catch (ServletException se) {
            throw se;
        } catch (Exception e) {
            throw new ServletException(e);
        }
    }
 
    @Override
    public void doPost(HttpServletRequest request,
                       HttpServletResponse response)
        throws ServletException, IOException
    {
        response.setContentType(CONTENT_TYPE);
        request.setCharacterEncoding("UTF-8");
 
        HttpSession session = request.getSession(true);
        String pathInfo = request.getPathInfo();
 
        // Clear the message on every post request
        StringBuilder message = new StringBuilder("");
 
        try {
          // Select each handler based on the form action
          if ("".equals(pathInfo)) {
            // No processing
          } else if (PATH_SUBMIT.equals(pathInfo)) {
            postSubmitRequest(request, message);
          } else if (PATH_ALTER.equals(pathInfo)) {
            postAlterRequest(request, message);
          } else {
            message.append(String.format("<p>No handler for pathInfo=%s</p>",
                                         pathInfo));
          }
        }
        catch (ServletException se) {
            Throwable t = se.getCause();
            String cause = (t == null) ? se.toString() : t.toString();
            message.append (String.format(ESS_UNAVAIL_MSG, cause));
        }
 
        // Storing the messages in the session allows them to persist
        // through the redirect and across refreshes.
        session.setAttribute(MESSAGE_KEY, message.toString());
 
        // render the page by redirecting to doGet(); this intentionally
        // strips the actions and post data from the request.
        response.sendRedirect(request.getContextPath() +
                              request.getServletPath());
    }
 
    /**
     * Handle the job submission form.
     * @param request
     * @param message
     * @throws ServletException
     */
    private void postSubmitRequest(HttpServletRequest request,
                                   StringBuilder message)
        throws ServletException
    {
        String jobDefName = request.getParameter("job");
        String scheduleDefName = request.getParameter("schedule");
 
        // Various required args for submission
        Calendar start = Calendar.getInstance();
        start.add(Calendar.SECOND, 2);
 
 
        // Launch the job based on form contents
        if (jobDefName == null || scheduleDefName == null) {
            message.append("Both a job name and a schedule name must be specified\n");
        } else {
            PseudoScheduleChoices pseudoSchedule = null;
 
            // See if schedule given is actually a pseudo schedule
            try {
                pseudoSchedule = PseudoScheduleChoices.valueOf(scheduleDefName);
            } catch (IllegalArgumentException e) {
                // The string is not a valid member of the enum
                pseudoSchedule = null;
            }
 
 
            MetadataObjectId scheduleDefId = null;
            String scheduleDefNamePart = null;
            MetadataObjectId jobDefId = stringToMetadataObjectId(jobDefName);
 
            // Don't look up schedules that aren't real
            if (pseudoSchedule != null) {
                scheduleDefNamePart = scheduleDefName;
                start.add(Calendar.SECOND, pseudoSchedule.getSeconds());
            } else {
                scheduleDefId = stringToMetadataObjectId(scheduleDefName);
                scheduleDefNamePart = scheduleDefId.getNamePart();
            }
 
            String jobDefNamePart = jobDefId.getNamePart();
            String requestDesc = jobDefNamePart + "@" + scheduleDefNamePart;
 
 
            Logger logger = getLogger();
            long requestId = submitRequest(pseudoSchedule, requestDesc,
                                           jobDefId, scheduleDefId, start, logger);
 
            // Populate the message block based on results
            message.append(String.format("<p>New request %d launched using %s</p>",
                                         requestId, requestDesc));
        }
    }
 
    private Long submitRequest(final PseudoScheduleChoices pseudoSchedule,
                               final String requestDesc,
                               final MetadataObjectId jobDefId,
                               final MetadataObjectId scheduleDefId,
                               final Calendar start,
                               final Logger logger)
        throws ServletException
    {
        RuntimeServicePayload<Long> myPayload = new RuntimeServicePayload<Long>() {
            @Override
            Long execute(RuntimeService service,
                         RuntimeServiceHandle handle,
                         Logger logger)
                throws Exception
            {
                RequestParameters params = new RequestParameters();
                return (null != pseudoSchedule)
                    ? service.submitRequest(handle, requestDesc, jobDefId,
                                            start, params)
                    : service.submitRequest(handle, requestDesc, jobDefId,
                                            scheduleDefId, null,
                                            start, null, params);
            }
        };
        try {
            return performOperation(myPayload, logger);
        } catch (Exception e) {
            throw new ServletException("Error submitting request using job: " +
                                       jobDefId + " and schedule: " +
                                       scheduleDefId, e);
        }
    }
 
    /**
     * Handle the "Cancel" and "Purge" actions from the form enclosing
     * the Request Status table.
     * @param request
     * @param message
     * @throws ServletException
     */
    private void postAlterRequest(HttpServletRequest request,
                                  StringBuilder message)
        throws ServletException
    {
        String cancelID = null;
 
        /*
         * there are a few assumptions going on here...
         * the HTTP button being used to transmit the action and
         * request is backwards from its normal usage (eg. the name
         * should be invariable, and the value variable).  Because we
         * want to display either "Purge" or "Cancel" on the button, and
         * transmit the reqId with it, we are reversing the map entry
         * to get the key (which in this case is the reqID), and
         * match it to the value (Purge or Cancel).
         * Assumptions are that there is only one entry in the map
         * per request (one purge or cancel).  Also, that the datatypes
         * for the key and value are those documented for
         * ServletRequest (<K,V> = <String, String[]>).
         */
        Map requestMap = request.getParameterMap();
        Iterator mapIter = requestMap.entrySet().iterator();
        while (mapIter.hasNext()) {
            Map.Entry entry = (Map.Entry)mapIter.next();
            String key = (String)entry.getKey();
            String[] values = (String[])entry.getValue();
            if (ACTION_CANCEL.equals(values[0])) {
                cancelID = key;
            }
        }
 
        if (cancelID != null) {
            try {
                final String cancelId2 = cancelID;
                RuntimeServicePayload<Void> myPayload = new RuntimeServicePayload<Void>() {
                    @Override
                    Void execute(RuntimeService service,
                                 RuntimeServiceHandle handle,
                                 Logger logger)
                        throws Exception
                    {
                        service.cancelRequest(handle, Long.valueOf(cancelId2));
                        return null;
                    }
                };
 
                Logger logger = getLogger();
                performOperation(myPayload, logger);
                message.append
                    (String.format("<p>Cancelled request %s</p>", cancelID));
            } catch (Exception e) {
                throw new ServletException
                    ("Error canceling or purging request", e);
            }
        } else {
            message.append("<p>No purge or cancel action specified</p>");
        }
    }
 
    private String metadataObjectIdToString(MetadataObjectId mdoID)
        throws ServletException {
 
        String mdoString =
            mdoID.getType().value() + MDO_SEP + mdoID.getPackagePart() +
            MDO_SEP + mdoID.getNamePart();
 
        return mdoString;
    }
 
    private MetadataObjectId stringToMetadataObjectId(String mdoString)
        throws ServletException {
        String[] mdoStringParts = mdoString.split(Pattern.quote(MDO_SEP));
        if (mdoStringParts.length != 3) {
            throw new ServletException(String.format("Unexpected number of components %d found " +
                                                     "when converting %s to MetadataObjectID",
                                                     mdoStringParts.length,
                                                     mdoString));
        }
 
        MetadataObjectType mdType =
            MetadataObjectType.getMOType(mdoStringParts[0]);
        String mdPackage = mdoStringParts[1];
        String mdName = mdoStringParts[2];
 
        MetadataObjectId mdoID =
            MetadataObjectId.createMetadataObjectId(mdType, mdPackage, mdName);
        return mdoID;
    }
 
    /**
     * this changes the format used in this class for job definitions to the one
     * which is used in the runtime query.
     * @param strMetadataObject
     * @return string representing object in runtime store
     * @throws ServletException
     */
    private String fixMetadataString(String strMetadataObject)
        throws ServletException {
        String fslash = "/";
        String[] mdoStringParts =
            strMetadataObject.split(Pattern.quote(MDO_SEP));
        if (mdoStringParts.length != 3) {
            throw new ServletException(String.format("Unexpected number of components %d found " +
                                                     "when converting %s to MetadataObjectID",
                                                     mdoStringParts.length,
                                                     strMetadataObject));
        }
        String[] trimStringParts = new String[mdoStringParts.length];
        for (int i = 0; i < mdoStringParts.length; i++) {
            String mdoStringPart = mdoStringParts[i];
            trimStringParts[i] = mdoStringPart.replaceAll(fslash, " ").trim();
        }
 
        MetadataObjectType mdType =
            MetadataObjectType.getMOType(trimStringParts[0]);
        String mdPackage = fslash + trimStringParts[1];
        String mdName = trimStringParts[2];
        MetadataObjectId metadataObjId =
            MetadataObjectId.createMetadataObjectId(mdType, mdPackage, mdName);
        return metadataObjId.toString();
    }
 
    private Set<String> getSetFromMetadataEnum(Enumeration<MetadataObjectId> enumMetadata)
        throws ServletException {
        Set<String> stringSet = new HashSet<String>();
 
        while (enumMetadata.hasMoreElements()) {
            MetadataObjectId objId = enumMetadata.nextElement();
            String strNamePart = objId.getNamePart();
            stringSet.add(strNamePart);
        }
        return stringSet;
    }
 
    //****************************************************************************
    //
    //   HTML Rendering Methods
    //
    //****************************************************************************
 
    /**
     * Rendering code for the page displayed.
     * In a real application this would be done using JSP, but this approach
     * keeps everything in one file to make the example easier to follow.
     * @param response The response object from the main request.
     * @param message Text that appears in the message panel, may contain HTML
     * @throws IOException
     */
    private void renderResponse(MetadataLists ml,
                                RuntimeLists rl,
                                HttpServletRequest request,
                                HttpServletResponse response,
                                String message)
        throws IOException, ServletException
    {
        response.setContentType(CONTENT_TYPE);
        PrintWriter out = response.getWriter();
 
        String urlBase = request.getContextPath() + request.getServletPath();
 
        // Indents maintained for clarity
        out.println("<html>");
        out.println("<head><title>EssDemo</title></head>");
        out.println("<body>");
        out.println("<table align=\"center\"><tbody>");
        out.println("  <tr><td align=\"center\"><h1>Oracle Enterprise Scheduler Tutorial</h1></td></tr>");
        out.println("  <tr><td align=\"center\"><table cellspacing=6><tr>");
 
        // Job launch form
        out.println("    <td align=\"center\">");
        out.println("      <h2>Launch Job</h2>");
        renderLaunchJobForm(ml, out, urlBase);
        out.println("    </td>");
 
        out.println("    <td align=\"center\" bgcolor=\"blue\" width=\"2\"/>");
 
        out.println("  </tr></table></td></tr>");
 
        out.println("  <tr><td bgcolor=\"red\"/></tr>");
 
        // Message panel
        out.println("      <tr><td align=\"center\"><h3>Messages</h3></td></tr>");
        out.println("      <tr><td>");
        out.println(message);
        out.println("    </td></tr>");
 
        out.println("  <tr><td bgcolor=\"red\"/></tr>");
 
        // Request status
        out.println("  <tr><td align=\"center\">");
        out.println("    <form name=\"attrs\" action=\"" + urlBase +
                    PATH_ALTER + "\" method=\"post\">");
        out.println("    <h2>Request Status</h2>");
        out.println("    <table border=2><tbody>");
        out.println("          <th>reqID</th>");
        out.println("          <th>Description</th>");
        out.println("          <th>Scheduled time</th>");
        out.println("          <th>State</th>");
        out.println("          <th>Action</th>");
 
        renderStatusTable(out, rl.requestDetails);
 
        out.println("    </tbody></table>");
        out.println("    </form>");
        out.println("  </td></tr>");
        out.println("</tbody></table>");
        out.println("</body></html>");
        out.close();
    }
 
    private void renderLaunchJobForm(MetadataLists ml, PrintWriter out, String urlBase)
        throws ServletException {
        out.println("      <form name=\"attrs\" action=\"" + urlBase +
                    PATH_SUBMIT + "\" method=\"post\">");
        out.println("        <table><tbody>");
        out.println("          <tr><td align=\"right\">");
        out.println("            <b>Job:</b>");
        out.println("            <select name=\"job\">");
 
        renderMetadataChoices(out, ml.jobDefList, false);
        renderMetadataChoices(out, ml.jobSetList, false);
 
        out.println("            </select>");
        out.println("          </td></tr>");
        out.println("          <tr><td align=\"right\">");
        out.println("            <b>Schedule:</b>");
        out.println("            <select name=\"schedule\">");
 
        renderPseudoScheduleChoices(out);
        renderMetadataChoices(out, ml.scheduleList, false);
 
        out.println("            </select>");
        out.println("          </td></tr>");
        out.println("          <tr><td align=\"center\">");
        out.println("            <input name=\"submit\" value=\"Submit\" type=\"submit\">");
        out.println("          </td></tr>");
        out.println("        </tbody></table>");
        out.println("      </form>");
    }
 
    /**
     *
     * @param out - printwriter
     * @param jobChoices --  metadata to be displayed
     * @param bBlankFirst -- blank first (so that this param is not required)
     * @throws ServletException
     */
    private void renderMetadataChoices(PrintWriter out,
                                       Enumeration<MetadataObjectId> jobChoices,
                                       boolean bBlankFirst)
        throws ServletException
    {
        if (jobChoices == null)
            return;
 
        boolean bFirst = true;
        while (jobChoices.hasMoreElements()) {
            MetadataObjectId job = jobChoices.nextElement();
            String strJob = metadataObjectIdToString(job);
            String strNamePart = job.getNamePart();
            if (strNamePart.compareTo("BatchPurgeJob") == 0) {
                continue;
            } else {
                if (bFirst && bBlankFirst) {
                    out.printf("<option value=\"%s\">%s</option>", "", "");
                    bFirst = false;
                }
                out.printf("<option value=\"%s\">%s</option>", strJob,
                           strNamePart);
            }
        }
    }
 
    /**
     * helper method for rendering choices based on strings, adding an empty
     * string to the beginning of the list
     * @param out
     * @param choices
     */
    private void renderStringChoices(PrintWriter out, Set<String> choices) {
        if (choices == null)
            return;
 
        choices.add("");
        SortedSet<String> sorted = new TreeSet<String>(choices);
        Iterator choiceIter = sorted.iterator();
        while (choiceIter.hasNext()) {
            String choice = (String)choiceIter.next();
 
            out.printf("<option value=\"%s\">%s</option>", choice, choice);
        }
    }
 
    private void renderPseudoScheduleChoices(PrintWriter out) {
        for (PseudoScheduleChoices c : PseudoScheduleChoices.values()) {
            out.printf("<option value=\"%s\">%s</option>", c, c);
        }
    }
 
    private void renderStatusTable
        (PrintWriter out, List<RequestDetail> reqDetails)
    {
        if (reqDetails == null) {
            return;
        }
 
        for (RequestDetail reqDetail : reqDetails) {
            State state = reqDetail.getState();
 
            Calendar scheduledTime = reqDetail.getScheduledTime();
            String scheduledTimeString = null;
 
            if (scheduledTime == null) {
                scheduledTimeString = "null scheduled time";
            } else {
                scheduledTimeString = String.valueOf(scheduledTime.getTime());
            }
 
            final String actionButton;
            if (!state.isTerminal()) {
                String action = ACTION_CANCEL;
                String reqId = String.valueOf(reqDetail.getRequestId());
                actionButton = String.format
                    ("<button type=submit value=%s name=\"%s\">%s</button>",
                     action, reqId, action);
            } else {
                actionButton = "&nbsp;";
            }
 
            out.printf("<tr><td>%d</td><td>%s</td><td>%s</td><td>%s</td><td>%s</td></tr>\n",
                       reqDetail.getRequestId(), reqDetail.getDescription(),
                       scheduledTimeString, state, actionButton);
        }
    }
 
 
    private MetadataService getMetadataService() throws Exception {
        return JndiUtil.getMetadataServiceEJB();
    }
 
    private RuntimeService getRuntimeService() throws Exception {
        return JndiUtil.getRuntimeServiceEJB();
    }
 
    private abstract class Payload<SERVICE, HANDLE, RETURN> {
        abstract SERVICE getService() throws Exception;
        abstract HANDLE getHandle(SERVICE service) throws Exception;
        abstract void closeHandle(SERVICE service,
                                  HANDLE handle,
                                  boolean abort)
            throws Exception;
        abstract RETURN execute(SERVICE service, HANDLE handle, Logger logger)
            throws Exception;
    }
 
    private abstract class MetadataServicePayload<T>
        extends Payload<MetadataService, MetadataServiceHandle, T>
    {
        @Override
        MetadataService getService() throws Exception {
            return getMetadataService();
        }
 
        @Override
        MetadataServiceHandle getHandle(MetadataService service)
            throws Exception
        {
            return service.open();
        }
 
        @Override
        void closeHandle(MetadataService service,
                         MetadataServiceHandle handle,
                         boolean abort)
            throws Exception
        {
            service.close(handle, abort);
        }
    }
 
    private abstract class RuntimeServicePayload<T>
        extends Payload<RuntimeService, RuntimeServiceHandle, T>
    {
        @Override
        RuntimeService getService() throws Exception {
            return getRuntimeService();
        }
 
        @Override
        RuntimeServiceHandle getHandle(RuntimeService service)
            throws Exception
        {
            return service.open();
        }
 
        @Override
        void closeHandle(RuntimeService service,
                         RuntimeServiceHandle handle,
                         boolean abort)
            throws Exception
        {
            service.close(handle, abort);
        }
    }
 
    private <S, H, R> R performOperation
            (Payload<S, H, R> payload, Logger logger)
        throws Exception
    {
        S service = payload.getService();
        H handle = payload.getHandle(service);
 
        Exception origException = null;
        try {
            return payload.execute(service, handle, logger);
        } catch (Exception e2) {
            origException = e2;
            throw e2;
        } finally {
            if (null != handle) {
                try {
                    boolean abort = (null != origException);
                    payload.closeHandle(service, handle, abort);
                } catch (Exception e2) {
                    if (null != origException) {
                        logger.log(Level.WARNING, "An error occurred while " +
                            "closing handle, however, a previous failure was " +
                            "detected.  The following error will be logged " +
                            "but not reported: " + stackTraceToString(e2));
                    }
                }
            }
        }
    }
 
    private final String stackTraceToString(Exception e) {
        StringWriter sw = new StringWriter();
        PrintWriter pw = new PrintWriter(sw);
        e.printStackTrace(pw);
        pw.flush();
        pw.close();
        return sw.toString();
    }
 
    private Logger getLogger() {
        return Logger.getLogger(this.getClass().getName());
    }
 
    private class MetadataLists {
        private final Enumeration<MetadataObjectId> jobDefList;
        private final Enumeration<MetadataObjectId> jobSetList;
        private final Enumeration<MetadataObjectId> scheduleList;
        private final Enumeration<MetadataObjectId> jobTypeList;
 
        private MetadataLists(Enumeration<MetadataObjectId> jobDefList,
                              Enumeration<MetadataObjectId> jobSetList,
                              Enumeration<MetadataObjectId> scheduleList,
                              Enumeration<MetadataObjectId> jobTypeList)
        {
            this.jobDefList   = jobDefList;
            this.jobSetList   = jobSetList;
            this.scheduleList = scheduleList;
            this.jobTypeList  = jobTypeList;
        }
    }
 
    private class RuntimeLists {
        private final List<RequestDetail> requestDetails;
        private final Set<String> applicationChoices;
        private final Set<String> stateChoices;
        private final Set<MetadataObjectId> jobDefMDOChoices;
 
        private RuntimeLists(List<RequestDetail> requestDetails,
                             Set<String> applicationChoices,
                             Set<String> stateChoices,
                             Set<MetadataObjectId> jobDefMDOChoices)
        {
            super();
            this.requestDetails = requestDetails;
            this.applicationChoices = applicationChoices;
            this.stateChoices = stateChoices;
            this.jobDefMDOChoices = jobDefMDOChoices;
        }
    }
 
    /**
     * Retrieve lists of jobs, schedules, and status for use by the renderer
     * @throws ServletException
     */
    private MetadataLists getMetadataLists() throws Exception {
        Logger logger = getLogger();
 
        MetadataServicePayload<MetadataLists> myPayload =
            new MetadataServicePayload<MetadataLists>()
        {
            @Override
            MetadataLists execute(MetadataService service,
                                  MetadataServiceHandle handle,
                                  Logger logger)
                throws Exception
            {
                Enumeration<MetadataObjectId> jobDefs =
                    service.queryJobDefinitions(handle, null, QueryField.NAME, true);
                Enumeration<MetadataObjectId> jobSets =
                    service.queryJobSets(handle, null, QueryField.NAME, true);
                Enumeration<MetadataObjectId> schedules =
                    service.querySchedules(handle, null, QueryField.NAME, true);
                Enumeration<MetadataObjectId> jobTypes =
                    service.queryJobTypes(handle, null, QueryField.NAME, true);
 
                return new MetadataLists(jobDefs, jobSets, schedules, jobTypes);
            }
        };
        MetadataLists ml = performOperation(myPayload, logger);
        return ml;
    }
 
    private RuntimeLists getRuntimeLists() throws Exception {
        Logger logger = getLogger();
 
        RuntimeServicePayload<List<RequestDetail>> myPayload2 =
            new RuntimeServicePayload<List<RequestDetail>>()
        {
            @Override
            List<RequestDetail> execute(RuntimeService service,
                                        RuntimeServiceHandle handle,
                                        Logger logger)
                throws Exception
            {
                List<RequestDetail> reqDetails =
                    new ArrayList<RequestDetail>(10);
                Enumeration requestIds = service.queryRequests
                    (handle, null, RuntimeService.QueryField.REQUESTID, true);
 
                while (requestIds.hasMoreElements()) {
                    Long reqId = (Long)requestIds.nextElement();
                    RequestDetail detail = service.getRequestDetail(handle, reqId);
                    reqDetails.add(detail);
                }
 
                return reqDetails;
            }
        };
        List<RequestDetail> reqDetails = performOperation(myPayload2, logger);
        RuntimeLists rl = getRuntimeLists(reqDetails);
        return rl;
    }
 
    private RuntimeLists getRuntimeLists(List<RequestDetail> reqDetails) {
        Set<String> applicationSet = new HashSet<String>(10);
        Set<String> stateSet = new HashSet<String>(10);
        Set<MetadataObjectId> jobDefMOSet = new HashSet<MetadataObjectId>(10);
 
        if (reqDetails != null) {
            ListIterator detailIter = reqDetails.listIterator();
            while (detailIter.hasNext()) {
                RequestDetail detail = (RequestDetail)detailIter.next();
                applicationSet.add(detail.getDeployedApplication());
                State state = detail.getState();
                if (state.isTerminal())
                    stateSet.add(state.name());
                jobDefMOSet.add(detail.getJobDefn());
            }
        }
 
        RuntimeLists rl = new RuntimeLists
            (reqDetails, applicationSet, stateSet, jobDefMOSet);
        return rl;
    }
 
}

Example 7-7 Contents to Copy to weblogic-application.xml for a Front-End Submitter Application

<?xml version = '1.0' encoding = 'UTF-8'?>
<weblogic-application xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
                      xsi:schemaLocation="http://www.bea.com/ns/weblogic/weblogic-application
 
http://www.bea.com/ns/weblogic/weblogic-application/1.0/weblogic-application.xsd"
                      xmlns="http://www.bea.com/ns/weblogic/weblogic-application">
 
    <!-- The following application parameter tells JPS which stripe it should
       - use to upload the jazn-data.xml policy.  If this parameter is not
       - specified, it uses the Java EE deployment name plus the version
       - number (e.g. EssDemoApp#V2.0).
      -->
    <application-param>
        <param-name>jps.policystore.applicationid</param-name>
        <param-value>EssDemoAppUI</param-value>
    </application-param>
 
    <!-- This listener allows JPS to configure itself and upload the
       - jazn-data.xml policy to the appropriate stripe
      -->
    <listener>
        <listener-class>oracle.security.jps.wls.listeners.JpsApplicationLifecycleListener</listener-class>
    </listener>
 
    <!-- This listener allows MDS to configure itself and upload any metadata
       - as defined by the MAR profile and adf-config.xml
      -->
    <listener>
        <listener-class>oracle.mds.lcm.weblogic.WLLifecycleListener</listener-class>
    </listener>
 
    <!-- This listener allows Oracle Enterprise Scheduler to configure itself
      -->
    <listener>
        <listener-class>oracle.as.scheduler.platform.wls.deploy.ESSApplicationLifecycleListener</listener-class>
    </listener>
 
    <!-- This shared library contains all the Oracle Enterprise Scheduler classes
      -->
    <library-ref>
        <library-name>oracle.ess.client</library-name>
    </library-ref>
    <library-ref>
        <library-name>adf.oracle.domain</library-name>
    </library-ref>
</weblogic-application>

Example 7-8 Contents to Copy to adf-config.xml for a Front-End Submitter Application

<?xml version="1.0" encoding="UTF-8" ? >
<adf-config xmlns="http://xmlns.oracle.com/adf/config" 
    xmlns:sec="http://xmlns.oracle.com/adf/security/config">
  <sec:adf-security-child xmlns="http://xmlns.oracle.com/adf/security/config">  <CredentialStoreContext 
 credentialStoreClass="oracle.adf.share.security.providers.jps.CSFCredentialSto 
 re" 
                           
 credentialStoreLocation="../../src/META-INF/jps-config.xml"/> 
   sec:JaasSecurityContext 
 initialContextFactoryClass="oracle.adf.share.security.JAASInitialContextFactor 
 y" 
                             
 jaasProviderClass="oracle.adf.share.security.providers.jps.JpsSecurityContext" 
 . 
                            authorizationEnforce="false" 
                            authenticationRequire="true"/ 
  </sec:adf-security-child> 
  <adf-mds-config xmlns="http://xmlns.oracle.com/adf/mds/config"> 
    <mds-config version="11.1.1.000" 
xmlns="http://xmlns.oracle.com/mds/config"> 
    <type-config> 
             <type-definitions> 
               <classpathschema/Exclusion.xsd/classpath> 
               <classpathschema/Incompatibility.xsd/classpath> 
               <classpathschema/JobDefinition.xsd/classpath> 
               <classpathschema/JobSet.xsd/classpath> 
               <classpathschema/JobType.xsd/classpath> 
               <classpathschema/Schedule.xsd/classpath> 
               <classpathschema/Specialization.xsd/classpath> 
               <classpathschema/Trigger.xsd/classpath> 
               <classpathschema/TriggerExpression.xsd/classpath> 
               <classpathschema/WorkAssignment.xsd/classpath> 
               <classpathschema/Workshift.xsd/classpath> 
             </type-definitions> 
           </type-config> 
    <persistence-config> 
        <metadata-namespaces> 
           <namespace path="/oracle/as/ess/core" 
 metadata-store-usage="ess-core"/> 
           namespace path="/oracle/apps/ess" 
 metadata-store-usage="demo-app"/> 
        </metadata-namespaces> 
        <metadata-store-usages> 
        <metadata-store-usage id="ess-core" deploy-target="false" 
 default-cust-store="false"> 
           <metadata-store 
 class-name="oracle.mds.persistence.stores.db.DBMetadataStore">           
             <property name="jndi-datasource" value="jdbc/mds-ESS_MDS_DS"/> 
             <property name="repository-name" value="mds-ESS_MDS_DS"/> 
             <property name="partition-name" 
 value="essapp-internal-partition"/> 
           </metadata-store> 
        </metadata-store-usage> 
        metadata-store-usage id="demo-app" deploy-target="true" 
 default-cust-store="false"> 
           <metadata-store 
 class-name="oracle.mds.persistence.stores.db.DBMetadataStore"> 
             <property name="jndi-datasource" value="jdbc/mds-ESS_MDS_DS"/>
             <property name="repository-name" value="mds-ESS_MDS_DS"/> 
             <property name="partition-name" value="essUserMetadata"/> 
           </metadata-store> 
        </metadata-store-usage> 
        </metadata-store-usages> 
      </persistence-config> 
    </mds-config> 
  </adf-mds-config> 
 </adf-config>