|
From: <de...@us...> - 2003-07-02 12:29:28
|
Update of /cvsroot/babeldoc/babeldoc/modules/core/src/com/babeldoc/core/pipeline/feeder
In directory sc8-pr-cvs1:/tmp/cvs-serv14090/modules/core/src/com/babeldoc/core/pipeline/feeder
Modified Files:
AsynchronousFeeder.java
Log Message:
Fixed bug that causes initialization error when using DiskQueue
Index: AsynchronousFeeder.java
===================================================================
RCS file: /cvsroot/babeldoc/babeldoc/modules/core/src/com/babeldoc/core/pipeline/feeder/AsynchronousFeeder.java,v
retrieving revision 1.7
retrieving revision 1.8
diff -C2 -d -r1.7 -r1.8
*** AsynchronousFeeder.java 30 Jun 2003 22:14:56 -0000 1.7
--- AsynchronousFeeder.java 2 Jul 2003 12:29:25 -0000 1.8
***************
*** 112,126 ****
* @param map
*/
! public void initialize(Map map)
! throws GeneralException{
! if(map!=null) {
String qtype = (String)map.get(Q_TYPE);
! if(Q_TYPE_DISK.equals(qtype)) {
String qname = (String)map.get(Q_DIR_NAME);
String qdir = (String)map.get(Q_DISK_DIR);
! if(qname==null) {
throw new GeneralException("Disk queues must have a 'queueName'");
}
! if(qdir==null||new File(qdir).exists()) {
throw new GeneralException("Disk queues must have a 'queueDir'");
}
--- 112,125 ----
* @param map
*/
! public void initialize(Map map) throws GeneralException{
! if (map != null) {
String qtype = (String)map.get(Q_TYPE);
! if (Q_TYPE_DISK.equals(qtype)) {
String qname = (String)map.get(Q_DIR_NAME);
String qdir = (String)map.get(Q_DISK_DIR);
! if (qname == null || qname.equals("")) {
throw new GeneralException("Disk queues must have a 'queueName'");
}
! if (qdir == null || qdir.equals("")) {
throw new GeneralException("Disk queues must have a 'queueDir'");
}
|