Java Doc for JobQueue.java in » J2EE » Expresso » com » jcorporate » expresso » services » dbobj » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation

1.	6.0 JDK Core
2.	6.0 JDK Modules
3.	6.0 JDK Modules com.sun
4.	6.0 JDK Modules com.sun.java
5.	6.0 JDK Modules sun
6.	6.0 JDK Platform
7.	Ajax
8.	Apache Harmony Java SE
9.	Aspect oriented
10.	Authentication Authorization
11.	Blogger System
12.	Build
13.	Byte Code
14.	Cache
15.	Chart
16.	Chat
17.	Code Analyzer
18.	Collaboration
19.	Content Management System
20.	Database Client
21.	Database DBMS
22.	Database JDBC Connection Pool
23.	Database ORM
24.	Development
25.	EJB Server geronimo
26.	EJB Server GlassFish
27.	EJB Server JBoss 4.2.1
28.	EJB Server resin 3.1.5
29.	ERP CRM Financial
30.	ESB
31.	Forum
32.	GIS
33.	Graphic Library
34.	Groupware
35.	HTML Parser
36.	IDE
37.	IDE Eclipse
38.	IDE Netbeans
39.	Installer
40.	Internationalization Localization
41.	Inversion of Control
42.	Issue Tracking
43.	J2EE
44.	JBoss
45.	JMS
46.	JMX
47.	Library
48.	Mail Clients
49.	Net
50.	Parser
51.	PDF
52.	Portal
53.	Profiler
54.	Project Management
55.	Report
56.	RSS RDF
57.	Rule Engine
58.	Science
59.	Scripting
60.	Search Engine
61.	Security
62.	Sevlet Container
63.	Source Control
64.	Swing Library
65.	Template Engine
66.	Test Coverage
67.	Testing
68.	UML
69.	Web Crawler
70.	Web Framework
71.	Web Mail
72.	Web Server
73.	Web Services
74.	Web Services apache cxf 2.0.1
75.	Web Services AXIS2
76.	Wiki Engine
77.	Workflow Engines
78.	XML
79.	XML UI

Java

Java Tutorial

Illustrator Tutorials

GIMP Tutorials

C# / C Sharp

C# / CSharp Tutorial

C# / CSharp Open Source

SQL Server / T-SQL Tutorial

Oracle PL / SQL

Oracle PL/SQL Tutorial

Flash / Flex / ActionScript

VBA / Excel / Access / Word

XML

XML Tutorial

Microsoft Office PowerPoint 2007 Tutorial

Microsoft Office Excel 2007 Tutorial

Microsoft Office Word 2007 Tutorial

Java Source Code / Java Documentation » J2EE » Expresso » com.jcorporate.expresso.services.dbobj

Source Cross Reference Class Diagram Java Document (Java Doc)

com.jcorporate.expresso.core.dbobj .SecuredDBObject

com.jcorporate.expresso.services.dbobj .JobQueue

JobQueue

public class JobQueue extends SecuredDBObject (Code)

Jobqueue is a table that contains all the jobs, or asynchronous tasks, to be executed. This table works with JobQueueParam table as a detail table so that multiple parameters per job may be specified. The JobHandler checks the JobQueue table every so often to see if there's a job there waiting to be used. If it is, then the JobHandler server takes ownership of that JobQueue entry, constructs a job object based upon it and executes the appropriate job

author:
Michael Nash, Cron Enhancements by Mike Dubman
version:
$Revision: 1.16 $ $Date: 2004/11/17 20:48:18 $

Field Summary
final public static String	FLD_JOBCODE
final public static String	FLD_JOBCRON_PARAMS
final public static String	FLD_JOBNUMBER
final public static String	FLD_JOBOSNAME
final public static String	FLD_JOB_PROGRESS_MSG
final public static String	FLD_PRIORITY
final public static String	FLD_REQUEST_TIME
final public static String	FLD_SERVERID
final public static String	FLD_STATUS_CODE
final public static String	FLD_UID
final public static String	JOB_ARCH_ANY
final public static String	JOB_ARCH_MSWIN
final public static String	JOB_ARCH_UNIX
final public static String	JOB_PRIORITY_HIGH
final public static String	JOB_PRIORITY_LOW
final public static String	JOB_PRIORITY_NORMAL
final public static String	JOB_STATUS_AVAILABLE
final public static String	JOB_STATUS_COMPLETED
final public static String	JOB_STATUS_KILLED
final public static String	JOB_STATUS_NEW
final public static String	JOB_STATUS_RUNNING
final public static String	JOB_STATUS_STOPPED
final public static String	JOB_STATUS_SUSPENDED

Constructor Summary
public	JobQueue()
public	JobQueue(DBConnection newConnection) Connection that provides a DBConnection.
public	JobQueue(int uid) Initializes the JobQueue with the appropriate user permissions.
public	JobQueue(ControllerRequest request) For using DBObjects within Controllers.

