This commit is contained in:
artnaseef 2015-03-06 10:35:52 -07:00
commit dd35e357e3
2 changed files with 1 additions and 32 deletions

View File

@ -26,7 +26,6 @@ import java.util.List;
import java.util.Set;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.filter.DestinationFilter;
import org.apache.activemq.filter.DestinationMap;
import org.apache.activemq.filter.DestinationMapEntry;
@ -171,19 +170,7 @@ public class DefaultAuthorizationMap extends DestinationMap implements Authoriza
}
return answer;
}
Set answer = findWildcardMatches(key);
if (key.isPattern()) {
for (Iterator<Object> iterator = answer.iterator(); iterator.hasNext(); ) {
AuthorizationEntry entry = (AuthorizationEntry)iterator.next();
DestinationFilter filter = DestinationFilter.parseFilter(entry.getDestination());
if (!filter.matches(key)) {
iterator.remove();
}
}
}
return answer;
return findWildcardMatches(key);
}

View File

@ -89,24 +89,6 @@ public class AuthorizationMapTest extends TestCase {
assertTrue("Contains users group", tempAdminACLs.contains(TEMP_DESTINATION_ADMINS));
}
public void testWildcardSubscriptions() {
AuthorizationMap map = createAuthorizationMap();
Set<?> readACLs = map.getReadACLs(new ActiveMQQueue(">"));
assertEquals("set size: " + readACLs, 1, readACLs.size());
assertTrue("Contains admins group", readACLs.contains(ADMINS));
assertFalse("Contains users group", readACLs.contains(USERS));
readACLs = map.getReadACLs(new ActiveMQQueue("USERS.>"));
assertEquals("set size: " + readACLs, 2, readACLs.size());
assertTrue("Contains admins group", readACLs.contains(ADMINS));
assertTrue("Contains users group", readACLs.contains(USERS));
readACLs = map.getReadACLs(new ActiveMQQueue("USERS.FOO.>"));
assertEquals("set size: " + readACLs, 2, readACLs.size());
assertTrue("Contains admins group", readACLs.contains(ADMINS));
assertTrue("Contains users group", readACLs.contains(USERS));
}
protected AuthorizationMap createWildcardAuthorizationMap() {
DefaultAuthorizationMap answer = new DefaultAuthorizationMap();