KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > jsmtpd > core > send > DeliveryWorker


1 /*
2  *
3  * Jsmtpd, Java SMTP daemon
4  * Copyright (C) 2005 Jean-Francois POUX, jf.poux@laposte.net
5  *
6  * This program is free software; you can redistribute it and/or
7  * modify it under the terms of the GNU General Public License
8  * as published by the Free Software Foundation; either version 2
9  * of the License, or (at your option) any later version.
10  *
11  * This program is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14  * GNU General Public License for more details.
15  *
16  * You should have received a copy of the GNU General Public License
17  * along with this program; if not, write to the Free Software
18  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
19  *
20  */
21 package org.jsmtpd.core.send;
22
23 import org.jsmtpd.core.mail.Email;
24 import org.jsmtpd.generic.threadpool.IThreadedClass;
25
26 /**
27  * implements the interface to be runable by the generic thread pooler
28  * @author Jean-Francois POUX
29  * @see org.jsmtpd.generic.threadpool.GenericThreadPool
30  */
31 public class DeliveryWorker implements IThreadedClass {
32
33     private DeliveryHandler handler = new DeliveryHandler();
34     private Email curentMail = null;
35
36     public void doJob() {
37         try {
38             handler.processMessage(curentMail);
39
40         } catch (RuntimeException JavaDoc e) {
41             //=> requeue mail
42 QueueService.getInstance().requeueMail(curentMail);
43             e.printStackTrace();
44         }
45         curentMail = null;
46     }
47
48     public void forceShutdown() {
49         // Not really clean ... at all
50 // or wait for curentMail to be null
51 handler.clearMail(); //this will generate a null pointer exception excplicitly. Catched in doJob for requeing
52 //wait for curmail to be null
53
54         //Wait for curentMail to be null
55 while (true) {
56             if (curentMail == null)
57                 break;
58             try {
59                 Thread.sleep(100);
60             } catch (InterruptedException JavaDoc e) {
61
62                 e.printStackTrace();
63             }
64         }
65
66     }
67     
68     
69     public void gracefullShutdown() {
70         //TODO implement shutdown Handler
71 }
72
73     public void setParam(Object JavaDoc o) {
74         curentMail = (Email) o;
75
76     }
77
78 }
Popular Tags