You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by lh...@apache.org on 2008/08/08 11:10:29 UTC
svn commit: r683918 - in
/servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix:
JbiConstants.java jbi/nmr/flow/jms/AbstractJMSFlow.java
Author: lhein
Date: Fri Aug 8 02:10:28 2008
New Revision: 683918
URL: http://svn.apache.org/viewvc?rev=683918&view=rev
Log:
applied patch to set the jms message priority through exchange properties (SM-1506)
thanks to oleg for providing the patch
Modified:
servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/JbiConstants.java
servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/AbstractJMSFlow.java
Modified: servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/JbiConstants.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/JbiConstants.java?rev=683918&r1=683917&r2=683918&view=diff
==============================================================================
--- servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/JbiConstants.java (original)
+++ servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/JbiConstants.java Fri Aug 8 02:10:28 2008
@@ -50,4 +50,8 @@
*/
String CORRELATION_ID = "org.apache.servicemix.correlationId";
+ /**
+ * Constant for JMS Message Priority.
+ */
+ String MESSAGE_PRIORITY = "org.apache.servicemix.jms.messagePriority";
}
Modified: servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/AbstractJMSFlow.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/AbstractJMSFlow.java?rev=683918&r1=683917&r2=683918&view=diff
==============================================================================
--- servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/AbstractJMSFlow.java (original)
+++ servicemix/smx3/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/AbstractJMSFlow.java Fri Aug 8 02:10:28 2008
@@ -482,6 +482,11 @@
try {
Queue queue = inboundSession.createQueue(destination);
ObjectMessage msg = inboundSession.createObjectMessage(me);
+ // Set message priority.
+ Integer priority = (Integer) me.getProperty(JbiConstants.MESSAGE_PRIORITY);
+ if (null != priority) {
+ msg.setJMSPriority(priority);
+ }
MessageProducer queueProducer = inboundSession.createProducer(queue);
queueProducer.send(msg);
} finally {