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 {
