Author: norman
Date: Mon Oct 18 19:12:31 2010
New Revision: 1023956

URL: http://svn.apache.org/viewvc?rev=1023956&view=rev
Log:
Set the message priority via the MessageProducer so we are sure its not override

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=1023956&r1=1023955&r2=1023956&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
 Mon Oct 18 19:12:31 2010
@@ -80,7 +80,7 @@ public class JMSMailQueue implements Mai
     /**
      * Handle mail with normal priority (this is the default)
      */
-    public final static int NORMAL_PRIORITY = 5;
+    public final static int NORMAL_PRIORITY = Message.DEFAULT_DELIVERY_MODE;
     
     /**
      * Handle mail with highest priority
@@ -212,9 +212,14 @@ public class JMSMailQueue implements Mai
                        producer = session.createProducer(queue);
                        Message message = createMessage(session, mail, mydelay);
                        populateJMSProperties(message, mail, mydelay);
-                       populateJMSHeaders(message, mail);
-                       
-                       producer.send(message);
+
+                       int msgPrio = NORMAL_PRIORITY;
+                       Object prio = mail.getAttribute(MAIL_PRIORITY);
+               if (prio instanceof Integer) {
+                   msgPrio = (Integer) prio;
+               }
+               
+                       producer.send(message, Message.DEFAULT_DELIVERY_MODE, 
msgPrio, Message.DEFAULT_TIME_TO_LIVE);
                } catch (Exception e) {
                        if (session != null) {
                                try {
@@ -334,21 +339,7 @@ public class JMSMailQueue implements Mai
         
     }
     
-    /**
-     * Populate the JMS Message Headers from the given {...@link Mail}
-     * 
-     * @param message
-     * @param mail
-     * @throws JMSException
-     * @throws MessagingException
-     */
-    protected void populateJMSHeaders(Message message, Mail mail) throws 
JMSException, MessagingException {
-       Object prio = mail.getAttribute(MAIL_PRIORITY);
-       if (prio instanceof Integer) {
-               message.setJMSPriority((Integer) prio);
-       }
-    }
-    
+
     /**
      * Create the complete Mail from the JMS Message. So the created {...@link 
Mail} is completly populated
      * 



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

Reply via email to