Updated Branches: refs/heads/trunk 96bdda716 -> 6509b1f81
Added timeout because of tests failing intermittently Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/6509b1f8 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/6509b1f8 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/6509b1f8 Branch: refs/heads/trunk Commit: 6509b1f8114e326293b76def73a66790bd4feb90 Parents: 96bdda7 Author: Kevin Earls <[email protected]> Authored: Fri Jan 3 15:16:11 2014 +0100 Committer: Kevin Earls <[email protected]> Committed: Fri Jan 3 15:16:11 2014 +0100 ---------------------------------------------------------------------- .../apache/activemq/broker/policy/DeadLetterTestSupport.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/6509b1f8/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/DeadLetterTestSupport.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/DeadLetterTestSupport.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/DeadLetterTestSupport.java index 7b7aa7b..13be9dd 100755 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/DeadLetterTestSupport.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/DeadLetterTestSupport.java @@ -194,11 +194,15 @@ public abstract class DeadLetterTestSupport extends TestSupport { } private void validateConsumerPrefetch(String destination, long expectedCount) { + try { + Thread.sleep(100); + } catch (InterruptedException e) { + } RegionBroker regionBroker = (RegionBroker) broker.getRegionBroker(); for (org.apache.activemq.broker.region.Destination dest : regionBroker.getQueueRegion().getDestinationMap().values()) { if (dest.getName().equals(destination)) { DestinationStatistics stats = dest.getDestinationStatistics(); - LOG.info("inflight for : " + dest.getName() + ": " + stats.getInflight().getCount()); + LOG.info(">>>> inflight for : " + dest.getName() + ": " + stats.getInflight().getCount()); assertEquals("inflight for: " + dest.getName() + ": " + stats.getInflight().getCount() + " matches", expectedCount, stats.getInflight().getCount()); }
