Author: norman
Date: Tue May 10 17:25:26 2011
New Revision: 1101553

URL: http://svn.apache.org/viewvc?rev=1101553&view=rev
Log:
Make sure the mail attributes are set to the right type after dequeue a mail. 
See JAMES-1241

Modified:
    
james/server/trunk/queue-jms/src/main/java/org/apache/james/queue/jms/JMSMailQueue.java

Modified: 
james/server/trunk/queue-jms/src/main/java/org/apache/james/queue/jms/JMSMailQueue.java
URL: 
http://svn.apache.org/viewvc/james/server/trunk/queue-jms/src/main/java/org/apache/james/queue/jms/JMSMailQueue.java?rev=1101553&r1=1101552&r2=1101553&view=diff
==============================================================================
--- 
james/server/trunk/queue-jms/src/main/java/org/apache/james/queue/jms/JMSMailQueue.java
 (original)
+++ 
james/server/trunk/queue-jms/src/main/java/org/apache/james/queue/jms/JMSMailQueue.java
 Tue May 10 17:25:26 2011
@@ -419,9 +419,15 @@ public class JMSMailQueue implements Man
         StringTokenizer namesTokenizer = new StringTokenizer(attributeNames, 
JAMES_MAIL_SEPARATOR);
         while (namesTokenizer.hasMoreTokens()) {
             String name = namesTokenizer.nextToken();
-            Serializable attrValue = message.getStringProperty(name);
-
-            mail.setAttribute(name, attrValue);
+            
+            // Now case the property back to Serializable and set it as 
attribute.
+            // See JAMES-1241
+            Object attrValue = message.getObjectProperty(name);
+            if ( attrValue instanceof Serializable) {   
+                mail.setAttribute(name, (Serializable) attrValue);
+            } else {
+                logger.error("Not supported mail attribute " + name + " of 
type " + attrValue);
+            }
         }
 
         String sender = message.getStringProperty(JAMES_MAIL_SENDER);



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

Reply via email to