Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #319

This commit is contained in:
Clebert Suconic 2016-01-13 14:02:50 -05:00
parent 4bc3422f6a 79454893ce
commit 4bd0be40e2
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
View File

@ -1604,7 +1604,7 @@ public class QueueImpl implements Queue {
final HashMap<SimpleString, Long> queues = new HashMap<>();
return iterQueue(DEFAULT_FLUSH_LIMIT, null, new QueueIterateAction() {
return iterQueue(DEFAULT_FLUSH_LIMIT, filter, new QueueIterateAction() {
@Override
public void actMessage(Transaction tx, MessageReference ref) throws Exception {