You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by no...@apache.org on 2010/11/01 07:40:03 UTC

svn commit: r1029563 - in /james/server/trunk: core-library/src/main/java/org/apache/james/core/ lmtpserver/src/main/java/org/apache/james/lmtpserver/ mailets/src/main/java/org/apache/james/transport/mailets/

Author: norman
Date: Mon Nov  1 06:40:02 2010
New Revision: 1029563

URL: http://svn.apache.org/viewvc?rev=1029563&view=rev
Log:
MimeMessageInputStream constructor should throw MessagingException and not IOException

Modified:
    james/server/trunk/core-library/src/main/java/org/apache/james/core/MimeMessageInputStream.java
    james/server/trunk/lmtpserver/src/main/java/org/apache/james/lmtpserver/DataLineLMTPMessageHookHandler.java
    james/server/trunk/mailets/src/main/java/org/apache/james/transport/mailets/SieveMailet.java

Modified: james/server/trunk/core-library/src/main/java/org/apache/james/core/MimeMessageInputStream.java
URL: http://svn.apache.org/viewvc/james/server/trunk/core-library/src/main/java/org/apache/james/core/MimeMessageInputStream.java?rev=1029563&r1=1029562&r2=1029563&view=diff
==============================================================================
--- james/server/trunk/core-library/src/main/java/org/apache/james/core/MimeMessageInputStream.java (original)
+++ james/server/trunk/core-library/src/main/java/org/apache/james/core/MimeMessageInputStream.java Mon Nov  1 06:40:02 2010
@@ -35,21 +35,19 @@ public class MimeMessageInputStream exte
     private InputStream in;
 
     @SuppressWarnings("unchecked")
-    public MimeMessageInputStream(MimeMessage message) throws IOException {
+    public MimeMessageInputStream(MimeMessage message) throws MessagingException {
         MimeMessage m = message;
+       
+        // check if we need to use the wrapped message
         if (m instanceof MimeMessageCopyOnWriteProxy) {
             m = ((MimeMessageCopyOnWriteProxy) message).getWrappedMessage();
         }
-        try {
 
-            if (m instanceof MimeMessageWrapper) {
-                in = ((MimeMessageWrapper) m).getMessageInputStream();
-            } else {
-                in = new CombinedInputStream(new InputStream[] { new InternetHeadersInputStream(message.getAllHeaderLines()), message.getRawInputStream() });
-
-            }
-        } catch (MessagingException e) {
-            throw new IOException("Unable to read MimeMessage: " + e.getMessage());
+        // check if we can use optimized operations
+        if (m instanceof MimeMessageWrapper) {
+            in = ((MimeMessageWrapper) m).getMessageInputStream();
+        } else {
+            in = new CombinedInputStream(new InputStream[] { new InternetHeadersInputStream(message.getAllHeaderLines()), message.getRawInputStream() });
         }
 
     }
@@ -57,7 +55,6 @@ public class MimeMessageInputStream exte
     @Override
     public int read() throws IOException {
         return in.read();
-
     }
 
     @Override

Modified: james/server/trunk/lmtpserver/src/main/java/org/apache/james/lmtpserver/DataLineLMTPMessageHookHandler.java
URL: http://svn.apache.org/viewvc/james/server/trunk/lmtpserver/src/main/java/org/apache/james/lmtpserver/DataLineLMTPMessageHookHandler.java?rev=1029563&r1=1029562&r2=1029563&view=diff
==============================================================================
--- james/server/trunk/lmtpserver/src/main/java/org/apache/james/lmtpserver/DataLineLMTPMessageHookHandler.java (original)
+++ james/server/trunk/lmtpserver/src/main/java/org/apache/james/lmtpserver/DataLineLMTPMessageHookHandler.java Mon Nov  1 06:40:02 2010
@@ -173,11 +173,6 @@ public class DataLineLMTPMessageHookHand
                 mailboxManager.getMailbox(MailboxPath.inbox(username), mailboxSession).appendMessage(new MimeMessageInputStream(mail.getMessage()), new Date(), mailboxSession, true, null);
                 mailboxManager.endProcessingRequest(mailboxSession);
                 response = new SMTPResponse(SMTPRetCode.MAIL_OK, DSNStatus.getStatus(DSNStatus.SUCCESS,DSNStatus.CONTENT_OTHER)+" Message received");
-            } catch (IOException e) {
-                session.getLogger().info("Unexpected error handling DATA stream",e);
-
-                response = new SMTPResponse(SMTPRetCode.LOCAL_ERROR,DSNStatus.getStatus(DSNStatus.TRANSIENT,
-                        DSNStatus.UNDEFINED_STATUS) + " Temporary error deliver message to " + recipient);
             
             } catch (MessagingException e) {
                 session.getLogger().info("Unexpected error handling DATA stream",e);

Modified: james/server/trunk/mailets/src/main/java/org/apache/james/transport/mailets/SieveMailet.java
URL: http://svn.apache.org/viewvc/james/server/trunk/mailets/src/main/java/org/apache/james/transport/mailets/SieveMailet.java?rev=1029563&r1=1029562&r2=1029563&view=diff
==============================================================================
--- james/server/trunk/mailets/src/main/java/org/apache/james/transport/mailets/SieveMailet.java (original)
+++ james/server/trunk/mailets/src/main/java/org/apache/james/transport/mailets/SieveMailet.java Mon Nov  1 06:40:02 2010
@@ -19,7 +19,6 @@
 
 package org.apache.james.transport.mailets;
 
-import java.io.IOException;
 import java.util.Date;
 
 import javax.annotation.Resource;
@@ -154,8 +153,6 @@ public class SieveMailet extends SieveMa
                             }
 
                             mailbox.appendMessage(new MimeMessageInputStream(mail), new Date(), session, true, null);
-                        } catch (IOException e) {
-                            throw new MessagingException("Failed to write mail message", e);
                         } finally {
                             session.close();
                             mailboxManager.logout(session, true);



---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org