batchserver-cvs Mailing List for Enterprise Batch Server (Page 11)
Brought to you by:
suresh_pragada
Menu
▾
▴
batchserver-cvs — List to get the emails from cvs for check-ins.
You can subscribe to this list here.
| 2006 |
Jan
|
Feb
(10) |
Mar
(159) |
Apr
(5) |
May
(52) |
Jun
(70) |
Jul
|
Aug
(28) |
Sep
(256) |
Oct
(38) |
Nov
|
Dec
|
|---|---|---|---|---|---|---|---|---|---|---|---|---|
| 2007 |
Jan
|
Feb
|
Mar
|
Apr
|
May
(3) |
Jun
|
Jul
|
Aug
|
Sep
|
Oct
|
Nov
|
Dec
|
|
From: Suresh <sur...@us...> - 2006-09-12 04:07:58
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/jdbc In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv7494/framework/repository/jdbc Modified Files: JdbcRepository.java Log Message: no message Index: JdbcRepository.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/jdbc/JdbcRepository.java,v retrieving revision 1.1 retrieving revision 1.2 diff -C2 -d -r1.1 -r1.2 *** JdbcRepository.java 10 Sep 2006 17:57:01 -0000 1.1 --- JdbcRepository.java 12 Sep 2006 04:07:55 -0000 1.2 *************** *** 104,108 **** * @see org.jmonks.batchserver.framework.repository.Repository#clearDataTransferredToNextJob(String) */ ! public boolean clearDataTransferredToNextJob(String jobName) { logger.trace("Entering clearDataTransferredToNextJob"); --- 104,108 ---- * @see org.jmonks.batchserver.framework.repository.Repository#clearDataTransferredToNextJob(String) */ ! public boolean clearDataTransferredFromThisJob(String jobName) { logger.trace("Entering clearDataTransferredToNextJob"); *************** *** 132,136 **** logger.error("Exception while trying to clear the data for requested job = " + jobName + ". Message = " + exception.getMessage(), exception); ! dataCleared=true; } finally --- 132,136 ---- logger.error("Exception while trying to clear the data for requested job = " + jobName + ". Message = " + exception.getMessage(), exception); ! dataCleared=false; } finally *************** *** 162,166 **** try { ! PreparedStatement deleteStatement=connection.prepareStatement("delete from job_data_transfer where source_job_name=? and target_job_name=? and job_data_identifier=?"); deleteStatement.setString(1, sourceJobName); deleteStatement.setString(2, targetJobName); --- 162,166 ---- try { ! PreparedStatement deleteStatement=connection.prepareStatement("delete from job_data_transfer where source_job_name=? and destination_job_name=? and job_data_identifier=?"); deleteStatement.setString(1, sourceJobName); deleteStatement.setString(2, targetJobName); *************** *** 170,174 **** logger.debug("Data has been cleared before loading = " + sourceJobName + " " + targetJobName + " " + dataIdentifier); ! PreparedStatement insertStatement=connection.prepareStatement("insert into job_data_transfer (source_job_name,target_job_name,job_data_identifier,job_data) values (?,?,?,?)"); insertStatement.setString(1, sourceJobName); insertStatement.setString(2, targetJobName); --- 170,174 ---- logger.debug("Data has been cleared before loading = " + sourceJobName + " " + targetJobName + " " + dataIdentifier); ! PreparedStatement insertStatement=connection.prepareStatement("insert into job_data_transfer (source_job_name,destination_job_name,job_data_identifier,job_data) values (?,?,?,?)"); insertStatement.setString(1, sourceJobName); insertStatement.setString(2, targetJobName); *************** *** 188,192 **** logger.error("Exception while trying to send the data from " + sourceJobName + " to job = " + targetJobName + " with the identifier " + dataIdentifier + ". Message = " + exception.getMessage(), exception); ! dataSaved=true; } finally --- 188,192 ---- logger.error("Exception while trying to send the data from " + sourceJobName + " to job = " + targetJobName + " with the identifier " + dataIdentifier + ". Message = " + exception.getMessage(), exception); ! dataSaved=false; } finally *************** *** 219,223 **** try { ! PreparedStatement statement=connection.prepareStatement("select job_data from job_data_transfer where source_job_name=? and target_job_name=? and job_data_identifier=?"); statement.setString(1, sourceJobName); statement.setString(2, targetJobName); --- 219,223 ---- try { ! PreparedStatement statement=connection.prepareStatement("select job_data from job_data_transfer where source_job_name=? and destination_job_name=? and job_data_identifier=?"); statement.setString(1, sourceJobName); statement.setString(2, targetJobName); *************** *** 226,230 **** if(rs.next()) { ! InputStream inputStream=rs.getBinaryStream(4); data=getObjectFromByteArray(inputStream); } --- 226,230 ---- if(rs.next()) { ! InputStream inputStream=rs.getBinaryStream(1); data=getObjectFromByteArray(inputStream); } *************** *** 492,496 **** exception.printStackTrace(); logger.error("Exception while trying to register the mgmt mntr info = " + jobName+ ". Message = " + exception.getMessage(), exception); ! registered=true; } finally --- 492,496 ---- exception.printStackTrace(); logger.error("Exception while trying to register the mgmt mntr info = " + jobName+ ". Message = " + exception.getMessage(), exception); ! registered=false; } finally |
|
From: Suresh <sur...@us...> - 2006-09-12 04:07:58
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv7494/framework/repository Modified Files: Repository.java Log Message: no message Index: Repository.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/Repository.java,v retrieving revision 1.5 retrieving revision 1.6 diff -C2 -d -r1.5 -r1.6 *** Repository.java 10 Sep 2006 17:56:35 -0000 1.5 --- Repository.java 12 Sep 2006 04:07:55 -0000 1.6 *************** *** 150,154 **** /** * <p> - * Clears the data that has not been received by the target jobs. * This method will clear all the data that has been put up by * this job. Usually, this will be called by startp of framework, --- 150,153 ---- *************** *** 160,164 **** * @throws IllegalArgumentException If input job name is null. */ ! public abstract boolean clearDataTransferredToNextJob(String jobName); /** --- 159,163 ---- * @throws IllegalArgumentException If input job name is null. */ ! public abstract boolean clearDataTransferredFromThisJob(String jobName); /** |
|
From: Suresh <sur...@us...> - 2006-09-12 04:07:57
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/db4o In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv7494/framework/repository/db4o Modified Files: Db4oRepository.java Log Message: no message Index: Db4oRepository.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/db4o/Db4oRepository.java,v retrieving revision 1.7 retrieving revision 1.8 diff -C2 -d -r1.7 -r1.8 *** Db4oRepository.java 10 Sep 2006 17:57:14 -0000 1.7 --- Db4oRepository.java 12 Sep 2006 04:07:55 -0000 1.8 *************** *** 221,225 **** * @see org.jmonks.batchserver.framework.repository.Repository#clearDataTransferredToNextJob(String) */ ! public boolean clearDataTransferredToNextJob(String jobName) { logger.trace("Entering clearDataTransferredToNextJob"); --- 221,225 ---- * @see org.jmonks.batchserver.framework.repository.Repository#clearDataTransferredToNextJob(String) */ ! public boolean clearDataTransferredFromThisJob(String jobName) { logger.trace("Entering clearDataTransferredToNextJob"); |
|
From: Suresh <sur...@us...> - 2006-09-10 22:24:27
|
Update of /cvsroot/batchserver/batchserver/bin/dbscripts/mysql In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv21657/mysql Log Message: Directory /cvsroot/batchserver/batchserver/bin/dbscripts/mysql added to the repository |
|
From: Suresh <sur...@us...> - 2006-09-10 22:24:11
|
Update of /cvsroot/batchserver/batchserver/lib/jdbc/mysql In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv21286 Added Files: mysql_jdbc_driver_3.1.13.jar Log Message: no message --- NEW FILE: mysql_jdbc_driver_3.1.13.jar --- (This appears to be a binary file; contents omitted.) |
|
From: Suresh <sur...@us...> - 2006-09-10 22:23:37
|
Update of /cvsroot/batchserver/batchserver/lib/jdbc/mysql In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv21253/mysql Log Message: Directory /cvsroot/batchserver/batchserver/lib/jdbc/mysql added to the repository |
|
From: Suresh <sur...@us...> - 2006-09-10 22:19:30
|
Update of /cvsroot/batchserver/batchserver/bin/dbscripts/oracle In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv19635 Added Files: create_job_data_transfer.sql create_job_mgmt_mntr_info.sql create_job_statistics.sql Log Message: no message --- NEW FILE: create_job_mgmt_mntr_info.sql --- -- Create table create table JOB_MGMT_MNTR_INFO ( JOB_NAME VARCHAR2(64) not null, JOB_INFO BLOB not null ); -- Add comments to the columns comment on column JOB_MGMT_MNTR_INFO.JOB_NAME is 'Name of the job.'; comment on column JOB_MGMT_MNTR_INFO.JOB_MGMT_MNTR_INFO is 'Management and monitor information'; -- Create/Recreate primary, unique and foreign key constraints alter table JOB_MGMT_MNTR_INFO add constraint PK_JOB_MGMT_MNTR_INFO primary key (JOB_NAME); --- NEW FILE: create_job_statistics.sql --- -- Create table create table JOB_STATISTICS ( JOB_NAME VARCHAR2(64) not null, JOB_START_TIME DATE not null, JOB_END_TIME DATE not null, JOB_EXIT_CODE NUMBER not null, JOB_EXIT_REASON VARCHAR2(1024), RECORDS_PRCOESSED NUMBER, MEMORY_USAGE NUMBER ); -- Add comments to the columns comment on column JOB_STATISTICS.JOB_NAME is 'Job Name'; comment on column JOB_STATISTICS.JOB_START_TIME is 'Timestamp when job got started.'; comment on column JOB_STATISTICS.JOB_END_TIME is 'Timestamp when job got finished.'; comment on column JOB_STATISTICS.JOB_EXIT_CODE is 'Job exit code.'; comment on column JOB_STATISTICS.JOB_EXIT_REASON is 'Reason in case of job failure'; comment on column JOB_STATISTICS.RECORDS_PRCOESSED is 'Number of records processed.'; comment on column JOB_STATISTICS.MEMORY_USAGE is 'Memory used by the job.'; -- Create/Recreate indexes create index NUIDX_JOB_STATS on JOB_STATISTICS (JOB_NAME); --- NEW FILE: create_job_data_transfer.sql --- -- Create table create table JOB_DATA_TRANSFER ( SOURCE_JOB_NAME VARCHAR2(64) not null, DESTINATION_JOB_NAME VARCHAR2(64) not null, JOB_DATA_IDENTIFIER VARCHAR2(256) not null, JOB_DATA BLOB not null ); -- Add comments to the columns comment on column JOB_DATA_TRANSFER.SOURCE_JOB_NAME is 'Source Job Name'; comment on column JOB_DATA_TRANSFER.DESTINATION_JOB_NAME is 'Destination Job Name'; comment on column JOB_DATA_TRANSFER.JOB_DATA is 'Data to be transferred from source job to destination job.'; comment on column JOB_DATA_TRANSFER.JOB_DATA_IDENTIFIER is 'Identifier used to recognize the data.'; -- Create/Recreate primary, unique and foreign key constraints alter table JOB_DATA_TRANSFER add constraint PK_SRC_DST_JOB_NAME primary key (SOURCE_JOB_NAME,DESTINATION_JOB_NAME,JOB_DATA_IDENTIFIER); |
|
From: Suresh <sur...@us...> - 2006-09-10 22:19:04
|
Update of /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/util In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv19259 Added Files: JdbcConnectionHelperTest.java Log Message: no message --- NEW FILE: JdbcConnectionHelperTest.java --- /* * JdbcConnectionHelperTest.java * JUnit based test * * Created on September 10, 2006, 5:18 PM */ package org.jmonks.batchserver.framework.util; import junit.framework.*; import java.sql.Connection; import java.sql.DriverManager; import java.util.Map; import org.apache.log4j.Logger; /** * * @author Suresh Pragada */ public class JdbcConnectionHelperTest extends TestCase { public JdbcConnectionHelperTest(String testName) { super(testName); } protected void setUp() throws Exception { } protected void tearDown() throws Exception { } public static Test suite() { TestSuite suite = new TestSuite(JdbcConnectionHelperTest.class); return suite; } /** * Test of getConnection method, of class org.jmonks.batchserver.framework.util.JdbcConnectionHelper. */ public void testGetConnection() { System.out.println("testGetConnection"); // TODO add your test code below by replacing the default call to fail. fail("The test case is empty."); } /** * Test of closeConnection method, of class org.jmonks.batchserver.framework.util.JdbcConnectionHelper. */ public void testCloseConnection() { System.out.println("testCloseConnection"); // TODO add your test code below by replacing the default call to fail. fail("The test case is empty."); } } |
|
From: Suresh <sur...@us...> - 2006-09-10 22:17:25
|
Update of /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv18852 Modified Files: RepositoryTest.java Log Message: no message Index: RepositoryTest.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository/RepositoryTest.java,v retrieving revision 1.5 retrieving revision 1.6 diff -C2 -d -r1.5 -r1.6 *** RepositoryTest.java 5 Sep 2006 18:16:32 -0000 1.5 --- RepositoryTest.java 10 Sep 2006 22:17:24 -0000 1.6 *************** *** 195,199 **** public void testJobControllerHolder() { ! Repository repository=Repository.getRepository(); assertNotNull(repository); --- 195,199 ---- public void testJobControllerHolder() { ! /* Repository repository=Repository.getRepository(); assertNotNull(repository); *************** *** 219,223 **** assertNotNull(basicController); released=repository.releaseController(jobName); ! assertTrue(released); } --- 219,223 ---- assertNotNull(basicController); released=repository.releaseController(jobName); ! assertTrue(released); */ } |
|
From: Suresh <sur...@us...> - 2006-09-10 22:17:14
|
Update of /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository/jdbc In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv18838 Modified Files: JdbcRepositoryTest.java Added Files: MySQLJdbcRepository.java Log Message: no message Index: JdbcRepositoryTest.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository/jdbc/JdbcRepositoryTest.java,v retrieving revision 1.1 retrieving revision 1.2 diff -C2 -d -r1.1 -r1.2 *** JdbcRepositoryTest.java 10 Sep 2006 17:58:52 -0000 1.1 --- JdbcRepositoryTest.java 10 Sep 2006 22:17:12 -0000 1.2 *************** *** 9,34 **** import junit.framework.*; ! import java.io.ByteArrayInputStream; ! import java.io.ByteArrayOutputStream; ! import java.io.IOException; ! import java.io.InputStream; ! import java.io.ObjectInputStream; ! import java.io.ObjectOutputStream; ! import java.sql.Connection; ! import java.sql.PreparedStatement; ! import java.sql.ResultSet; ! import java.sql.SQLException; ! import java.sql.Timestamp; ! import java.sql.Types; ! import java.util.ArrayList; ! import java.util.HashMap; ! import java.util.List; ! import java.util.Map; ! import org.apache.log4j.Logger; ! import org.jmonks.batchserver.framework.ErrorCode; ! import org.jmonks.batchserver.framework.JobStatistics; ! import org.jmonks.batchserver.framework.config.ConfigurationException; ! import org.jmonks.batchserver.framework.repository.Repository; ! import org.jmonks.batchserver.framework.util.JdbcConnectionHelper; /** --- 9,14 ---- import junit.framework.*; ! ! /** *************** *** 64,71 **** public void testInit() { ! System.out.println("testInit"); ! ! // TODO add your test code below by replacing the default call to fail. ! fail("The test case is empty."); } --- 44,56 ---- public void testInit() { ! try ! { ! MySQLJdbcRepository repository=new MySQLJdbcRepository(); ! repository.init(repository.getMySQLConfigMap()); ! } ! catch(Exception exception) ! { ! fail("MySQL Jdbc Repository init was failed."); ! } } *************** *** 75,82 **** public void testClearDataTransferredToNextJob() { - System.out.println("testClearDataTransferredToNextJob"); - - // TODO add your test code below by replacing the default call to fail. - fail("The test case is empty."); } --- 60,63 ---- *************** *** 86,93 **** public void testSendDataToNextJob() { - System.out.println("testSendDataToNextJob"); - - // TODO add your test code below by replacing the default call to fail. - fail("The test case is empty."); } --- 67,70 ---- *************** *** 97,104 **** public void testGetDataFromPreviousJob() { - System.out.println("testGetDataFromPreviousJob"); - - // TODO add your test code below by replacing the default call to fail. - fail("The test case is empty."); } --- 74,77 ---- *************** *** 108,115 **** public void testLogStatistics() { - System.out.println("testLogStatistics"); - - // TODO add your test code below by replacing the default call to fail. - fail("The test case is empty."); } --- 81,84 ---- *************** *** 119,126 **** public void testGetStatistics() { - System.out.println("testGetStatistics"); - - // TODO add your test code below by replacing the default call to fail. - fail("The test case is empty."); } --- 88,91 ---- *************** *** 130,137 **** public void testLookupJobMgmtMntrInfo() { - System.out.println("testLookupJobMgmtMntrInfo"); - - // TODO add your test code below by replacing the default call to fail. - fail("The test case is empty."); } --- 95,98 ---- *************** *** 141,148 **** public void testUnregisterJobMgmtMntrInfo() { - System.out.println("testUnregisterJobMgmtMntrInfo"); - - // TODO add your test code below by replacing the default call to fail. - fail("The test case is empty."); } --- 102,105 ---- *************** *** 152,159 **** public void testRegisterJobMgmtMntrInfo() { - System.out.println("testRegisterJobMgmtMntrInfo"); - - // TODO add your test code below by replacing the default call to fail. - fail("The test case is empty."); } --- 109,112 ---- *************** *** 163,170 **** public void testGetAllRegisteredMgmtMntrInfo() { - System.out.println("testGetAllRegisteredMgmtMntrInfo"); - - // TODO add your test code below by replacing the default call to fail. - fail("The test case is empty."); } --- 116,119 ---- --- NEW FILE: MySQLJdbcRepository.java --- /* * MySQLJdbcRepository.java * * Created on September 10, 2006, 5:08 PM * * To change this template, choose Tools | Options and locate the template under * the Source Creation and Management node. Right-click the template and choose * Open. You can then make changes to the template in the Source Editor. */ package org.jmonks.batchserver.framework.repository.jdbc; import java.util.HashMap; import java.util.Map; import org.jmonks.batchserver.framework.util.JdbcConnectionHelper; /** * * @author Suresh Pragada */ public class MySQLJdbcRepository extends JdbcRepository { /** Creates a new instance of MySQLJdbcRepository */ public MySQLJdbcRepository() { } public void init(Map configMap) { super.init(configMap); } public Map getMySQLConfigMap() { Map configMap=new HashMap(); configMap.put(JdbcConnectionHelper.PROPERTY_JDBC_DRIVER_CLASS_NAME, ""); configMap.put(JdbcConnectionHelper.PROPERTY_JDBC_URL, ""); configMap.put(JdbcConnectionHelper.PROPERTY_DATABASE_USER_NAME, ""); configMap.put(JdbcConnectionHelper.PROPERTY_DATABASE_PASSWORD, ""); return configMap; } } |
|
From: Suresh <sur...@us...> - 2006-09-10 17:58:54
|
Update of /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository/jdbc In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv10579 Added Files: JdbcRepositoryTest.java Log Message: no message --- NEW FILE: JdbcRepositoryTest.java --- /* * JdbcRepositoryTest.java * JUnit based test * * Created on September 10, 2006, 12:53 PM */ package org.jmonks.batchserver.framework.repository.jdbc; import junit.framework.*; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Timestamp; import java.sql.Types; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import org.apache.log4j.Logger; import org.jmonks.batchserver.framework.ErrorCode; import org.jmonks.batchserver.framework.JobStatistics; import org.jmonks.batchserver.framework.config.ConfigurationException; import org.jmonks.batchserver.framework.repository.Repository; import org.jmonks.batchserver.framework.util.JdbcConnectionHelper; /** * * @author Suresh Pragada */ public class JdbcRepositoryTest extends TestCase { public JdbcRepositoryTest(String testName) { super(testName); } protected void setUp() throws Exception { } protected void tearDown() throws Exception { } public static Test suite() { TestSuite suite = new TestSuite(JdbcRepositoryTest.class); return suite; } /** * Test of init method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository. */ public void testInit() { System.out.println("testInit"); // TODO add your test code below by replacing the default call to fail. fail("The test case is empty."); } /** * Test of clearDataTransferredToNextJob method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository. */ public void testClearDataTransferredToNextJob() { System.out.println("testClearDataTransferredToNextJob"); // TODO add your test code below by replacing the default call to fail. fail("The test case is empty."); } /** * Test of sendDataToNextJob method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository. */ public void testSendDataToNextJob() { System.out.println("testSendDataToNextJob"); // TODO add your test code below by replacing the default call to fail. fail("The test case is empty."); } /** * Test of getDataFromPreviousJob method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository. */ public void testGetDataFromPreviousJob() { System.out.println("testGetDataFromPreviousJob"); // TODO add your test code below by replacing the default call to fail. fail("The test case is empty."); } /** * Test of logStatistics method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository. */ public void testLogStatistics() { System.out.println("testLogStatistics"); // TODO add your test code below by replacing the default call to fail. fail("The test case is empty."); } /** * Test of getStatistics method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository. */ public void testGetStatistics() { System.out.println("testGetStatistics"); // TODO add your test code below by replacing the default call to fail. fail("The test case is empty."); } /** * Test of lookupJobMgmtMntrInfo method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository. */ public void testLookupJobMgmtMntrInfo() { System.out.println("testLookupJobMgmtMntrInfo"); // TODO add your test code below by replacing the default call to fail. fail("The test case is empty."); } /** * Test of unregisterJobMgmtMntrInfo method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository. */ public void testUnregisterJobMgmtMntrInfo() { System.out.println("testUnregisterJobMgmtMntrInfo"); // TODO add your test code below by replacing the default call to fail. fail("The test case is empty."); } /** * Test of registerJobMgmtMntrInfo method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository. */ public void testRegisterJobMgmtMntrInfo() { System.out.println("testRegisterJobMgmtMntrInfo"); // TODO add your test code below by replacing the default call to fail. fail("The test case is empty."); } /** * Test of getAllRegisteredMgmtMntrInfo method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository. */ public void testGetAllRegisteredMgmtMntrInfo() { System.out.println("testGetAllRegisteredMgmtMntrInfo"); // TODO add your test code below by replacing the default call to fail. fail("The test case is empty."); } } |
|
From: Suresh <sur...@us...> - 2006-09-10 17:58:32
|
Update of /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository/jdbc In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv10535/jdbc Log Message: Directory /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository/jdbc added to the repository |
|
From: Suresh <sur...@us...> - 2006-09-10 17:58:12
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv10342/jmonks/batchserver/framework/config Modified Files: framework-config.xml Log Message: no message Index: framework-config.xml =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/framework-config.xml,v retrieving revision 1.16 retrieving revision 1.17 diff -C2 -d -r1.16 -r1.17 *** framework-config.xml 28 Mar 2006 04:46:51 -0000 1.16 --- framework-config.xml 10 Sep 2006 17:58:07 -0000 1.17 *************** *** 8,15 **** <job-config-factory-config job-config-factory-class-name="org.jmonks.batchserver.framework.config.db.DBJobConfigFactory"> ! <property key="config-db-jdbc-driver-class-name">oracle.jdbc.driver.OracleDriver</property> ! <property key="config-db-url">jdbc:oracle:thin:@hostname:1521:instancename</property> ! <property key="config-db-username">scott</property> ! <property key="config-db-password">tiger</property> </job-config-factory-config> --> --- 8,15 ---- <job-config-factory-config job-config-factory-class-name="org.jmonks.batchserver.framework.config.db.DBJobConfigFactory"> ! <property key="jdbc-driver-class-name">oracle.jdbc.driver.OracleDriver</property> ! <property key="jdbc-url">jdbc:oracle:thin:@hostname:1521:instancename</property> ! <property key="username">scott</property> ! <property key="password">tiger</property> </job-config-factory-config> --> |
|
From: Suresh <sur...@us...> - 2006-09-10 17:58:09
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/db In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv10342/jmonks/batchserver/framework/config/db Modified Files: DBJobConfigFactory.java Log Message: no message Index: DBJobConfigFactory.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/config/db/DBJobConfigFactory.java,v retrieving revision 1.9 retrieving revision 1.10 diff -C2 -d -r1.9 -r1.10 *** DBJobConfigFactory.java 22 Mar 2006 14:20:45 -0000 1.9 --- DBJobConfigFactory.java 10 Sep 2006 17:58:07 -0000 1.10 *************** *** 12,16 **** import java.sql.Connection; - import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; --- 12,15 ---- *************** *** 22,25 **** --- 21,25 ---- import org.jmonks.batchserver.framework.config.JobConfig; import org.jmonks.batchserver.framework.config.JobConfigFactory; + import org.jmonks.batchserver.framework.util.JdbcConnectionHelper; /** *************** *** 33,48 **** * </p> * <p> ! * Following are the four properties, this factory looks in job config properties ! * to connect to the database. If anyone of the property is missing, it throws ! * ConfigurationException. ! * <table> ! * <tr><td><b>property key</b></td><td><b>property value</b></td></tr> ! * <tr><td>config-db-jdbc-driver-class-name</td><td>oracle.jdbc.driver.OracleDriver</td></tr> ! * <tr><td>config-db-url</td><td>jdbc:oracle:thin:@hostname:1521:instname</td></tr> ! * <tr><td>config-db-username</td><td>scott</td></tr> ! * <tr><td>config-db-password</td><td>tiger</td></tr> ! * </table> ! * These properties can be configured using <property> element in the <job-config-factory-config> element ! * in the framework configuration file. * </p> * --- 33,57 ---- * </p> * <p> ! * This factory looks for the properties "jdbc-driver-class-name","jdbc-url", ! * "username" and "password" in job config factory config in framework configuration to ! * establish the connection to read the job configuration. If anyone of the properties ! * are missing, it throws ConfigurationException. Following example shows, how it can ! * be configured. ! * <br><br> ! * <pre> ! * <job-config-factory-config job-config-factory-class-name="org.jmonks.batchserver.framework.config.db.DBJobConfigFactory"> ! * <property key="jdbc-driver-class-name">oracle.jdbc.driver.OracleDriver</property> ! * <property key="jdbc-url">jdbc:oracle:thin:@hostname:1521:instancename</property> ! * <property key="username">scott</property> ! * <property key="password">tiger</property> ! * </job-config-factory-config> ! * </pre> ! * <br>The user specified in the configuration should have read privileges to the following database table objects. ! * <table> ! * <tr><td>JOB_CONFIG</td></tr> ! * <tr><td>JOB_LOGGING_CONFIG</td></tr> ! * <tr><td>BASIC_JOB_CONTROLLER_CONFIG</td></tr> ! * <tr><td>POOL_JOB_CONTROLLER_CONFIG</td></tr> ! * </table> * </p> * *************** *** 58,77 **** private Map configFactoryProps=null; /** - * Constant defines the property name of jdbc driver class name. - */ - private static final String PROPERTY_JOB_CONFIG_JDBC_DRIVER_CLASS_NAME = "config-db-jdbc-driver-class-name"; - /** - * Constant defines the property name of database URL. - */ - private static final String PROPERTY_JOB_CONFIG_DATABASE_URL = "config-db-url"; - /** - * Constant defines the property name of daabase user name. - */ - private static final String PROPERTY_JOB_CONFIG_DATABASE_USER_NAME = "config-db-username"; - /** - * Constant defines the property name of database password. - */ - private static final String PROPERTY_JOB_CONFIG_DATABASE_PASSWORD = "config-db-password"; - /** * SQL Query to pull the job configuration. */ --- 67,70 ---- *************** *** 112,131 **** * and close it to make sure property values are valid. */ ! Connection connection=this.getConnection(); if(connection==null) throw new ConfigurationException(ConfigurationException.JOB_CONFIG_FACTORY_CONFIG, "Unable to establish the database " + "connection with the properties " + this.configFactoryProps +"."); else ! { ! try ! { ! connection.close(); ! } ! catch(SQLException sqle) ! { ! sqle.printStackTrace(); ! logger.error(sqle.getMessage(),sqle); ! } ! } logger.trace("Exiting init"); } --- 105,114 ---- * and close it to make sure property values are valid. */ ! Connection connection=JdbcConnectionHelper.getConnection(this.configFactoryProps); if(connection==null) throw new ConfigurationException(ConfigurationException.JOB_CONFIG_FACTORY_CONFIG, "Unable to establish the database " + "connection with the properties " + this.configFactoryProps +"."); else ! JdbcConnectionHelper.closeConnection(connection); logger.trace("Exiting init"); } *************** *** 150,154 **** throw new IllegalArgumentException("Job name cannot be null."); ! Connection connection=this.getConnection(); if(connection==null) throw new IllegalStateException("DBJobConfigFacotry not initialized properly. Unable to get the connection."); --- 133,137 ---- throw new IllegalArgumentException("Job name cannot be null."); ! Connection connection=JdbcConnectionHelper.getConnection(this.configFactoryProps); if(connection==null) throw new IllegalStateException("DBJobConfigFacotry not initialized properly. Unable to get the connection."); *************** *** 185,231 **** return jobConfig; } - - /** - * Get the required properties from the configFactoryProperties map and - * establishes the connection. Returns null, if it cannot establish the - * connection. - * - * @return Returns the database connction, null, if it cannot establish the connection. - */ - private Connection getConnection() - { - logger.trace("Exiting getConnection"); - logger.info("Connection configuration : " + this.configFactoryProps); - - Connection connection=null; - - String driverClassName=(String)this.configFactoryProps.get(DBJobConfigFactory.PROPERTY_JOB_CONFIG_JDBC_DRIVER_CLASS_NAME); - String databaseURL=(String)this.configFactoryProps.get(DBJobConfigFactory.PROPERTY_JOB_CONFIG_DATABASE_URL); - String userName=(String)this.configFactoryProps.get(DBJobConfigFactory.PROPERTY_JOB_CONFIG_DATABASE_USER_NAME); - String password=(String)this.configFactoryProps.get(DBJobConfigFactory.PROPERTY_JOB_CONFIG_DATABASE_PASSWORD); - - if(driverClassName==null || "".equals(driverClassName) || databaseURL==null || "".equals(databaseURL) || - userName==null || "".equals(userName) || password==null || "".equals(password)) - connection=null; - else - { - try - { - Class.forName(driverClassName); - connection=DriverManager.getConnection(databaseURL,userName, password); - } - /** - * No need to worry about the specific exception. Either case need to return null. - * So catching the generic one. - */ - catch(Exception exception) - { - exception.printStackTrace(); - logger.error(exception.getMessage(), exception); - connection=null; - } - } - logger.trace("Exiting getConnection"); - return connection; - } } --- 168,170 ---- |
|
From: Suresh <sur...@us...> - 2006-09-10 17:58:09
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv10342/jmonks/batchserver/framework/controller/pool Modified Files: PoolJobController.java Log Message: no message Index: PoolJobController.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/PoolJobController.java,v retrieving revision 1.12 retrieving revision 1.13 diff -C2 -d -r1.12 -r1.13 *** PoolJobController.java 29 Aug 2006 02:01:32 -0000 1.12 --- PoolJobController.java 10 Sep 2006 17:58:07 -0000 1.13 *************** *** 399,402 **** --- 399,403 ---- } } + this.jobStatistics.setExitCode(returnCode); logger.trace("Exiting hybernate = " + returnCode); return returnCode; |
|
From: Suresh <sur...@us...> - 2006-09-10 17:58:09
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/basic In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv10342/jmonks/batchserver/framework/controller/basic Modified Files: BasicJobController.java Log Message: no message Index: BasicJobController.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/basic/BasicJobController.java,v retrieving revision 1.12 retrieving revision 1.13 diff -C2 -d -r1.12 -r1.13 *** BasicJobController.java 29 Aug 2006 02:01:32 -0000 1.12 --- BasicJobController.java 10 Sep 2006 17:58:07 -0000 1.13 *************** *** 363,366 **** --- 363,367 ---- } } + this.jobStatistics.setExitCode(returnCode); logger.trace("Exiting hybernate = " + returnCode); return returnCode; |
|
From: Suresh <sur...@us...> - 2006-09-10 17:57:40
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/util In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv10082 Added Files: JdbcConnectionHelper.java Log Message: no message --- NEW FILE: JdbcConnectionHelper.java --- /* * JdbcConnectionHelper.java * * Created on September 9, 2006, 10:57 AM * * To change this template, choose Tools | Options and locate the template under * the Source Creation and Management node. Right-click the template and choose * Open. You can then make changes to the template in the Source Editor. */ package org.jmonks.batchserver.framework.util; import java.sql.Connection; import java.sql.DriverManager; import java.util.Map; import org.apache.log4j.Logger; /** * * @author Suresh Pragada */ public final class JdbcConnectionHelper { /** * Constant defines the property name for jdbc driver class name. The name * should be "jdbc-driver-class-name". */ public static final String PROPERTY_JDBC_DRIVER_CLASS_NAME = "jdbc-driver-class-name"; /** * Constant defines the property name for database URL. The name * should be "jdbc-url". */ public static final String PROPERTY_JDBC_URL = "jdbc-url"; /** * Constant defines the property name for database user name. The name * should be "username". */ public static final String PROPERTY_DATABASE_USER_NAME = "username"; /** * Constant defines the property name for database password. The name * should be "password". */ public static final String PROPERTY_DATABASE_PASSWORD = "password"; private static Logger logger=Logger.getLogger(JdbcConnectionHelper.class); /** * To restrict the instantiation of JdbcConnectionHelper */ private JdbcConnectionHelper() { } /** * Get the required properties from the given configMap and * establishes the connection. Returns null, if it cannot establish the * connection. * * @param configMap Map contains the properties required to create the connection. * * @return Returns the database connction, null, if it cannot establish the connection. */ public static synchronized Connection getConnection(Map configMap) { logger.trace("Entering getConnection"); logger.info("Connection configuration : " + configMap); Connection connection=null; String driverClassName=(String)configMap.get(JdbcConnectionHelper.PROPERTY_JDBC_DRIVER_CLASS_NAME); String databaseURL=(String)configMap.get(JdbcConnectionHelper.PROPERTY_JDBC_URL); String userName=(String)configMap.get(JdbcConnectionHelper.PROPERTY_DATABASE_USER_NAME); String password=(String)configMap.get(JdbcConnectionHelper.PROPERTY_DATABASE_PASSWORD); if(driverClassName==null || "".equals(driverClassName) || databaseURL==null || "".equals(databaseURL) || userName==null || "".equals(userName) || password==null || "".equals(password)) connection=null; else { try { Class.forName(driverClassName); connection=DriverManager.getConnection(databaseURL,userName, password); } catch(Exception exception) { /** * No need to worry about the specific exception. In any case need to return null. * So catching the generic one. */ exception.printStackTrace(); logger.error(exception.getMessage(), exception); connection=null; } } logger.trace("Exiting getConnection"); return connection; } /** * Closes the given connection. Doesn't throw any exceptions to the caller. */ public static void closeConnection(Connection connection) { try { if(connection!=null && !connection.isClosed()) connection.close(); } catch(Exception exception) { exception.printStackTrace(); logger.error(exception.getMessage(),exception); } } } |
|
From: Suresh <sur...@us...> - 2006-09-10 17:57:17
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/db4o In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv10050 Modified Files: Db4oRepository.java Log Message: no message Index: Db4oRepository.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/db4o/Db4oRepository.java,v retrieving revision 1.6 retrieving revision 1.7 diff -C2 -d -r1.6 -r1.7 *** Db4oRepository.java 6 Sep 2006 22:08:05 -0000 1.6 --- Db4oRepository.java 10 Sep 2006 17:57:14 -0000 1.7 *************** *** 431,524 **** } ! /** ! * @see org.jmonks.batchserver.framework.repository.Repository#saveController(String,org.jmonks.batchserver.framework.controller.JobController) ! */ ! public boolean saveController(String jobName, final JobController controller) ! { ! logger.trace("Entering saveController"); ! logger.debug("saveController :: job name = " + jobName + " controller = " + controller); ! if(jobName==null || controller==null) ! throw new IllegalArgumentException("job name and controller cannot be null to save the controller."); ! ! boolean saved=true; ! ! if(container==null) ! saved=false; ! else ! { ! ObjectSet jobControllerHolderResultSet=container.query(new Db4oJobControllerHolderPredicate(jobName)); ! ! while(jobControllerHolderResultSet.hasNext()) ! container.delete(jobControllerHolderResultSet.next()); ! container.commit(); ! ! container.set(new Db4oJobControllerHolder(jobName, controller)); ! container.commit(); ! logger.debug(jobName + " controller has been added to the repository."); ! saved=true; ! } ! logger.trace("Exiting saveController"); ! return saved; ! } ! ! /** ! * @see org.jmonks.batchserver.framework.repository.Repository#loadController(String) ! */ ! public JobController loadController(String jobName) ! { ! logger.trace("Entering loadController"); ! logger.debug(" loadController :: job name = " + jobName); ! ! if(jobName==null) ! throw new IllegalArgumentException("jobName cannot be null to load the controller."); ! ! JobController controller=null; ! if(container==null) ! controller=null; ! else ! { ! ObjectSet jobControllerHolderResultSet=container.query(new Db4oJobControllerHolderPredicate(jobName)); ! if(jobControllerHolderResultSet.hasNext()) ! { ! controller=((Db4oJobControllerHolder)jobControllerHolderResultSet.next()).getJobController(); ! logger.debug(jobName + " controller found and being returned"); ! } ! else ! controller=null; ! } ! logger.trace("Exiting loadController"); ! return controller; ! } ! ! /** ! * @see org.jmonks.batchserver.framework.repository.Repository#releaseController(String) ! */ ! public boolean releaseController(String jobName) ! { ! logger.trace("Entering releaseController"); ! logger.debug(" releaseController :: job name = " + jobName); ! ! if(jobName==null) ! throw new IllegalArgumentException("jobName cannot be null to release the controller."); ! ! boolean released=false; ! ! if(container==null) ! released=false; ! else ! { ! ObjectSet jobControllerHolderResultSet=container.query(new Db4oJobControllerHolderPredicate(jobName)); ! if(jobControllerHolderResultSet.hasNext()) ! { ! container.delete(jobControllerHolderResultSet.next()); ! container.commit(); ! logger.debug(jobName + " controller has been released"); ! released=true; ! } ! else ! released=false; ! } ! logger.trace("Exiting releaseController"); ! return released; ! } } --- 431,524 ---- } ! //////// /** ! //////// * @see org.jmonks.batchserver.framework.repository.Repository#saveController(String,org.jmonks.batchserver.framework.controller.JobController) ! //////// */ ! //////// public boolean saveController(String jobName, final JobController controller) ! //////// { ! //////// logger.trace("Entering saveController"); ! //////// logger.debug("saveController :: job name = " + jobName + " controller = " + controller); ! //////// if(jobName==null || controller==null) ! //////// throw new IllegalArgumentException("job name and controller cannot be null to save the controller."); ! //////// ! //////// boolean saved=true; ! //////// ! //////// if(container==null) ! //////// saved=false; ! //////// else ! //////// { ! //////// ObjectSet jobControllerHolderResultSet=container.query(new Db4oJobControllerHolderPredicate(jobName)); ! //////// ! //////// while(jobControllerHolderResultSet.hasNext()) ! //////// container.delete(jobControllerHolderResultSet.next()); ! //////// container.commit(); ! //////// ! //////// container.set(new Db4oJobControllerHolder(jobName, controller)); ! //////// container.commit(); ! //////// logger.debug(jobName + " controller has been added to the repository."); ! //////// saved=true; ! //////// } ! //////// logger.trace("Exiting saveController"); ! //////// return saved; ! //////// } ! //////// ! //////// /** ! //////// * @see org.jmonks.batchserver.framework.repository.Repository#loadController(String) ! //////// */ ! //////// public JobController loadController(String jobName) ! //////// { ! //////// logger.trace("Entering loadController"); ! //////// logger.debug(" loadController :: job name = " + jobName); ! //////// ! //////// if(jobName==null) ! //////// throw new IllegalArgumentException("jobName cannot be null to load the controller."); ! //////// ! //////// JobController controller=null; ! //////// if(container==null) ! //////// controller=null; ! //////// else ! //////// { ! //////// ObjectSet jobControllerHolderResultSet=container.query(new Db4oJobControllerHolderPredicate(jobName)); ! //////// if(jobControllerHolderResultSet.hasNext()) ! //////// { ! //////// controller=((Db4oJobControllerHolder)jobControllerHolderResultSet.next()).getJobController(); ! //////// logger.debug(jobName + " controller found and being returned"); ! //////// } ! //////// else ! //////// controller=null; ! //////// } ! //////// logger.trace("Exiting loadController"); ! //////// return controller; ! //////// } ! //////// ! //////// /** ! //////// * @see org.jmonks.batchserver.framework.repository.Repository#releaseController(String) ! //////// */ ! //////// public boolean releaseController(String jobName) ! //////// { ! //////// logger.trace("Entering releaseController"); ! //////// logger.debug(" releaseController :: job name = " + jobName); ! //////// ! //////// if(jobName==null) ! //////// throw new IllegalArgumentException("jobName cannot be null to release the controller."); ! //////// ! //////// boolean released=false; ! //////// ! //////// if(container==null) ! //////// released=false; ! //////// else ! //////// { ! //////// ObjectSet jobControllerHolderResultSet=container.query(new Db4oJobControllerHolderPredicate(jobName)); ! //////// if(jobControllerHolderResultSet.hasNext()) ! //////// { ! //////// container.delete(jobControllerHolderResultSet.next()); ! //////// container.commit(); ! //////// logger.debug(jobName + " controller has been released"); ! //////// released=true; ! //////// } ! //////// else ! //////// released=false; ! //////// } ! //////// logger.trace("Exiting releaseController"); ! //////// return released; ! //////// } } |
|
From: Suresh <sur...@us...> - 2006-09-10 17:57:04
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/jdbc In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv9669 Added Files: JdbcRepository.java Log Message: no message --- NEW FILE: JdbcRepository.java --- /* * JdbcRepository.java * * Created on September 9, 2006, 10:34 AM * * To change this template, choose Tools | Options and locate the template under * the Source Creation and Management node. Right-click the template and choose * Open. You can then make changes to the template in the Source Editor. */ package org.jmonks.batchserver.framework.repository.jdbc; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Timestamp; import java.sql.Types; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import org.apache.log4j.Logger; import org.jmonks.batchserver.framework.ErrorCode; import org.jmonks.batchserver.framework.JobStatistics; import org.jmonks.batchserver.framework.config.ConfigurationException; import org.jmonks.batchserver.framework.repository.Repository; import org.jmonks.batchserver.framework.util.JdbcConnectionHelper; /** * <p> * JdbcRepository implementation of repository uses any database that can be accessed by using * the JDBC technology. This looks for the properties "jdbc-driver-class-name","jdbc-url", * "username" and "password" in repository config in framework configuration contains the * values to establish the connection to implement the Repository. * <br> * Following is the example of repository configuration. * <br><br> * <pre> * <repository-config repository-class-name="org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository"> * <property key="jdbc-driver-class-name">oracle.jdbc.driver.OracleDriver</property> * <property key="jdbc-url">jdbc:oracle:thin:@hostname:1521:instancename</property> * <property key="username">scott</property> * <property key="password">tiger</property> * </repository-config> * </pre> * <br><br> * The database user specified in the configuration should have update, insert & delete * privileges on the following objects in the database. * <table> * <tr><td>JOB_DATA_TRANSFER</td></tr> * <tr><td>JOB_STATISTICS</td></tr> * <tr><td>JOB_MGMT_MNTR_INFO</td></tr> * </table> * </p> * * @author Suresh Pragada * @version 1.0 * @since 1.0 */ public class JdbcRepository extends Repository { /** * Map holds the jdbc configuration. */ protected Map jdbcConfigMap=null; private static Logger logger=Logger.getLogger(JdbcRepository.class); /** * <p> * Receives the jdbc configuration in a map from the factory method and * validates the given configuration is valid by making a connection to the database. * </p> * * @param configProps Map contains the jdbc configuration. * * @throws ConfigurationException If not able to get the connection by using the properties * given in the map. */ protected void init(Map configProps) { logger.trace("Entering init"); this.jdbcConfigMap=new HashMap(configProps); /** * Do the basic validation to make sure we can get a connection using the given configuration. */ Connection connection=JdbcConnectionHelper.getConnection(this.jdbcConfigMap); if(connection==null) throw new ConfigurationException(ConfigurationException.REPOSITORY_CONFIG, "Unable to get the jdbc " + "connection with the properties " + this.jdbcConfigMap +"."); else JdbcConnectionHelper.closeConnection(connection); logger.trace("Exiting init"); } /** * @see org.jmonks.batchserver.framework.repository.Repository#clearDataTransferredToNextJob(String) */ public boolean clearDataTransferredToNextJob(String jobName) { logger.trace("Entering clearDataTransferredToNextJob"); logger.debug("clearDataTransferredToNextJob :: job name = " + jobName); if(jobName==null) throw new IllegalArgumentException("job name cannot be null."); boolean dataCleared=false; Connection connection=JdbcConnectionHelper.getConnection(this.jdbcConfigMap); if(connection==null) dataCleared=false; else { try { PreparedStatement statement=connection.prepareStatement("delete from job_data_transfer where source_job_name=?"); statement.setString(1, jobName); statement.executeUpdate(); statement.close(); connection.commit(); dataCleared=true; } catch(SQLException exception) { exception.printStackTrace(); logger.error("Exception while trying to clear the data for requested job = " + jobName + ". Message = " + exception.getMessage(), exception); dataCleared=true; } finally { JdbcConnectionHelper.closeConnection(connection); } } logger.trace("Exiting clearDataTransferredToNextJob"); return dataCleared; } /** * @see org.jmonks.batchserver.framework.repository Repository#sendDataToNextJob(String,String,String,Object) */ public boolean sendDataToNextJob(String dataIdentifier, String sourceJobName, String targetJobName, Object data) { logger.trace("Entering sendDataToNextJob);"); logger.debug("data identifier = " + dataIdentifier + " source job name = " + sourceJobName + " target job name = " + targetJobName + " data = " + data); if(dataIdentifier==null || sourceJobName==null || targetJobName==null || data==null) throw new IllegalArgumentException("No arguments cannot be null to the sendDataToNextJob method."); boolean dataSaved=false; Connection connection=JdbcConnectionHelper.getConnection(this.jdbcConfigMap); if(connection==null) dataSaved=false; else { try { PreparedStatement deleteStatement=connection.prepareStatement("delete from job_data_transfer where source_job_name=? and target_job_name=? and job_data_identifier=?"); deleteStatement.setString(1, sourceJobName); deleteStatement.setString(2, targetJobName); deleteStatement.setString(3, dataIdentifier); deleteStatement.executeUpdate(); deleteStatement.close(); logger.debug("Data has been cleared before loading = " + sourceJobName + " " + targetJobName + " " + dataIdentifier); PreparedStatement insertStatement=connection.prepareStatement("insert into job_data_transfer (source_job_name,target_job_name,job_data_identifier,job_data) values (?,?,?,?)"); insertStatement.setString(1, sourceJobName); insertStatement.setString(2, targetJobName); insertStatement.setString(3, dataIdentifier); byte[] objectByteArray=this.getByteArrayFromObject(data); insertStatement.setBinaryStream(4, new ByteArrayInputStream(objectByteArray), objectByteArray.length); insertStatement.executeUpdate(); insertStatement.close(); logger.debug("Data has been loaded = " + sourceJobName + " " + targetJobName + " " + dataIdentifier); connection.commit(); dataSaved=true; } catch(SQLException exception) { exception.printStackTrace(); logger.error("Exception while trying to send the data from " + sourceJobName + " to job = " + targetJobName + " with the identifier " + dataIdentifier + ". Message = " + exception.getMessage(), exception); dataSaved=true; } finally { JdbcConnectionHelper.closeConnection(connection); } } logger.trace("Exiting sendDataToNextJob"); return dataSaved; } /** * @see org.jmonks.batchserver.framework.repository.Repository#getDataFromPreviousJob(String,String,String) */ public Object getDataFromPreviousJob(String dataIdentifier, String sourceJobName, String targetJobName) { logger.trace("Entering getDataFromPreviousJob"); logger.debug("data identifier = " + dataIdentifier + " source job name = " + sourceJobName + " target job name = " + targetJobName); if(dataIdentifier==null || sourceJobName==null || targetJobName==null) throw new IllegalArgumentException("Data identifer, source job name and target job name cannot be null " + "to get the data from previous job."); Object data=null; Connection connection=JdbcConnectionHelper.getConnection(this.jdbcConfigMap); if(connection==null) data=null; else { try { PreparedStatement statement=connection.prepareStatement("select job_data from job_data_transfer where source_job_name=? and target_job_name=? and job_data_identifier=?"); statement.setString(1, sourceJobName); statement.setString(2, targetJobName); statement.setString(3, dataIdentifier); ResultSet rs=statement.executeQuery(); if(rs.next()) { InputStream inputStream=rs.getBinaryStream(4); data=getObjectFromByteArray(inputStream); } else data=null; rs.close(); statement.close(); } catch(SQLException exception) { exception.printStackTrace(); logger.error("Exception while trying to send the data from " + sourceJobName + " to job = " + targetJobName + " with the identifier " + dataIdentifier + ". Message = " + exception.getMessage(), exception); data=null; } finally { JdbcConnectionHelper.closeConnection(connection); } } logger.trace("Exiting getDataFromPreviousJob"); return data; } /** * * @see org.jmonks.batchserver.framework.repository.Repository#logStatistics(org.jmonks.batchserver.framework.JobStatistics) */ public boolean logStatistics(final JobStatistics statistics) { logger.trace("Entering logStatistics"); if(statistics==null) throw new IllegalArgumentException("Null statistic objects will not be saved in repository"); logger.debug("Logging = " + statistics.toString()); boolean logged=false; Connection connection=JdbcConnectionHelper.getConnection(this.jdbcConfigMap); if(connection==null) logged=false; else { try { PreparedStatement statement=connection.prepareStatement("insert into job_statistics (job_name,job_start_time,job_end_time," + "job_exit_code,job_exit_reason,records_processed,memory_usage) values(?,?,?,?,?,?,?)"); statement.setString(1, statistics.getJobname()); statement.setTimestamp(2, new Timestamp(statistics.getStartTime().getTime())); statement.setTimestamp(3, new Timestamp(statistics.getEndTime().getTime())); statement.setInt(4, statistics.getExitCode().getCode()); if(statistics.getExitCode().getMessage()!=null) statement.setString(5, statistics.getExitCode().getMessage()); else statement.setNull(5,Types.VARCHAR); statement.setInt(6, statistics.getRecordsProcessed()); statement.setInt(7, statistics.getMaxMemoryUsage()); statement.executeUpdate(); statement.close(); connection.commit(); logged=true; } catch(SQLException exception) { exception.printStackTrace(); logger.error("Exception while logging the job statistics = " + statistics.toString() + ". Message = " + exception.getMessage(), exception); logged=false; } finally { JdbcConnectionHelper.closeConnection(connection); } } logger.trace("Exiting logStatistics"); return logged; } /** * @see org.jmonks.batchserver.framework.repository.Repository#getStatistics(String) */ public JobStatistics[] getStatistics(String jobName) { logger.trace("Entering getStatistics"); logger.debug("getStatistics :: job name = " + jobName); if(jobName==null) throw new IllegalArgumentException("job name cannot be null for querying the job statistics."); JobStatistics[] statistics=null; List jobStatisticsList=null; Connection connection=JdbcConnectionHelper.getConnection(this.jdbcConfigMap); if(connection==null) statistics=new JobStatistics[]{}; else { try { PreparedStatement statement=connection.prepareStatement("select job_start_time,job_end_time,job_exit_code,job_exit_reason,records_processed,memory_usage from job_statistics where job_name=?"); statement.setString(1, jobName); ResultSet rs=statement.executeQuery(); jobStatisticsList=new ArrayList(); while(rs.next()) { JobStatistics statistic=new JobStatistics(jobName); statistic.setStartTime(new java.util.Date(rs.getTimestamp(1).getTime())); statistic.setEndTime(new java.util.Date(rs.getTimestamp(2).getTime())); int exitCode=rs.getInt(3); String exitReason=rs.getString(4); ErrorCode errorCode=ErrorCode.createErrorCode(exitCode, exitReason==null?"":exitReason); statistic.setExitCode(errorCode); statistic.setRecordsProcessed(rs.getInt(5)); statistic.setMaxMemeoryUsage(rs.getInt(6)); jobStatisticsList.add(statistic); } rs.close(); statement.close(); } catch(SQLException exception) { exception.printStackTrace(); logger.error("Exception while trying to get the job statistics for the job = " + jobName + ". Message = " + exception.getMessage(), exception); } finally { JdbcConnectionHelper.closeConnection(connection); if(jobStatisticsList!=null) statistics=(JobStatistics[])jobStatisticsList.toArray(); else statistics=new JobStatistics[]{}; } } logger.trace("Exiting getStatistics"); return statistics; } /** * @see org.jmonks.batchserver.framework.repository.Repository#lookupJobMgmtMntrInfo(String) */ public Object lookupJobMgmtMntrInfo(String jobName) { logger.trace("Entering lookupJobMgmtMntrInfo"); logger.debug("lookupJobMgmtMntrInfo :: job name = " + jobName); if(jobName==null) throw new IllegalArgumentException("jobName cannot be null to lookup the mgmt and mntr information."); Object registredInfo=null; Connection connection=JdbcConnectionHelper.getConnection(this.jdbcConfigMap); if(connection==null) registredInfo=null; else { try { PreparedStatement statement=connection.prepareStatement("select job_info from job_mgmt_mntr_info where job_name=?"); statement.setString(1, jobName); ResultSet rs=statement.executeQuery(); if(rs.next()) { InputStream inputStream=rs.getBinaryStream(1); registredInfo=getObjectFromByteArray(inputStream); } else registredInfo=null; rs.close(); statement.close(); } catch(SQLException exception) { exception.printStackTrace(); logger.error("Exception while trying to lookup mgmt and mntr info = " + jobName); registredInfo=null; } finally { JdbcConnectionHelper.closeConnection(connection); } } logger.trace("Exiting lookupJobMgmtMntrInfo"); return registredInfo; } /** * @see org.jmonks.batchserver.framework.repository.Repository#unregisterJobMgmtMntrInfo(String) */ public boolean unregisterJobMgmtMntrInfo(String jobName) { logger.trace("Entering unregisterJobMgmtMntrInfo"); logger.debug("unregisterJobMgmtMntrInfo :: job name = " + jobName); if(jobName==null) throw new IllegalArgumentException("jobName cannot be null to unregister the mgmt and mntr information."); boolean unregistered=false; Connection connection=JdbcConnectionHelper.getConnection(this.jdbcConfigMap); if(connection==null) unregistered=false; else { try { PreparedStatement statement=connection.prepareStatement("delete from job_mgmt_mntr_info where job_name=?"); statement.setString(1, jobName); statement.executeUpdate(); statement.close(); connection.commit(); unregistered=true; } catch(SQLException exception) { exception.printStackTrace(); logger.error("Exception while trying to lookup mgmt and mntr info = " + jobName); unregistered=false; } finally { JdbcConnectionHelper.closeConnection(connection); } } logger.trace("Exiting unregisterJobMgmtMntrInfo"); return unregistered; } /** * @see org.jmonks.batchserver.framework.repository.Repository#registerJobMgmtMntrInfo(String,Object) */ public boolean registerJobMgmtMntrInfo(String jobName, Object registrationInfo) { logger.trace("Entering registerJobMgmtMntrInfo"); logger.debug("job name = " + jobName + " registratinfo = " + registrationInfo); if(jobName==null) throw new IllegalArgumentException("Job name cannot be null to register the job in repository."); if(registrationInfo==null) throw new IllegalArgumentException("Job registration information cannot be null to register the job in repository."); boolean registered=true; Connection connection=JdbcConnectionHelper.getConnection(this.jdbcConfigMap); if(connection==null) registered=false; else { try { PreparedStatement deleteStatement=connection.prepareStatement("delete from job_mgmt_mntr_info where job_name=?"); deleteStatement.setString(1, jobName); deleteStatement.executeUpdate(); deleteStatement.close(); logger.debug("Cleared the existing registration info = " + jobName); PreparedStatement insertStatement=connection.prepareStatement("insert into job_mgmt_mntr_info (job_name,job_info) values (?,?)"); insertStatement.setString(1, jobName); byte[] objectByteArray=this.getByteArrayFromObject(registrationInfo); insertStatement.setBinaryStream(2, new ByteArrayInputStream(objectByteArray), objectByteArray.length); insertStatement.executeUpdate(); insertStatement.close(); logger.debug("Registered mgmt mntr info = " + jobName); connection.commit(); registered=true; } catch(SQLException exception) { exception.printStackTrace(); logger.error("Exception while trying to register the mgmt mntr info = " + jobName+ ". Message = " + exception.getMessage(), exception); registered=true; } finally { JdbcConnectionHelper.closeConnection(connection); } } logger.trace("Exiting registerJobMgmtMntrInfo"); return registered; } /** * @see org.jmonks.batchserver.framework.repository.Repository#getAllRegisteredMgmtMntrInfo() */ public Map getAllRegisteredMgmtMntrInfo() { logger.trace("Entering getAllRegisteredMgmtMntrInfo"); Map registeredJobs=null; Connection connection=JdbcConnectionHelper.getConnection(this.jdbcConfigMap); if(connection==null) registeredJobs=new HashMap(); else { try { PreparedStatement statement=connection.prepareStatement("select job_name, job_info from job_mgmt_mntr_info"); ResultSet rs=statement.executeQuery(); registeredJobs=new HashMap(); while(rs.next()) { String jobName=rs.getString(1); InputStream inputStream=rs.getBinaryStream(2); Object registredInfo=getObjectFromByteArray(inputStream); registeredJobs.put(jobName, registredInfo); } rs.close(); statement.close(); } catch(SQLException exception) { exception.printStackTrace(); logger.error("Exception while trying to get all the registered jobs"); registeredJobs=new HashMap(); } finally { JdbcConnectionHelper.closeConnection(connection); } } logger.trace("Exiting getAllRegisteredMgmtMntrInfo"); return registeredJobs; } private byte[] getByteArrayFromObject(Object object) { try { ByteArrayOutputStream bos=new ByteArrayOutputStream(); ObjectOutputStream oos=new ObjectOutputStream(bos); oos.writeObject(object); oos.close(); bos.flush(); bos.close(); return bos.toByteArray(); } catch(IOException exception) { exception.printStackTrace(); logger.error("Error while serializing the object. Message = " + exception.getMessage(), exception); return null; } } private Object getObjectFromByteArray(InputStream inputStream) { try { ObjectInputStream ois=new ObjectInputStream(inputStream); Object data=ois.readObject(); ois.close(); return data; } catch(ClassNotFoundException exception) { exception.printStackTrace(); logger.error("Error while deserializing the object. Message = " + exception.getMessage(), exception); return null; } catch(IOException exception) { exception.printStackTrace(); logger.error("Error while deserializing the object. Message = " + exception.getMessage(), exception); return null; } } //////// Need to be implemented in the future. //////// public boolean releaseController(String jobName) //////// { //////// return false; //////// } //////// //////// public boolean saveController(String jobName, JobController controller) //////// { //////// return false; //////// } //////// //////// public JobController loadController(String jobName) //////// { //////// return null; //////// } } |
|
From: Suresh <sur...@us...> - 2006-09-10 17:56:38
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv9630 Modified Files: Repository.java Log Message: no message Index: Repository.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/Repository.java,v retrieving revision 1.4 retrieving revision 1.5 diff -C2 -d -r1.4 -r1.5 *** Repository.java 28 Mar 2006 04:56:24 -0000 1.4 --- Repository.java 10 Sep 2006 17:56:35 -0000 1.5 *************** *** 145,149 **** * @throws IllegalArgumentException If any one of the input values is null. */ ! public abstract Object getDataFromPreviousJob(String dataIdentifer, String sourceJobName, String targetJobName); --- 145,149 ---- * @throws IllegalArgumentException If any one of the input values is null. */ ! public abstract Object getDataFromPreviousJob(String dataIdentifier, String sourceJobName, String targetJobName); *************** *** 234,279 **** public abstract JobStatistics[] getStatistics(String jobName); ! /** ! * <p> ! * Persist the controller in repository with the given job name. ! * If there are any controller entries with this job name, it removes them ! * first and then saves this controller. This will be useful, when job wants to be restarted. ! * When controller receives stop signal from servier with restart flag, it persist itself into ! * the repository. ! * </p> ! * ! * @param jobName Name of the job ! * @param controller Controller object to be persisted. ! * ! * @return Returns true, if it could persist the controller, false, otherwise. ! * ! * @throws IllegalArgumentException If input arguments job name or controller is null. ! */ ! public abstract boolean saveController(String jobName, final JobController controller); ! ! /** ! * <p> ! * Loads the controller assosicated with this job name in the repsoitory. When controller starts ! * execution, always, it looks into the reposiotry for restart. This can be overriden by passing addition ! * configuration property. ! * </p> ! * ! * @param jobName Name of the job. ! * ! * @return Returns the controller object, null, if it couldnt find any. ! * ! * @throws IllegalArgumentException If input arguments job name is null. ! */ ! public abstract JobController loadController(String jobName); ! ! /** ! * Releases the persistedcontroller object from repository. ! * ! * @param jobName Name of the job. ! * ! * @return Returns true, if it could release the controller from repository, null, otherwise. ! * ! * @throws IllegalArgumentException If input arguments job name is null. ! */ ! public abstract boolean releaseController(String jobName); } --- 234,280 ---- public abstract JobStatistics[] getStatistics(String jobName); ! //////// Following APIs are for future use. ! //////// /** ! //////// * <p> ! //////// * Persist the controller in repository with the given job name. ! //////// * If there are any controller entries with this job name, it removes them ! //////// * first and then saves this controller. This will be useful, when job wants to be restarted. ! //////// * When controller receives stop signal from servier with restart flag, it persist itself into ! //////// * the repository. ! //////// * </p> ! //////// * ! //////// * @param jobName Name of the job ! //////// * @param controller Controller object to be persisted. ! //////// * ! //////// * @return Returns true, if it could persist the controller, false, otherwise. ! //////// * ! //////// * @throws IllegalArgumentException If input arguments job name or controller is null. ! //////// */ ! //////// public abstract boolean saveController(String jobName, final JobController controller); ! //////// ! //////// /** ! //////// * <p> ! //////// * Loads the controller assosicated with this job name in the repsoitory. When controller starts ! //////// * execution, always, it looks into the reposiotry for restart. This can be overriden by passing addition ! //////// * configuration property. ! //////// * </p> ! //////// * ! //////// * @param jobName Name of the job. ! //////// * ! //////// * @return Returns the controller object, null, if it couldnt find any. ! //////// * ! //////// * @throws IllegalArgumentException If input arguments job name is null. ! //////// */ ! //////// public abstract JobController loadController(String jobName); ! //////// ! //////// /** ! //////// * Releases the persistedcontroller object from repository. ! //////// * ! //////// * @param jobName Name of the job. ! //////// * ! //////// * @return Returns true, if it could release the controller from repository, null, otherwise. ! //////// * ! //////// * @throws IllegalArgumentException If input arguments job name is null. ! //////// */ ! //////// public abstract boolean releaseController(String jobName); } |
|
From: Suresh <sur...@us...> - 2006-09-10 17:56:29
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/jdbc In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv9616/jdbc Log Message: Directory /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/repository/jdbc added to the repository |
|
From: Suresh <sur...@us...> - 2006-09-10 17:56:20
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv9584 Modified Files: ErrorCode.java JobStatistics.java Log Message: no message Index: ErrorCode.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/ErrorCode.java,v retrieving revision 1.2 retrieving revision 1.3 diff -C2 -d -r1.2 -r1.3 *** ErrorCode.java 6 Sep 2006 22:07:22 -0000 1.2 --- ErrorCode.java 10 Sep 2006 17:56:13 -0000 1.3 *************** *** 82,89 **** * @param newMessage Mesage to be used to construct the ErrorCode. * ! * @throws java.lang.IllegalArgumentException If given code is not greater than 9999. */ public static ErrorCode createErrorCode(int newCode, String newMessage) { if(newCode>ErrorCode.FRAMEWORK_MAX_ERROR_CODE) return new ErrorCode(newCode,newMessage); --- 82,92 ---- * @param newMessage Mesage to be used to construct the ErrorCode. * ! * @throws java.lang.IllegalArgumentException If given code is not greater than 9999 or newMessage is null. */ public static ErrorCode createErrorCode(int newCode, String newMessage) { + if(newMessage==null) + throw new IllegalArgumentException("Message to create new ErrorCode should not be null."); + if(newCode>ErrorCode.FRAMEWORK_MAX_ERROR_CODE) return new ErrorCode(newCode,newMessage); Index: JobStatistics.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/JobStatistics.java,v retrieving revision 1.4 retrieving revision 1.5 diff -C2 -d -r1.4 -r1.5 *** JobStatistics.java 16 Mar 2006 05:56:31 -0000 1.4 --- JobStatistics.java 10 Sep 2006 17:56:13 -0000 1.5 *************** *** 32,35 **** --- 32,39 ---- */ private String jobName; + /** + * Exit code of the job. + */ + private ErrorCode exitCode=null; /** *************** *** 43,46 **** --- 47,51 ---- this.maxMemoryUsage=0; this.recordsProcessed=0; + this.exitCode=ErrorCode.JOB_COMPLETED_SUCCESSFULLY; } *************** *** 134,137 **** --- 139,160 ---- return this.jobName; } + + /** + * Sets the given error code as exit code. + * + * @param exitCode Error code controller is going to return to the framework. + */ + public void setExitCode(ErrorCode exitCode) + { + this.exitCode=exitCode; + } + + /** + * Gets the exit code. + */ + public ErrorCode getExitCode() + { + return this.exitCode; + } /** *************** *** 151,154 **** --- 174,178 ---- stringValue.append("[maxMemoryUsage = " + this.maxMemoryUsage + "]"); stringValue.append("[recordsProcessed = " + this.recordsProcessed + "]"); + stringValue.append("[exitCode = " + this.exitCode.toString() + "]"); stringValue.append("}"); return stringValue.toString(); |
|
From: Suresh <sur...@us...> - 2006-09-07 03:06:40
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv4490 Removed Files: JobContext.java Log Message: no message --- JobContext.java DELETED --- |
|
From: Suresh <sur...@us...> - 2006-09-07 03:06:19
|
Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/management/jmxmp In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv4473 Modified Files: RepositoryJMXMPConnectorHelper.java Log Message: no message Index: RepositoryJMXMPConnectorHelper.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/management/jmxmp/RepositoryJMXMPConnectorHelper.java,v retrieving revision 1.2 retrieving revision 1.3 diff -C2 -d -r1.2 -r1.3 *** RepositoryJMXMPConnectorHelper.java 6 Sep 2006 22:07:53 -0000 1.2 --- RepositoryJMXMPConnectorHelper.java 7 Sep 2006 03:06:17 -0000 1.3 *************** *** 9,13 **** import javax.management.remote.JMXServiceURL; import org.apache.log4j.Logger; ! import org.jmonks.batchserver.framework.JobContext; /** --- 9,13 ---- import javax.management.remote.JMXServiceURL; import org.apache.log4j.Logger; ! import org.jmonks.batchserver.framework.repository.Repository; /** *************** *** 61,65 **** JMXServiceURL jmxServiceURL=jmxConnectorServer.getAddress(); ! boolean registered=JobContext.getReposiotry().registerJobMgmtMntrInfo(jobName, jmxServiceURL.toString()); logger.info(jobName + " with the service url " + jmxServiceURL.toString() + " registered in repository = " + registered); --- 61,65 ---- JMXServiceURL jmxServiceURL=jmxConnectorServer.getAddress(); ! boolean registered=Repository.getRepository().registerJobMgmtMntrInfo(jobName, jmxServiceURL.toString()); logger.info(jobName + " with the service url " + jmxServiceURL.toString() + " registered in repository = " + registered); *************** *** 85,89 **** throw new IllegalArgumentException("job name cannot be null to unregister the service url."); ! boolean unregistered=JobContext.getReposiotry().unregisterJobMgmtMntrInfo(jobName); logger.debug(jobName + " mgmt and mntr information unregistered = " + unregistered); --- 85,89 ---- throw new IllegalArgumentException("job name cannot be null to unregister the service url."); ! boolean unregistered=Repository.getRepository().unregisterJobMgmtMntrInfo(jobName); logger.debug(jobName + " mgmt and mntr information unregistered = " + unregistered); *************** *** 99,103 **** public List getRegisteredJobList() { ! return (List)JobContext.getReposiotry().getAllRegisteredMgmtMntrInfo().keySet(); } --- 99,103 ---- public List getRegisteredJobList() { ! return (List)Repository.getRepository().getAllRegisteredMgmtMntrInfo().keySet(); } *************** *** 115,119 **** throw new IllegalArgumentException("job name cannot be null to create the connector."); ! String serviceURL=(String)JobContext.getReposiotry().lookupJobMgmtMntrInfo(jobName); JMXConnector jmxConnector=null; if(serviceURL==null) --- 115,119 ---- throw new IllegalArgumentException("job name cannot be null to create the connector."); ! String serviceURL=(String)Repository.getRepository().lookupJobMgmtMntrInfo(jobName); JMXConnector jmxConnector=null; if(serviceURL==null) |
|
From: Suresh <sur...@us...> - 2006-09-06 22:09:42
|
Update of /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/io/xml In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv14422 Modified Files: XMLFileWriterTest.java Log Message: no message Index: XMLFileWriterTest.java =================================================================== RCS file: /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/io/xml/XMLFileWriterTest.java,v retrieving revision 1.5 retrieving revision 1.6 diff -C2 -d -r1.5 -r1.6 *** XMLFileWriterTest.java 3 Sep 2006 16:53:51 -0000 1.5 --- XMLFileWriterTest.java 6 Sep 2006 22:09:39 -0000 1.6 *************** *** 39,43 **** { TestSuite suite = new TestSuite(XMLFileWriterTest.class); - return suite; } --- 39,42 ---- |
