The testcase would wait for all the messages to arrive. But in the topic case the total number of messages computed was wrong and the test would not wait long enough.
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/QueueSubscriptionTest.java