Github user michaelandrepearce commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2488#discussion_r245006326
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/Consumer.java
---
@@ -21,7 +21,7 @@
import org.apache.activemq.artemis.core.filter.Filter;
import org.apache.activemq.artemis.spi.core.protocol.SessionCallback;
-public interface Consumer {
+public interface Consumer extends PriorityAware {
--- End diff --
Correct, but to make testing of the QueueConsumersImpl logic easier and
quite self contained this, its kept seperate, also it means if we wanted to
reuse the new QueueConsumerImpl for other PriorityAware needs it makes it
easier.
---
