compiles

[org.ibex.mail.git] / src / org / ibex / mail / protocol / SMTP.java

diff --git a/src/org/ibex/mail/protocol/SMTP.java b/src/org/ibex/mail/protocol/SMTP.java
index 2350dfd..8261247 100644 (file)
--- a/src/org/ibex/mail/protocol/SMTP.java
+++ b/src/org/ibex/mail/protocol/SMTP.java
@@ -11,6 +11,9 @@ import javax.naming.directory.*;
 
 public class SMTP extends MessageProtocol {
 
+    // FIXME
+    private static final Mailbox outgoing = null;
+
     static { new Thread() { public void run() { Outgoing.runq(); } }.start(); }
     public static String convdir = null;
     public static void main(String[] s) throws Exception {
@@ -48,7 +51,7 @@ public class SMTP extends MessageProtocol {
                 return;
             }
             synchronized(Outgoing.class) {
-                Mailbox.root.slash("outgoing").add(m);
+                outgoing.add(m);
                 queue.append(m);
                 Outgoing.class.notify();
             }
@@ -96,7 +99,8 @@ public class SMTP extends MessageProtocol {
                 w.print(".\r\n");
                 check(r.readLine());
                 Log.info(SMTP.Outgoing.class, "message accepted by " + mx);
-                Mailbox.root.slash("outgoing").delete(m);
+                // FIXME!
+                //outgoing.delete(m);
                 s.close();
                 return true;
             } catch (Exception e) {
@@ -111,7 +115,6 @@ public class SMTP extends MessageProtocol {
         static void runq() {
             try {
                 Log.setThreadAnnotation("[outgoing smtp] ");
-                Mailbox outgoing = Mailbox.root.slash("outgoing");
                 Log.info(SMTP.Outgoing.class, "outgoing thread started; " + outgoing.count(Query.all()) + " messages to send");
                 for(Mailbox.Iterator it = outgoing.iterator(); it.cur() != null; it.next()) queue.append(it.cur());
                 while(true) {