Method Summary
public void	add()
public boolean	find() Extend the normal find method to read the parameters once the find is done.
public String	getCronEntry()
public String	getField(String fieldName)
public String	getJobStatus()
public synchronized String	getParamValue(String paramCode)
public synchronized Vector	getParams()
public Vector	getValidValues(String fieldName)
public void	retrieve()
public void	setCronParams(int minute, int hour, int dayOfMonth, int month, int dayOfWeek, int year)
public void	setJobCode(String jobCode)
public void	setJobOSName(String os)
public void	setJobStatus(String status)
public void	setUid(String userId)
protected synchronized void	setupFields()
public boolean	useCron() Convenience method to determine if cron parameters are associated with this object instance.

Field Detail

FLD_JOBCODE
final public static String FLD_JOBCODE(Code)

FLD_JOBCRON_PARAMS
final public static String FLD_JOBCRON_PARAMS(Code)

FLD_JOBNUMBER
final public static String FLD_JOBNUMBER(Code)

FLD_JOBOSNAME
final public static String FLD_JOBOSNAME(Code)

FLD_JOB_PROGRESS_MSG
final public static String FLD_JOB_PROGRESS_MSG(Code)

FLD_PRIORITY
final public static String FLD_PRIORITY(Code)

FLD_REQUEST_TIME
final public static String FLD_REQUEST_TIME(Code)

FLD_SERVERID
final public static String FLD_SERVERID(Code)

FLD_STATUS_CODE
final public static String FLD_STATUS_CODE(Code)

FLD_UID
final public static String FLD_UID(Code)

JOB_ARCH_ANY
final public static String JOB_ARCH_ANY(Code)

JOB_ARCH_MSWIN
final public static String JOB_ARCH_MSWIN(Code)

JOB_ARCH_UNIX
final public static String JOB_ARCH_UNIX(Code)

JOB_PRIORITY_HIGH
final public static String JOB_PRIORITY_HIGH(Code)

JOB_PRIORITY_LOW
final public static String JOB_PRIORITY_LOW(Code)

JOB_PRIORITY_NORMAL
final public static String JOB_PRIORITY_NORMAL(Code)

JOB_STATUS_AVAILABLE
final public static String JOB_STATUS_AVAILABLE(Code)

JOB_STATUS_COMPLETED
final public static String JOB_STATUS_COMPLETED(Code)

JOB_STATUS_KILLED
final public static String JOB_STATUS_KILLED(Code)

JOB_STATUS_NEW
final public static String JOB_STATUS_NEW(Code)

JOB_STATUS_RUNNING
final public static String JOB_STATUS_RUNNING(Code)

JOB_STATUS_STOPPED
final public static String JOB_STATUS_STOPPED(Code)

JOB_STATUS_SUSPENDED
final public static String JOB_STATUS_SUSPENDED(Code)

Constructor Detail

JobQueue
public JobQueue() throws DBException(Code)
	See Also: com.jcorporate.expresso.core.dbobj.SecuredDBObject

JobQueue
public JobQueue(DBConnection newConnection) throws DBException(Code)
	Connection that provides a DBConnection. Parameters: newConnection - an already created DBConnection grabbed from theconnection pool that will be used for the lifetime of the object.

JobQueue
public JobQueue(int uid) throws DBException(Code)
	Initializes the JobQueue with the appropriate user permissions. Parameters: uid - The User's uid throws: DBException - on error

JobQueue
public JobQueue(ControllerRequest request) throws DBException(Code)
	For using DBObjects within Controllers. Initializes based upon the current user and the requested db. [Of course this can be modified later] Parameters: request - - The controller request handed to you by the framework.

Method Detail

add
public void add() throws DBException(Code)
	Extends the usual add method to fetch a next number field and set the Updated flag to Y throws: DBException - If the next number cannot be determined orthe add fails

find
public boolean find() throws DBException(Code)
	Extend the normal find method to read the parameters once the find is done. boolean

getCronEntry
public String getCronEntry() throws DBException(Code)

getField
public String getField(String fieldName) throws DBException(Code)

getJobStatus
public String getJobStatus() throws DBException(Code)

getParamValue
public synchronized String getParamValue(String paramCode) throws DBException(Code)
	Get the parameter value for the named parameter code Parameters: paramCode - Code for which we want the value String The parameter value throws: DBException - If the paramter value cannot be retrieved

getParams
public synchronized Vector getParams() throws DBException(Code)
	Get the job queue parameters associated with this queue entry Vector A vector of JobQueueParam objects for this entry throws: DBException - If the job queue entry has not yet been retrieved

getValidValues
public Vector getValidValues(String fieldName) throws DBException(Code)
	Override the method getValidValues to provide specific values for our multi-valued fields Parameters: fieldName - Field name for which values are requested Vector The ValidValues field throws: DBException - If the values cannot be retrieved

