Coverage Report

Coverage Report - org.kuali.rice.kew.batch.XmlPollerServiceImpl

Classes in this File

Line Coverage

Branch Coverage

Complexity

XmlPollerServiceImpl

0/123

0/56

3.105

 /*
  * Copyright 2005-2007 The Kuali Foundation
  * 
  * 
  * Licensed under the Educational Community License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  * 
  * http://www.opensource.org/licenses/ecl2.php
  * 
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 package org.kuali.rice.kew.batch;
 
 import java.io.BufferedReader;
 import java.io.File;
 import java.io.FileReader;
 import java.io.FileWriter;
 import java.io.IOException;
 import java.text.Format;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Calendar;
 import java.util.Collection;
 import java.util.Date;
 import java.util.Iterator;
 import java.util.List;
 
 import org.kuali.rice.core.api.CoreApiServiceLocator;
 import org.kuali.rice.core.api.impex.xml.DirectoryXmlDocCollection;
 import org.kuali.rice.core.api.impex.xml.FileXmlDocCollection;
 import org.kuali.rice.core.api.impex.xml.XmlDocCollection;
 import org.kuali.rice.core.api.impex.xml.XmlIngesterService;
 import org.kuali.rice.core.api.impex.xml.ZipXmlDocCollection;
 
 
 /**
  * Utility class responsible for polling and ingesting XML data files
  * containing various forms of workflow engine data (e.g. document types
  * and rules).
  * Loaded files and problem files are placed into a subdirectory of a
  * configured 'loaded' and 'problem' directory, respectively.
  * "Problem-ness" is determined by inspecting a 'processed' flag on each <code>XmlDoc</code>
  * in each collection.  If not all <code>XmlDoc</code>s are marked 'processed' an
  * error is assumed, and the collection file (e.g. for a Zip, the Zip file) is moved
  * to the 'problem' directory.
  * As such, it is the <b><code>XmlIngesterService</code>'s responsibility</b> to mark
  * any unknown or otherwise innocuous non-failure non-processed files, as 'processed'.
  * A different mechanism can be developed if this proves to be a problem, but for now
  * it is simple enough for the <code>XmlIngesterService</code> to determine this.
  * @see org.kuali.rice.kew.batch.XmlPollerService
  * @see org.kuali.rice.kew.batch.XmlIngesterServiceImpl
  * @author Kuali Rice Team (rice.collab@kuali.org)
  */
 public class XmlPollerServiceImpl implements XmlPollerService {
 
     private static final org.apache.log4j.Logger LOG = org.apache.log4j.Logger
             .getLogger(XmlPollerServiceImpl.class);
     private static final Format DIR_FORMAT = new SimpleDateFormat("yyyy-MM-dd_HH-mm-ss-SSS");
 
     /**
      * Specifies the polling interval that should be used with this task.
      */
     private int pollIntervalSecs = 5 * 60; // default to 5 minutes
     /**
      * Specifies the initial delay the poller should wait before starting to poll
      */
     private int initialDelaySecs = 30; // default to 30 seconds
     /**
      * Location in which to find XML files to load.
      */
     private String xmlPendingLocation;
     /**
      * Location in which to place successfully loaded XML files.
      */
     private String xmlCompletedLocation;
     /**
      * Location in which to place XML files which have failed to load.
      */
     private String xmlProblemLocation;
     
     private String xmlParentDirectory;
     private static final String PENDING_MOVE_FAILED_ARCHIVE_FILE = "movesfailed";
     private static final String NEW_LINE = "\n";
 
     public void run() {
         // if(!directoriesWritable()){
         //     LOG.error("Error writing to xml data directories. Stopping xmlLoader ...");
         //     this.cancel();
         // }
         LOG.debug("checking for xml data files...");
         File[] files = getXmlPendingDir().listFiles();
         if (files == null || files.length == 0) {
                 return;
         }
         LOG.info("Found " + files.length + " files to ingest.");
         List<XmlDocCollection> collections = new ArrayList<XmlDocCollection>();
         for (File file : files)
         {
             if (file.isDirectory())
             {
                 collections.add(new DirectoryXmlDocCollection(file));
             } else if (file.getName().equals(PENDING_MOVE_FAILED_ARCHIVE_FILE))
             {
                 // the movesfailed file...ignore this
                 continue;
             } else if (file.getName().toLowerCase().endsWith(".zip"))
             {
                 try
                 {
                     collections.add(new ZipXmlDocCollection(file));
                 } catch (IOException ioe)
                 {
                     LOG.error("Unable to load file: " + file);
                 }
             } else if (file.getName().endsWith(".xml"))
             {
                 collections.add(new FileXmlDocCollection(file));
             } else
             {
                 LOG.warn("Ignoring extraneous file in xml pending directory: " + file);
             }
         }
 
         // Cull any resources which were already processed and whose moves failed
         Iterator collectionsIt = collections.iterator();
         Collection<XmlDocCollection> culled = new ArrayList<XmlDocCollection>();
         while (collectionsIt.hasNext()) {
             XmlDocCollection container = (XmlDocCollection) collectionsIt.next();
             // if a move has already failed for this archive, ignore it
             if (inPendingMoveFailedArchive(container.getFile())) {
                 LOG.info("Ignoring previously processed resource: " + container);
                 culled.add(container);
             }
         }
         collections.removeAll(culled);
 
         if (collections.size() == 0) {
             LOG.debug("No valid new resources found to ingest");
             return;
         }
 
         Date LOAD_TIME = Calendar.getInstance().getTime();
         // synchronization around date format should not be an issue as this code is single-threaded
         File completeDir = new File(getXmlCompleteDir(), DIR_FORMAT.format(LOAD_TIME));
         File failedDir = new File(getXmlProblemDir(), DIR_FORMAT.format(LOAD_TIME));
 
         // now ingest the containers
         Collection failed = null;
         try {
             failed = CoreApiServiceLocator.getXmlIngesterService().ingest(collections);
         } catch (Exception e) {
             LOG.error("Error ingesting data", e);
             //throw new RuntimeException(e);
         }
     
         // now iterate through all containers again, and move containers to approprate dir
         LOG.info("Moving files...");
         collectionsIt = collections.iterator();
         while (collectionsIt.hasNext()) {
             XmlDocCollection container = (XmlDocCollection) collectionsIt.next();
             LOG.debug("container: " + container);
             try {
                 // "close" the container
                 // this only matters for ZipFiles for now
                 container.close();
             } catch (IOException ioe) {
                 LOG.warn("Error closing " + container, ioe);
             }
             if (failed.contains(container)) {
                 // some docs must have failed, move the whole
                 // container to the failed dir
                 if (container.getFile() != null) {
                     LOG.error("Moving " + container.getFile() + " to problem dir.");
                     if ((!failedDir.isDirectory() && !failedDir.mkdirs())
                         || !moveFile(failedDir, container.getFile())) {
                         LOG.error("Could not move: " + container.getFile());
                         recordUnmovablePendingFile(container.getFile(), LOAD_TIME);         
                     }
                 }
             } else {
                 if (container.getFile() != null) {
                     LOG.info("Moving " + container.getFile() + " to loaded dir.");
                     if((!completeDir.isDirectory() && !completeDir.mkdirs())
                         || !moveFile(completeDir, container.getFile())){
                         LOG.error("Could not move: " + container.getFile());
                         recordUnmovablePendingFile(container.getFile(), LOAD_TIME);         
                     }
                 }
             }
         }
     }
 
     private boolean inPendingMoveFailedArchive(File xmlDataFile){
         if (xmlDataFile == null) return false;
         BufferedReader inFile = null;
         File movesFailedFile = new File(getXmlPendingDir(), PENDING_MOVE_FAILED_ARCHIVE_FILE);
         if (!movesFailedFile.isFile()) return false;
         try {
             inFile = new BufferedReader(new FileReader(movesFailedFile));
             String line;
             
             while((line = inFile.readLine()) != null){
                 String trimmedLine = line.trim();
                 if(trimmedLine.equals(xmlDataFile.getName()) ||
                    trimmedLine.startsWith(xmlDataFile.getName() + "=")) { 
                     return true;
                 }
             }
         } catch (IOException e){
             LOG.warn("Error reading file " + movesFailedFile);
             //TODO try reading the pending file or stop?
         } finally {
             if (inFile != null) try {
                 inFile.close();
             } catch (Exception e) {
                 LOG.warn("Error closing buffered reader for " + movesFailedFile);
             }
         }
       
         return false;
     }
 
     private boolean recordUnmovablePendingFile(File unMovablePendingFile, Date dateLoaded){
         boolean recorded = false;
         FileWriter archiveFile = null;
         try{
             archiveFile = new FileWriter(new File(getXmlPendingDir(), PENDING_MOVE_FAILED_ARCHIVE_FILE), true);  
             archiveFile.write(unMovablePendingFile.getName() + "=" + dateLoaded.getTime() + NEW_LINE);
             recorded = true;
         } catch (IOException e){
             LOG.error("Unable to record unmovable pending file " + unMovablePendingFile.getName() + "in the archive file " + PENDING_MOVE_FAILED_ARCHIVE_FILE);
         } finally {
             if (archiveFile != null) {
                 try {
                     archiveFile.close();
                 } catch (IOException ioe) {
                     LOG.error("Error closing unmovable pending file", ioe);
                 }
             }
         }
         return recorded;       
     }
 
     private boolean moveFile(File toDirectory, File fileToMove){
         boolean moved = true;
         if (!fileToMove.renameTo(new File(toDirectory.getPath(), fileToMove.getName()))){
             LOG.error("Unable to move file " + fileToMove.getName() + " to directory " + toDirectory.getPath());
             moved = false;
         }
         return moved;
     }
 
     private File getXmlPendingDir() {
         return new File(getXmlPendingLocation());
     }
 
     private File getXmlCompleteDir() {
         return new File(getXmlCompletedLocation());
     }
 
     private File getXmlProblemDir() {
         return new File(getXmlProblemLocation());
     }
 
     public String getXmlCompletedLocation() {
         return xmlCompletedLocation;
     }
 
     public void setXmlCompletedLocation(String xmlCompletedLocation) {
         this.xmlCompletedLocation = xmlCompletedLocation;
     }
 
     public String getXmlPendingLocation() {
         return xmlPendingLocation;
     }
 
     /*public boolean validate(File uploadedFile) {
         XmlDataLoaderFileFilter filter = new XmlDataLoaderFileFilter();
         return filter.accept(uploadedFile);
     }*/
 
     public void setXmlPendingLocation(String xmlPendingLocation) {
         this.xmlPendingLocation = xmlPendingLocation;
     }
 
     public String getXmlProblemLocation() {
         return xmlProblemLocation;
     }
 
     public void setXmlProblemLocation(String xmlProblemLocation) {
         this.xmlProblemLocation = xmlProblemLocation;
     }
     public String getXmlParentDirectory() {
         return xmlParentDirectory;
     }
     public void setXmlParentDirectory(String xmlDataParentDirectory) {
         this.xmlParentDirectory = xmlDataParentDirectory;
     }
 
     /**
      * Sets the polling interval time in seconds
      * @param seconds the polling interval time in seconds
      */
     public void setPollIntervalSecs(int seconds) {
         this.pollIntervalSecs = seconds;
     }
 
     /**
      * Gets the polling interval time in seconds
      * @return the polling interval time in seconds
      */
     public int getPollIntervalSecs() {
         return this.pollIntervalSecs;
     }
 
     /**
      * Sets the initial delay time in seconds
      * @param seconds the initial delay time in seconds
      */
     public void setInitialDelaySecs(int seconds) {
         this.initialDelaySecs = seconds;
     }
 
     /**
      * Gets the initial delay time in seconds
      * @return the initial delay time in seconds
      */
     public int getInitialDelaySecs() {
         return this.initialDelaySecs;
     }
 }

