diff options
Diffstat (limited to 'pki/base/common/src/com/netscape/cmscore/request/RequestSubsystem.java')
-rw-r--r-- | pki/base/common/src/com/netscape/cmscore/request/RequestSubsystem.java | 79 |
1 files changed, 43 insertions, 36 deletions
diff --git a/pki/base/common/src/com/netscape/cmscore/request/RequestSubsystem.java b/pki/base/common/src/com/netscape/cmscore/request/RequestSubsystem.java index d58196a75..90df99248 100644 --- a/pki/base/common/src/com/netscape/cmscore/request/RequestSubsystem.java +++ b/pki/base/common/src/com/netscape/cmscore/request/RequestSubsystem.java @@ -17,6 +17,7 @@ // --- END COPYRIGHT BLOCK --- package com.netscape.cmscore.request; + import com.netscape.certsrv.apps.CMS; import com.netscape.certsrv.base.EBaseException; import com.netscape.certsrv.base.IConfigStore; @@ -31,21 +32,24 @@ import com.netscape.certsrv.request.IRequestSubsystem; import com.netscape.certsrv.request.IService; import com.netscape.cmscore.dbs.DBSubsystem; + /** * RequestSubsystem * <p> - * This class is reponsible for managing storage of request objects in the local - * database. + * This class is reponsible for managing storage of request objects + * in the local database. * <p> - * TODO: review this It provides: + registration of LDAP/JAVA mapping classes - * with the DBSubsystem + creation of RequestQueue storage in the database + - * retrieval of existing RequestQueue objects from the database + * TODO: review this + * It provides: + * + registration of LDAP/JAVA mapping classes with the DBSubsystem + * + creation of RequestQueue storage in the database + * + retrieval of existing RequestQueue objects from the database * <p> - * * @author thayes * @version $Revision$, $Date$ */ -public class RequestSubsystem implements IRequestSubsystem, ISubsystem { +public class RequestSubsystem + implements IRequestSubsystem, ISubsystem { public final static String ID = IRequestSubsystem.SUB_ID; @@ -63,49 +67,49 @@ public class RequestSubsystem implements IRequestSubsystem, ISubsystem { // end singleton enforcement. // - // Create a new request queue. The LDAP DN for the entry + // Create a new request queue. The LDAP DN for the entry // in the database is supplied by the caller. // - public void createRequestQueue(String name) throws EBaseException { + public void createRequestQueue(String name) + throws EBaseException { /* - * String dbName = makeQueueName(name); IDBSSession dbs = - * createDBSSession(); - * - * // Create Repository record here - * - * dbs.add(dbName, r); - */ + String dbName = makeQueueName(name); + IDBSSession dbs = createDBSSession(); + + // Create Repository record here + + dbs.add(dbName, r); + */ } - public IRequestQueue getRequestQueue(String name, int increment, IPolicy p, - IService s, INotify n) throws EBaseException { + public IRequestQueue + getRequestQueue(String name, int increment, IPolicy p, IService s, INotify n) + throws EBaseException { return getRequestQueue(name, increment, p, s, n, null); } - public IRequestQueue getRequestQueue(String name, int increment, IPolicy p, - IService s, INotify n, INotify pendingNotifier) - throws EBaseException { - RequestQueue rq = new RequestQueue(name, increment, p, s, n, - pendingNotifier); + public IRequestQueue + getRequestQueue(String name, int increment, IPolicy p, IService s, INotify n, + INotify pendingNotifier) + throws EBaseException { + RequestQueue rq = new RequestQueue(name, increment, p, s, n, pendingNotifier); // can't do this here because the service depends on getting rq - // (to get request) and since this method hasn't returned it's rq is - // null. - // rq.recover(); + // (to get request) and since this method hasn't returned it's rq is null. + //rq.recover(); return rq; } // // ISubsystem methods: - // getId, setId, init, startup, shutdown, getConfigStore + // getId, setId, init, startup, shutdown, getConfigStore // /** * Implements ISubsystem.getId * <p> - * * @see ISubsystem#getId */ public String getId() { @@ -113,7 +117,8 @@ public class RequestSubsystem implements IRequestSubsystem, ISubsystem { } // ISubsystem.setId - public void setId(String id) throws EBaseException { + public void setId(String id) + throws EBaseException { mId = id; } @@ -122,18 +127,18 @@ public class RequestSubsystem implements IRequestSubsystem, ISubsystem { mParent = parent; mConfig = config; } - + /** * Implements ISubsystem.startup * <p> - * * @see ISubsystem#startup */ - public void startup() throws EBaseException { + public void startup() + throws EBaseException { mLogger = CMS.getLogger(); mLogger.log(ILogger.EV_SYSTEM, ILogger.S_REQQUEUE, ILogger.LL_INFO, - "Request subsystem started"); + "Request subsystem started"); } public void shutdown() { @@ -141,7 +146,7 @@ public class RequestSubsystem implements IRequestSubsystem, ISubsystem { if (mLogger != null) { mLogger.log(ILogger.EV_SYSTEM, ILogger.S_REQQUEUE, ILogger.LL_INFO, - "Request subsystem stopped"); + "Request subsystem stopped"); } } @@ -160,7 +165,8 @@ public class RequestSubsystem implements IRequestSubsystem, ISubsystem { // Create a database session in the default database // system. // - protected IDBSSession createDBSSession() throws EBaseException { + protected IDBSSession createDBSSession() + throws EBaseException { return getDBSubsystem().createSession(); } @@ -180,5 +186,6 @@ public class RequestSubsystem implements IRequestSubsystem, ISubsystem { private String mId = IRequestSubsystem.SUB_ID; private IRequestQueue mRequestQueue; - protected ILogger mLogger; + protected ILogger mLogger; } + |