similarly iterator(). not sure what's drainTo's behavior is

datastax · May 3, 2024 · 9795119 · 9795119
1 parent 29b1b3b
commit 9795119
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../src/main/java/com/datastax/oss/pulsar/jms/MessagePriorityGrowableArrayBlockingQueue.java b/.../src/main/java/com/datastax/oss/pulsar/jms/MessagePriorityGrowableArrayBlockingQueue.java
@@ -131,7 +131,7 @@ public int size() {
 
   @Override
   public Iterator<Message> iterator() {
-    return queue.iterator();
+    return queue.stream().sorted(comparator).iterator();
   }
 
   @Override