KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > quadcap > pop3 > client > Agent


1 package com.quadcap.pop3.client;
2
3 /* Copyright 1997 - 2003 Quadcap Software. All rights reserved.
4  *
5  * This software is distributed under the Quadcap Free Software License.
6  * This software may be used or modified for any purpose, personal or
7  * commercial. Open Source redistributions are permitted. Commercial
8  * redistribution of larger works derived from, or works which bundle
9  * this software requires a "Commercial Redistribution License"; see
10  * http://www.quadcap.com/purchase.
11  *
12  * Redistributions qualify as "Open Source" under one of the following terms:
13  *
14  * Redistributions are made at no charge beyond the reasonable cost of
15  * materials and delivery.
16  *
17  * Redistributions are accompanied by a copy of the Source Code or by an
18  * irrevocable offer to provide a copy of the Source Code for up to three
19  * years at the cost of materials and delivery. Such redistributions
20  * must allow further use, modification, and redistribution of the Source
21  * Code under substantially the same terms as this license.
22  *
23  * Redistributions of source code must retain the copyright notices as they
24  * appear in each source code file, these license terms, and the
25  * disclaimer/limitation of liability set forth as paragraph 6 below.
26  *
27  * Redistributions in binary form must reproduce this Copyright Notice,
28  * these license terms, and the disclaimer/limitation of liability set
29  * forth as paragraph 6 below, in the documentation and/or other materials
30  * provided with the distribution.
31  *
32  * The Software is provided on an "AS IS" basis. No warranty is
33  * provided that the Software is free of defects, or fit for a
34  * particular purpose.
35  *
36  * Limitation of Liability. Quadcap Software shall not be liable
37  * for any damages suffered by the Licensee or any third party resulting
38  * from use of the Software.
39  */
40
41 import java.util.Date JavaDoc;
42 import java.util.Hashtable JavaDoc;
43 import java.util.Vector JavaDoc;
44
45 import java.io.IOException JavaDoc;
46 import java.io.InputStream JavaDoc;
47
48 import com.quadcap.util.Debug;
49
50 import com.quadcap.util.threads.Command;
51
52 /**
53  * This simple Pop3 agent transfers all new messages in a remote Pop3
54  * mailbox into the specified folder in the quadcap message store.
55  *
56  * <p>A more sophisticated agent would scan the headers first and apply
57  * filters to certain messages without having to fetch the bodies.
58  *
59  * @author Stan Bailes
60  */
61 public class Agent implements Runnable JavaDoc {
62     String JavaDoc host;
63     String JavaDoc user;
64     String JavaDoc password;
65     Session pop3 = null;
66
67     /**
68      * Create a new Agent with the specified profile name
69      *
70      * @param profileName the name of the profile.
71      */
72     public Agent(String JavaDoc host, String JavaDoc user, String JavaDoc password) {
73         this.host = host;
74         this.user = user;
75         this.password = password;
76     }
77
78     /**
79      * The Command callback object which invokes this agent.
80      */
81     public void run() {
82     Debug.println("[" + user + "] begin");
83     try {
84         if (pop3 == null) pop3 = new Session(host, 110);
85         pop3.connect();
86
87             if (pop3.user(user) != Session.OK) {
88                 throw new IOException JavaDoc("user failed: " + user);
89             }
90             if (pop3.pass(password) != Session.OK) {
91                 throw new IOException JavaDoc("password failed: " + user);
92         }
93             getAndDeleteMail();
94     } catch (IOException JavaDoc e) {
95         Debug.print(e);
96                      
97     } finally {
98         try {
99         pop3.quit();
100         } catch (IOException JavaDoc e) {
101         Debug.print(e);
102         }
103         // ---- we're about to "go to sleep", potentially for a long time,
104 // ---- so allow these objects to be gc'ed.
105 pop3 = null;
106     }
107     Debug.println("[" + user + "] done");
108     }
109
110     /**
111      * The simple <i>delete from server</i> case. Get all of the mail,
112      * put it in the right folder, then delete it from the server.
113      */
114     void getAndDeleteMail() throws IOException JavaDoc {
115     Vector JavaDoc r = pop3.stat();
116     int cnt = Integer.parseInt(r.elementAt(1).toString());
117         byte[] buf = new byte[16384];
118         for (int i = 1; i <= cnt; i++) {
119             Debug.println("[" + user + "] getting message " + i);
120             InputStream JavaDoc is = pop3.retr(i);
121             if (is != null) {
122                 int xcnt = 0;
123                 while ((xcnt = is.read(buf)) > 0) continue;
124                 is.close();
125             }
126             pop3.dele(i);
127     }
128         Debug.println("[" + user + "] deleted " + cnt + " messages");
129     }
130
131     public static void main(String JavaDoc[] args) {
132         while (true) {
133             for (int i = 0; i < 100; i++) {
134                 Agent agent = new Agent("nt1", "stan"+i, "stan"+i);
135                 agent.run();
136             }
137         }
138     }
139 }
140
141
Popular Tags