1		/*
2		* Copyright 2005-2007 The Kuali Foundation
3		*
4		*
5		* Licensed under the Educational Community License, Version 2.0 (the "License");
6		* you may not use this file except in compliance with the License.
7		* You may obtain a copy of the License at
8		*
9		* http://www.opensource.org/licenses/ecl2.php
10		*
11		* Unless required by applicable law or agreed to in writing, software
12		* distributed under the License is distributed on an "AS IS" BASIS,
13		* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14		* See the License for the specific language governing permissions and
15		* limitations under the License.
16		*/
17		package org.kuali.rice.kew.batch;
18
19		import java.io.BufferedReader;
20		import java.io.File;
21		import java.io.FileReader;
22		import java.io.FileWriter;
23		import java.io.IOException;
24		import java.text.Format;
25		import java.text.SimpleDateFormat;
26		import java.util.ArrayList;
27		import java.util.Calendar;
28		import java.util.Collection;
29		import java.util.Date;
30		import java.util.Iterator;
31		import java.util.List;
32
33		import org.kuali.rice.core.api.CoreApiServiceLocator;
34		import org.kuali.rice.core.api.impex.xml.DirectoryXmlDocCollection;
35		import org.kuali.rice.core.api.impex.xml.FileXmlDocCollection;
36		import org.kuali.rice.core.api.impex.xml.XmlDocCollection;
37		import org.kuali.rice.core.api.impex.xml.XmlIngesterService;
38		import org.kuali.rice.core.api.impex.xml.ZipXmlDocCollection;
39
40
41		/**
42		* Utility class responsible for polling and ingesting XML data files
43		* containing various forms of workflow engine data (e.g. document types
44		* and rules).
45		* Loaded files and problem files are placed into a subdirectory of a
46		* configured 'loaded' and 'problem' directory, respectively.
47		* "Problem-ness" is determined by inspecting a 'processed' flag on each <code>XmlDoc</code>
48		* in each collection. If not all <code>XmlDoc</code>s are marked 'processed' an
49		* error is assumed, and the collection file (e.g. for a Zip, the Zip file) is moved
50		* to the 'problem' directory.
51		* As such, it is the <b><code>XmlIngesterService</code>'s responsibility</b> to mark
52		* any unknown or otherwise innocuous non-failure non-processed files, as 'processed'.
53		* A different mechanism can be developed if this proves to be a problem, but for now
54		* it is simple enough for the <code>XmlIngesterService</code> to determine this.
55		* @see org.kuali.rice.kew.batch.XmlPollerService
56		* @see org.kuali.rice.kew.batch.XmlIngesterServiceImpl
57		* @author Kuali Rice Team (rice.collab@kuali.org)
58		*/
59	0	public class XmlPollerServiceImpl implements XmlPollerService {
60
61	0	private static final org.apache.log4j.Logger LOG = org.apache.log4j.Logger
62		.getLogger(XmlPollerServiceImpl.class);
63	0	private static final Format DIR_FORMAT = new SimpleDateFormat("yyyy-MM-dd_HH-mm-ss-SSS");
64
65		/**
66		* Specifies the polling interval that should be used with this task.
67		*/
68	0	private int pollIntervalSecs = 5 * 60; // default to 5 minutes
69		/**
70		* Specifies the initial delay the poller should wait before starting to poll
71		*/
72	0	private int initialDelaySecs = 30; // default to 30 seconds
73		/**
74		* Location in which to find XML files to load.
75		*/
76		private String xmlPendingLocation;
77		/**
78		* Location in which to place successfully loaded XML files.
79		*/
80		private String xmlCompletedLocation;
81		/**
82		* Location in which to place XML files which have failed to load.
83		*/
84		private String xmlProblemLocation;
85
86		private String xmlParentDirectory;
87		private static final String PENDING_MOVE_FAILED_ARCHIVE_FILE = "movesfailed";
88		private static final String NEW_LINE = "\n";
89
90		public void run() {
91		// if(!directoriesWritable()){
92		// LOG.error("Error writing to xml data directories. Stopping xmlLoader ...");
93		// this.cancel();
94		// }
95	0	LOG.debug("checking for xml data files...");
96	0	File[] files = getXmlPendingDir().listFiles();
97	0	if (files == null \|\| files.length == 0) {
98	0	return;
99		}
100	0	LOG.info("Found " + files.length + " files to ingest.");
101	0	List<XmlDocCollection> collections = new ArrayList<XmlDocCollection>();
102	0	for (File file : files)
103		{
104	0	if (file.isDirectory())
105		{
106	0	collections.add(new DirectoryXmlDocCollection(file));
107	0	} else if (file.getName().equals(PENDING_MOVE_FAILED_ARCHIVE_FILE))
108		{
109		// the movesfailed file...ignore this
110	0	continue;
111	0	} else if (file.getName().toLowerCase().endsWith(".zip"))
112		{
113		try
114		{
115	0	collections.add(new ZipXmlDocCollection(file));
116	0	} catch (IOException ioe)
117		{
118	0	LOG.error("Unable to load file: " + file);
119	0	}
120	0	} else if (file.getName().endsWith(".xml"))
121		{
122	0	collections.add(new FileXmlDocCollection(file));
123		} else
124		{
125	0	LOG.warn("Ignoring extraneous file in xml pending directory: " + file);
126		}
127		}
128
129		// Cull any resources which were already processed and whose moves failed
130	0	Iterator collectionsIt = collections.iterator();
131	0	Collection<XmlDocCollection> culled = new ArrayList<XmlDocCollection>();
132	0	while (collectionsIt.hasNext()) {
133	0	XmlDocCollection container = (XmlDocCollection) collectionsIt.next();
134		// if a move has already failed for this archive, ignore it
135	0	if (inPendingMoveFailedArchive(container.getFile())) {
136	0	LOG.info("Ignoring previously processed resource: " + container);
137	0	culled.add(container);
138		}
139	0	}
140	0	collections.removeAll(culled);
141
142	0	if (collections.size() == 0) {
143	0	LOG.debug("No valid new resources found to ingest");
144	0	return;
145		}
146
147	0	Date LOAD_TIME = Calendar.getInstance().getTime();
148		// synchronization around date format should not be an issue as this code is single-threaded
149	0	File completeDir = new File(getXmlCompleteDir(), DIR_FORMAT.format(LOAD_TIME));
150	0	File failedDir = new File(getXmlProblemDir(), DIR_FORMAT.format(LOAD_TIME));
151
152		// now ingest the containers
153	0	Collection failed = null;
154		try {
155	0	failed = CoreApiServiceLocator.getXmlIngesterService().ingest(collections);
156	0	} catch (Exception e) {
157	0	LOG.error("Error ingesting data", e);
158		//throw new RuntimeException(e);
159	0	}
160
161		// now iterate through all containers again, and move containers to approprate dir
162	0	LOG.info("Moving files...");
163	0	collectionsIt = collections.iterator();
164	0	while (collectionsIt.hasNext()) {
165	0	XmlDocCollection container = (XmlDocCollection) collectionsIt.next();
166	0	LOG.debug("container: " + container);
167		try {
168		// "close" the container
169		// this only matters for ZipFiles for now
170	0	container.close();
171	0	} catch (IOException ioe) {
172	0	LOG.warn("Error closing " + container, ioe);
173	0	}
174	0	if (failed.contains(container)) {
175		// some docs must have failed, move the whole
176		// container to the failed dir
177	0	if (container.getFile() != null) {
178	0	LOG.error("Moving " + container.getFile() + " to problem dir.");
179	0	if ((!failedDir.isDirectory() && !failedDir.mkdirs())
180		\|\| !moveFile(failedDir, container.getFile())) {
181	0	LOG.error("Could not move: " + container.getFile());
182	0	recordUnmovablePendingFile(container.getFile(), LOAD_TIME);
183		}
184		}
185		} else {
186	0	if (container.getFile() != null) {
187	0	LOG.info("Moving " + container.getFile() + " to loaded dir.");
188	0	if((!completeDir.isDirectory() && !completeDir.mkdirs())
189		\|\| !moveFile(completeDir, container.getFile())){
190	0	LOG.error("Could not move: " + container.getFile());
191	0	recordUnmovablePendingFile(container.getFile(), LOAD_TIME);
192		}
193		}
194		}
195	0	}
196	0	}
197
198		private boolean inPendingMoveFailedArchive(File xmlDataFile){
199	0	if (xmlDataFile == null) return false;
200	0	BufferedReader inFile = null;
201	0	File movesFailedFile = new File(getXmlPendingDir(), PENDING_MOVE_FAILED_ARCHIVE_FILE);
202	0	if (!movesFailedFile.isFile()) return false;
203		try {
204	0	inFile = new BufferedReader(new FileReader(movesFailedFile));
205		String line;
206
207	0	while((line = inFile.readLine()) != null){
208	0	String trimmedLine = line.trim();
209	0	if(trimmedLine.equals(xmlDataFile.getName()) \|\|
210		trimmedLine.startsWith(xmlDataFile.getName() + "=")) {
211	0	return true;
212		}
213	0	}
214	0	} catch (IOException e){
215	0	LOG.warn("Error reading file " + movesFailedFile);
216		//TODO try reading the pending file or stop?
217		} finally {
218	0	if (inFile != null) try {
219	0	inFile.close();
220	0	} catch (Exception e) {
221	0	LOG.warn("Error closing buffered reader for " + movesFailedFile);
222	0	}
223		}
224
225	0	return false;
226		}
227
228		private boolean recordUnmovablePendingFile(File unMovablePendingFile, Date dateLoaded){
229	0	boolean recorded = false;
230	0	FileWriter archiveFile = null;
231		try{
232	0	archiveFile = new FileWriter(new File(getXmlPendingDir(), PENDING_MOVE_FAILED_ARCHIVE_FILE), true);
233	0	archiveFile.write(unMovablePendingFile.getName() + "=" + dateLoaded.getTime() + NEW_LINE);
234	0	recorded = true;
235	0	} catch (IOException e){
236	0	LOG.error("Unable to record unmovable pending file " + unMovablePendingFile.getName() + "in the archive file " + PENDING_MOVE_FAILED_ARCHIVE_FILE);
237		} finally {
238	0	if (archiveFile != null) {
239		try {
240	0	archiveFile.close();
241	0	} catch (IOException ioe) {
242	0	LOG.error("Error closing unmovable pending file", ioe);
243	0	}
244		}
245		}
246	0	return recorded;
247		}
248
249		private boolean moveFile(File toDirectory, File fileToMove){
250	0	boolean moved = true;
251	0	if (!fileToMove.renameTo(new File(toDirectory.getPath(), fileToMove.getName()))){
252	0	LOG.error("Unable to move file " + fileToMove.getName() + " to directory " + toDirectory.getPath());
253	0	moved = false;
254		}
255	0	return moved;
256		}
257
258		private File getXmlPendingDir() {
259	0	return new File(getXmlPendingLocation());
260		}
261
262		private File getXmlCompleteDir() {
263	0	return new File(getXmlCompletedLocation());
264		}
265
266		private File getXmlProblemDir() {
267	0	return new File(getXmlProblemLocation());
268		}
269
270		public String getXmlCompletedLocation() {
271	0	return xmlCompletedLocation;
272		}
273
274		public void setXmlCompletedLocation(String xmlCompletedLocation) {
275	0	this.xmlCompletedLocation = xmlCompletedLocation;
276	0	}
277
278		public String getXmlPendingLocation() {
279	0	return xmlPendingLocation;
280		}
281
282		/*public boolean validate(File uploadedFile) {
283		XmlDataLoaderFileFilter filter = new XmlDataLoaderFileFilter();
284		return filter.accept(uploadedFile);
285		}*/
286
287		public void setXmlPendingLocation(String xmlPendingLocation) {
288	0	this.xmlPendingLocation = xmlPendingLocation;
289	0	}
290
291		public String getXmlProblemLocation() {
292	0	return xmlProblemLocation;
293		}
294
295		public void setXmlProblemLocation(String xmlProblemLocation) {
296	0	this.xmlProblemLocation = xmlProblemLocation;
297	0	}
298		public String getXmlParentDirectory() {
299	0	return xmlParentDirectory;
300		}
301		public void setXmlParentDirectory(String xmlDataParentDirectory) {
302	0	this.xmlParentDirectory = xmlDataParentDirectory;
303	0	}
304
305		/**
306		* Sets the polling interval time in seconds
307		* @param seconds the polling interval time in seconds
308		*/
309		public void setPollIntervalSecs(int seconds) {
310	0	this.pollIntervalSecs = seconds;
311	0	}
312
313		/**
314		* Gets the polling interval time in seconds
315		* @return the polling interval time in seconds
316		*/
317		public int getPollIntervalSecs() {
318	0	return this.pollIntervalSecs;
319		}
320
321		/**
322		* Sets the initial delay time in seconds
323		* @param seconds the initial delay time in seconds
324		*/
325		public void setInitialDelaySecs(int seconds) {
326	0	this.initialDelaySecs = seconds;
327	0	}
328
329		/**
330		* Gets the initial delay time in seconds
331		* @return the initial delay time in seconds
332		*/
333		public int getInitialDelaySecs() {
334	0	return this.initialDelaySecs;
335		}
336		}