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

Added test for MessageGroup types with options

This commit is contained in:
rajdavies 2013-10-11 11:07:51 +01:00
parent cd4b229f22
commit 7f17f49d73
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/MessageGroupConfigTest.java
View File

@ -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;
}