Added test for MessageGroup types with options
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/7f17f49d Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/7f17f49d Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/7f17f49d Branch: refs/heads/trunk Commit: 7f17f49d730b9e8cb465e79cd82728de08f9b1e0 Parents: cd4b229 Author: rajdavies <[email protected]> Authored: Fri Oct 11 11:07:51 2013 +0100 Committer: rajdavies <[email protected]> Committed: Fri Oct 11 11:07:51 2013 +0100 ---------------------------------------------------------------------- .../broker/policy/MessageGroupConfigTest.java | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/7f17f49d/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/MessageGroupConfigTest.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/MessageGroupConfigTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/MessageGroupConfigTest.java index a789e53..112cc46 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/MessageGroupConfigTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/MessageGroupConfigTest.java @@ -50,6 +50,12 @@ public class MessageGroupConfigTest extends TestSupport { doTestGroupConfiguration("cached",CachedMessageGroupMap.class); } + public void testCachedGroupConfigurationWithCacheSize() throws Exception { + CachedMessageGroupMap result = (CachedMessageGroupMap) doTestGroupConfiguration("cached?cacheSize=10",CachedMessageGroupMap.class); + assertEquals(10,result.getMaximumCacheSize()); + + } + public void testSimpleGroupConfiguration() throws Exception { doTestGroupConfiguration("simple", SimpleMessageGroupMap.class); } @@ -58,7 +64,12 @@ public class MessageGroupConfigTest extends TestSupport { doTestGroupConfiguration("bucket", MessageGroupHashBucket.class); } - public void doTestGroupConfiguration(String type, Class classType) throws Exception { + public void testBucketGroupConfigurationWithBucketCount() throws Exception { + MessageGroupHashBucket result = (MessageGroupHashBucket) doTestGroupConfiguration("bucket?bucketCount=2", MessageGroupHashBucket.class); + assertEquals(2,result.getBucketCount()); + } + + public MessageGroupMap doTestGroupConfiguration(String type, Class classType) throws Exception { broker = new BrokerService(); PolicyEntry defaultEntry = new PolicyEntry(); @@ -75,7 +86,7 @@ public class MessageGroupConfigTest extends TestSupport { MessageGroupMap messageGroupMap = brokerDestination.getMessageGroupOwners(); assertNotNull(messageGroupMap); assertTrue(messageGroupMap.getClass().isAssignableFrom(classType)); - + return messageGroupMap; }
