We had a need to use priority based queuing on a project I am working on and do not have enough time to wait on 6.0.0 to come out which is what AMQ-122 states as the release date, so I took a stab at implementing it. Since I am not too familiar with ActiveMQ I was hoping that one of the developers may be able to pick it up and incorporate into a 5.3 release if at all possible. I ran the unit tests and they seem to run with the exception of issues with the SSL but I do not believe that is related to the changes I made.
Here is the summary of the changes, all source files are attached: 1) Created class PriorityMessageDispatchChannel which replaced MessageDispatchChannel 2) Updated ActiveMQMessageConsumer.java and ActiveMQSessionExecutor.java in order to instantiate the PriorityMessageDispatchChannel instead of the the MessageDispatchChannel. This would be best done at runtime based upon a configuration option such as supportsJMSPriority, however I did not want to make that significant of a change until I could figure out the feasibility of getting it incorporated into ActiveMQ. 3) Updated ActiveMQConnection.java and ActiveMQSession.java to only set the message priority to the defaultPriority if it wasn't set on the Message. 4) Added a unit test ChangeSentMessagePriorityTest.java I have attached all of the source files to this post, please let me know if it is possible to get this into a release and if so if I can do anything to help make that happen. Thanks, Phillip Merritt http://old.nabble.com/file/p28170545/ActiveMQConnection.java ActiveMQConnection.java http://old.nabble.com/file/p28170545/ActiveMQMessageConsumer.java ActiveMQMessageConsumer.java http://old.nabble.com/file/p28170545/ActiveMQSession.java ActiveMQSession.java http://old.nabble.com/file/p28170545/ActiveMQSessionExecutor.java ActiveMQSessionExecutor.java http://old.nabble.com/file/p28170545/ChangeSentMessagePriorityTest.java ChangeSentMessagePriorityTest.java http://old.nabble.com/file/p28170545/PriorityMessageDispatchChannel.java PriorityMessageDispatchChannel.java -- View this message in context: http://old.nabble.com/ActiveMQ-JMSPriority-%28AMQ-122%29-tp28170545p28170545.html Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
