diff --git a/activemq-core/src/main/java/org/apache/activemq/SimplePriorityMessageDispatchChannel.java b/activemq-core/src/main/java/org/apache/activemq/SimplePriorityMessageDispatchChannel.java index ec95acb3f9..2c603b0cfe 100644 --- a/activemq-core/src/main/java/org/apache/activemq/SimplePriorityMessageDispatchChannel.java +++ b/activemq-core/src/main/java/org/apache/activemq/SimplePriorityMessageDispatchChannel.java @@ -237,8 +237,8 @@ public class SimplePriorityMessageDispatchChannel implements MessageDispatchChan protected int getPriority(MessageDispatch message) { int priority = javax.jms.Message.DEFAULT_PRIORITY; if (message.getMessage() != null) { - Math.max(message.getMessage().getPriority(), 0); - priority = Math.min(priority, 9); + priority = Math.max(message.getMessage().getPriority(), 0); + priority = Math.min(priority, 9); } return priority; }