1 18 package org.apache.activemq.broker.virtual; 19 20 import org.apache.activemq.spring.ConsumerBean; 21 22 25 public class FilteredQueueTest extends CompositeQueueTest { 26 27 @Override  28 protected String getBrokerConfigUri() { 29 return "org/apache/activemq/broker/virtual/filtered-queue.xml"; 30 } 31 32 @Override  33 protected void assertMessagesArrived(ConsumerBean messageList1, ConsumerBean messageList2) { 34 messageList1.assertMessagesArrived(total / 2); 35 messageList2.assertMessagesArrived(1); 36 } 37 } 38 | Popular Tags |