Author: norman
Date: Sat Oct  9 17:56:22 2010
New Revision: 1006203

URL: http://svn.apache.org/viewvc?rev=1006203&view=rev
Log:
Use MimeMessageWrapper when create the MailImpl object with the JMS Message. 
This helps to decrease the Memory usage of JavaMail (forgot to use it before).

Modified:
    
james/server/trunk/queue-activemq/src/main/java/org/apache/james/queue/activemq/ActiveMQMailQueue.java

Modified: 
james/server/trunk/queue-activemq/src/main/java/org/apache/james/queue/activemq/ActiveMQMailQueue.java
URL: 
http://svn.apache.org/viewvc/james/server/trunk/queue-activemq/src/main/java/org/apache/james/queue/activemq/ActiveMQMailQueue.java?rev=1006203&r1=1006202&r2=1006203&view=diff
==============================================================================
--- 
james/server/trunk/queue-activemq/src/main/java/org/apache/james/queue/activemq/ActiveMQMailQueue.java
 (original)
+++ 
james/server/trunk/queue-activemq/src/main/java/org/apache/james/queue/activemq/ActiveMQMailQueue.java
 Sat Oct  9 17:56:22 2010
@@ -50,6 +50,7 @@ import org.apache.james.core.MailImpl;
 import org.apache.james.core.MimeMessageCopyOnWriteProxy;
 import org.apache.james.core.MimeMessageInputStream;
 import org.apache.james.core.MimeMessageInputStreamSource;
+import org.apache.james.core.MimeMessageWrapper;
 import org.apache.james.queue.MailQueue;
 import org.apache.mailet.Mail;
 import org.apache.mailet.MailAddress;
@@ -312,7 +313,7 @@ public class ActiveMQMailQueue implement
                     // Ignore on error
                     logger.debug("Unable to get url from blobmessage for mail 
" + mail.getName());
                 }
-                mail.setMessage(new MimeMessageCopyOnWriteProxy(new 
MimeMessageInputStreamSource(mail.getName(), blobMessage.getInputStream())));
+                mail.setMessage(new MimeMessageWrapper(new 
MimeMessageCopyOnWriteProxy(new MimeMessageInputStreamSource(mail.getName(), 
blobMessage.getInputStream()))));
                 
             } else {
                 throw new MailQueueException("Not supported JMS Message 
received " + message);



---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to