retrieve
public void retrieve() throws DBException(Code)
	Extend the normal retrieve method to read the parameters after the record is retrieved throws: DBException - If the parameters or the entry cannot be retrieved

setCronParams

public void setCronParams(int minute, int hour, int dayOfMonth, int month, int dayOfWeek, int year) throws DBException(Code)

Cron-like alarm (minute, hour, day of month, month, day of week, year) Repetitive when the year is not specified.

Examples:

Every minute:
: setCronParams(-1, -1, -1, -1, -1)

Every hour at 5:
: setCronParams(5, -1, -1, -1, -1, -1)

Lunch time:
setCronParams(00, 12, -1, -1, -1, -1)

On the first of every month at 9:30
setCronParams(30, 9, 1, -1, -1, -1)

On every Friday at 18:00
setCronParams(00, 18, -1, -1, Calendar.FRIDAY, -1)

2 years that this class was programmed !
setCronParams(00, 13, 1, Calendar.AUGUST, -1, 2001)

Parameters:
  minute - The minute code
Parameters:
  hour - The hour code
Parameters:
  dayOfMonth - The day of Month code
Parameters:
  month - the Month to execute code
Parameters:
  dayOfWeek - The day of week to execute code
Parameters:
  year - The year to execute code
throws:
  DBException - upon error

setJobCode
public void setJobCode(String jobCode) throws DBException(Code)

setJobOSName
public void setJobOSName(String os) throws DBException(Code)

setJobStatus
public void setJobStatus(String status) throws DBException(Code)

setUid
public void setUid(String userId) throws DBException(Code)

setupFields
protected synchronized void setupFields() throws DBException(Code)
	See Also: com.jcorporate.expresso.core.dbobj.SecuredDBObject.setupFields

useCron
public boolean useCron() throws DBException(Code)
	Convenience method to determine if cron parameters are associated with this object instance. true if cron parameters are associated with this job

Fields inherited from com.jcorporate.expresso.core.dbobj.SecuredDBObject

final public static String ADD(Code)(Java Doc)
final public static String[] ALL_FUNCTIONS(Code)(Java Doc)
final protected static String CACHE_NAME(Code)(Java Doc)
final protected static long CACHE_TTY(Code)(Java Doc)
final public static String DELETE(Code)(Java Doc)
final public static String SEARCH(Code)(Java Doc)
final public static int SYSTEM_ACCOUNT(Code)(Java Doc)
final public static String SYSTEM_ACCOUNT_NAME(Code)(Java Doc)
final public static String UPDATE(Code)(Java Doc)

Methods inherited from com.jcorporate.expresso.core.dbobj.SecuredDBObject

public void add() throws DBException(Code)(Java Doc)
public boolean canRequesterAdd() throws DBException(Code)(Java Doc)
public boolean canRequesterDelete() throws DBException(Code)(Java Doc)
public boolean canRequesterRead() throws DBException(Code)(Java Doc)
public boolean canRequesterUpdate() throws DBException(Code)(Java Doc)
public boolean checkAllowed(String requestedFunction) throws DBException(Code)(Java Doc)
public void copyAttributes(DBObject returnObj) throws DBException(Code)(Java Doc)
public synchronized int count() throws com.jcorporate.expresso.core.db.DBException(Code)(Java Doc)
protected synchronized void createSecurityCache() throws CacheException(Code)(Java Doc)
public void delete() throws DBException(Code)(Java Doc)
public synchronized void deleteAll() throws com.jcorporate.expresso.core.db.DBException(Code)(Java Doc)
public boolean find() throws DBException(Code)(Java Doc)
public int getRequestingUid()(Code)(Java Doc)
protected String getString(String stringCode, Object[] args) throws DBException(Code)(Java Doc)
protected String getString(String stringCode) throws DBException(Code)(Java Doc)
protected String getString(String stringCode, String arg1) throws DBException(Code)(Java Doc)
protected String getString(String stringCode, String arg1, String arg2) throws DBException(Code)(Java Doc)
protected String getString(String stringCode, String arg1, String arg2, String arg3) throws DBException(Code)(Java Doc)
protected String getString(String stringCode, String arg1, String arg2, String arg3, String arg4) throws DBException(Code)(Java Doc)
public int getSystemUid()(Code)(Java Doc)
public static SecuredDBObject instantiate(String className) throws DBException(Code)(Java Doc)
public void isAllowed(String requestedFunction) throws SecurityException, DBException(Code)(Java Doc)
public void retrieve() throws DBException(Code)(Java Doc)
public synchronized void search() throws DBException(Code)(Java Doc)
public synchronized ArrayList searchAndRetrieveList() throws DBException(Code)(Java Doc)
public synchronized ArrayList searchAndRetrieveList(String sortKeys) throws DBException(Code)(Java Doc)
public void setRequestingUid(int newUid)(Code)(Java Doc)
public void update() throws DBException(Code)(Java Doc)

www.java2java.com | Contact Us

All other trademarks are property of their respective owners.