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: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to