public class org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap extends java.lang.Object implements org.apache.activemq.security.AuthorizationMap { private static final org.slf4j.Logger LOG; private final java.lang.String initialContextFactory; private java.lang.String connectionURL; private java.lang.String connectionUsername; private java.lang.String connectionPassword; private java.lang.String connectionProtocol; private java.lang.String authentication; private int queuePrefixLength; private int topicPrefixLength; private int tempPrefixLength; private java.lang.String queueSearchBase; private java.lang.String topicSearchBase; private java.lang.String tempSearchBase; private java.lang.String permissionGroupMemberAttribute; private java.lang.String adminPermissionGroupSearchFilter; private java.lang.String readPermissionGroupSearchFilter; private java.lang.String writePermissionGroupSearchFilter; private boolean legacyGroupMapping; private java.lang.String groupObjectClass; private java.lang.String userObjectClass; private java.lang.String groupNameAttribute; private java.lang.String userNameAttribute; private int refreshInterval; private boolean refreshDisabled; protected java.lang.String groupClass; private long lastUpdated; private static java.lang.String ANY_DESCENDANT; protected javax.naming.directory.DirContext context; private javax.naming.event.EventDirContext eventContext; private final java.util.concurrent.atomic.AtomicReference map; private final java.util.concurrent.ThreadPoolExecutor updaterService; protected java.util.Map entries; public void () { org.apache.activemq.security.DefaultAuthorizationMap v; java.util.concurrent.ThreadPoolExecutor v, v; java.util.concurrent.ConcurrentHashMap v; java.util.concurrent.LinkedBlockingQueue v; java.util.concurrent.atomic.AtomicReference v; java.util.concurrent.TimeUnit v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$1 v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; int v; java.util.concurrent.ThreadPoolExecutor$DiscardPolicy v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; specialinvoke v.()>(); v. = "com.sun.jndi.ldap.LdapCtxFactory"; v. = "ldap://localhost:1024"; v. = "uid=admin,ou=system"; v. = "s"; v. = "simple"; v. = 4; v. = 4; v. = 4; v. = "ou=Queue,ou=Destination,ou=ActiveMQ,ou=system"; v. = "ou=Topic,ou=Destination,ou=ActiveMQ,ou=system"; v. = "ou=Temp,ou=Destination,ou=ActiveMQ,ou=system"; v. = "member"; v. = "(cn=Admin)"; v. = "(cn=Read)"; v. = "(cn=Write)"; v. = 1; v. = "groupOfNames"; v. = "person"; v. = "cn"; v. = "uid"; v = (int) -1; v. = v; v. = 0; v. = "org.apache.activemq.jaas.GroupPrincipal"; v. = -1L; v = new java.util.concurrent.atomic.AtomicReference; v = new org.apache.activemq.security.DefaultAuthorizationMap; specialinvoke v.()>(); specialinvoke v.(java.lang.Object)>(v); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ThreadPoolExecutor; v = ; v = new java.util.concurrent.LinkedBlockingQueue; specialinvoke v.(int)>(2); v = new org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$1; specialinvoke v.(org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap)>(v); specialinvoke v.(int,int,long,java.util.concurrent.TimeUnit,java.util.concurrent.BlockingQueue,java.util.concurrent.ThreadFactory)>(0, 1, 60L, v, v, v); v. = v; v = v.; v = new java.util.concurrent.ThreadPoolExecutor$DiscardPolicy; specialinvoke v.()>(); virtualinvoke v.(v); return; } protected javax.naming.directory.DirContext createContext() throws javax.naming.NamingException { javax.naming.NamingException v, v; javax.naming.directory.InitialDirContext v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; java.util.Hashtable v; boolean v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v = new java.util.Hashtable; specialinvoke v.()>(); virtualinvoke v.("java.naming.factory.initial", "com.sun.jndi.ldap.LdapCtxFactory"); v = v.; if v == null goto label; v = ""; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; virtualinvoke v.("java.naming.security.principal", v); goto label; label: v = new javax.naming.NamingException; specialinvoke v.(java.lang.String)>("Empty username is not allowed"); throw v; label: v = v.; if v == null goto label; v = ""; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; virtualinvoke v.("java.naming.security.credentials", v); goto label; label: v = new javax.naming.NamingException; specialinvoke v.(java.lang.String)>("Empty password is not allowed"); throw v; label: v = v.; virtualinvoke v.("java.naming.security.protocol", v); v = v.; virtualinvoke v.("java.naming.provider.url", v); v = v.; virtualinvoke v.("java.naming.security.authentication", v); v = new javax.naming.directory.InitialDirContext; specialinvoke v.(java.util.Hashtable)>(v); return v; } protected boolean isContextAlive() { org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; javax.naming.directory.DirContext v, v; java.lang.Exception v; boolean v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v = 0; v = v.; if v == null goto label; label: v = v.; interfaceinvoke v.(""); v = 1; label: goto label; label: v := @caughtexception; label: return v; catch java.lang.Exception from label to label with label; } protected javax.naming.directory.DirContext open() throws javax.naming.NamingException { javax.naming.NamingException v; javax.naming.event.EventDirContext v, v, v, v, v; boolean v, v; javax.naming.directory.SearchControls v, v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType v, v, v, v, v; int v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType v, v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$CachedLDAPAuthorizationMapNamespaceChangeListener v, v, v, v, v; javax.naming.directory.DirContext v, v, v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType[] v, v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; java.lang.Object v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v = virtualinvoke v.(); if v == 0 goto label; v = v.; return v; label: v = virtualinvoke v.(); v. = v; v = v.; v = (int) -1; if v != v goto label; v = v.; if v != 0 goto label; v = v.; v = interfaceinvoke v.(""); v. = v; v = new javax.naming.directory.SearchControls; specialinvoke v.()>(); virtualinvoke v.(2); v = staticinvoke (); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; v = v.; v = virtualinvoke v.(v); v = new org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$CachedLDAPAuthorizationMapNamespaceChangeListener; v = ; specialinvoke v.(org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap,org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType,org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType)>(v, v, v); interfaceinvoke v.(v, v, v, v); v = v + 1; goto label; label: v = v.; v = v.; v = new javax.naming.directory.SearchControls; specialinvoke v.()>(); v = new org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$CachedLDAPAuthorizationMapNamespaceChangeListener; v = ; specialinvoke v.(org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap,org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType,org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType)>(v, v, null); interfaceinvoke v.(v, "cn=*", v, v); v = staticinvoke (); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; v = v.; v = virtualinvoke v.(v); v = new org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$CachedLDAPAuthorizationMapNamespaceChangeListener; v = ; specialinvoke v.(org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap,org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType,org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType)>(v, v, v); interfaceinvoke v.(v, v, v, v); v = v + 1; goto label; label: v = v.; v = v.; v = new javax.naming.directory.SearchControls; specialinvoke v.()>(); v = new org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$CachedLDAPAuthorizationMapNamespaceChangeListener; v = ; specialinvoke v.(org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap,org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType,org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType)>(v, v, null); interfaceinvoke v.(v, "cn=*", v, v); v = staticinvoke (); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; v = v.; v = virtualinvoke v.(v); v = new org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$CachedLDAPAuthorizationMapNamespaceChangeListener; v = ; specialinvoke v.(org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap,org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType,org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType)>(v, v, v); interfaceinvoke v.(v, v, v, v); v = v + 1; goto label; label: v := @caughtexception; v. = null; throw v; label: v = v.; return v; catch javax.naming.NamingException from label to label with label; } protected synchronized void query() throws java.lang.Exception { org.apache.activemq.security.DefaultAuthorizationMap v; java.util.Map v, v; java.util.Collection v; java.lang.Exception v, v, v; javax.naming.NamingEnumeration v, v, v; java.lang.Object[] v, v, v; java.util.concurrent.atomic.AtomicReference v; javax.naming.directory.SearchControls v; java.util.ArrayList v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType v, v, v; int v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType v, v, v; org.slf4j.Logger v, v, v; javax.naming.directory.DirContext v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType[] v, v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v = virtualinvoke v.(); v = v.; interfaceinvoke v.(); v = new javax.naming.directory.SearchControls; specialinvoke v.()>(); virtualinvoke v.(2); v = new org.apache.activemq.security.DefaultAuthorizationMap; specialinvoke v.()>(); v = staticinvoke (); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; label: v = v.; v = virtualinvoke v.(v); v = interfaceinvoke v.(v, v, v); v = ; virtualinvoke v.(v, v, v, v); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[3]; v = v.; v[0] = v; v = virtualinvoke v.(v); v[1] = v; v[2] = v; interfaceinvoke v.("Policy not applied!. Error processing policy under \'{}\' with filter \'{}\'", v); label: v = v + 1; goto label; label: v = staticinvoke (); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; label: v = v.; v = virtualinvoke v.(v); v = interfaceinvoke v.(v, v, v); v = ; virtualinvoke v.(v, v, v, v); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[3]; v = v.; v[0] = v; v = virtualinvoke v.(v); v[1] = v; v[2] = v; interfaceinvoke v.("Policy not applied!. Error processing policy under \'{}\' with filter \'{}\'", v); label: v = v + 1; goto label; label: v = staticinvoke (); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; label: v = v.; v = virtualinvoke v.(v); v = interfaceinvoke v.(v, v, v); v = ; virtualinvoke v.(v, v, v, v); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[3]; v = v.; v[0] = v; v = virtualinvoke v.(v); v[1] = v; v[2] = v; interfaceinvoke v.("Policy not applied!. Error processing policy under \'{}\' with filter \'{}\'", v); label: v = v + 1; goto label; label: v = new java.util.ArrayList; v = v.; v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); virtualinvoke v.(); return; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; } protected void processQueryResults(org.apache.activemq.security.DefaultAuthorizationMap, javax.naming.NamingEnumeration, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType) throws java.lang.Exception { javax.naming.ldap.LdapName v; org.slf4j.Logger v; org.apache.activemq.security.DefaultAuthorizationMap v; org.apache.activemq.security.AuthorizationEntry v; java.lang.Exception v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType v; javax.naming.NamingEnumeration v; java.lang.Object v; java.lang.String v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType v; boolean v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: org.apache.activemq.security.DefaultAuthorizationMap; v := @parameter: javax.naming.NamingEnumeration; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType; label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: v = new javax.naming.ldap.LdapName; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Policy not applied! Error parsing authorization policy entry under {}", v, v); goto label; label: virtualinvoke v.(v, v, v); goto label; label: return; catch java.lang.Exception from label to label with label; } protected void updated() { org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; long v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v = staticinvoke (); v. = v; return; } protected org.apache.activemq.security.AuthorizationEntry getEntry(org.apache.activemq.security.DefaultAuthorizationMap, javax.naming.ldap.LdapName, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType) { javax.naming.ldap.LdapName v; org.apache.activemq.security.DefaultAuthorizationMap v; org.apache.activemq.security.AuthorizationEntry v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType v; int[] v; java.util.Map v, v; int v, v, v, v, v, v, v, v; java.lang.String v; java.lang.IllegalArgumentException v, v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; org.apache.activemq.security.TempDestinationAuthorizationEntry v; java.lang.Object v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: org.apache.activemq.security.DefaultAuthorizationMap; v := @parameter: javax.naming.ldap.LdapName; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType; v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; default: goto label; }; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v + 1; if v == v goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Malformed policy structure for a temporary destination policy entry. The permission group entries should be immediately below the temporary policy base DN."); throw v; label: v = virtualinvoke v.(); if v != null goto label; v = new org.apache.activemq.security.TempDestinationAuthorizationEntry; specialinvoke v.()>(); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v + 2; if v == v goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Malformed policy structure for a queue or topic destination policy entry. The destination pattern and permission group entries should be nested below the queue or topic policy base DN."); throw v; label: v = virtualinvoke v.(v, v); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.activemq.security.AuthorizationEntry; specialinvoke v.()>(); v = v; virtualinvoke v.(v); v = v.; interfaceinvoke v.(v, v); goto label; label: v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown destination type \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; } protected void applyACL(org.apache.activemq.security.AuthorizationEntry, javax.naming.directory.SearchResult, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType) throws javax.naming.NamingException { org.apache.activemq.security.AuthorizationEntry v; javax.naming.NamingException v, v; javax.naming.directory.Attribute v, v, v, v; boolean v, v, v, v, v, v, v; java.lang.Exception v, v; javax.naming.directory.Attributes v, v; javax.naming.NamingEnumeration v, v; javax.naming.directory.SearchResult v; java.lang.Object[] v, v, v; java.lang.String[] v; java.util.concurrent.atomic.AtomicReference v; java.util.HashSet v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType v; org.slf4j.Logger v, v, v, v, v; javax.naming.directory.DirContext v; org.apache.activemq.jaas.UserPrincipal v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; java.lang.Object v, v, v, v, v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: org.apache.activemq.security.AuthorizationEntry; v := @parameter: javax.naming.directory.SearchResult; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType; v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = new java.util.HashSet; specialinvoke v.()>(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = 0; v = 0; v = v.; if v != 0 goto label; label: v = v.; v = newarray (java.lang.String)[3]; v[0] = "objectClass"; v = v.; v[1] = v; v = v.; v[2] = v; v = interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v = virtualinvoke v.(); v[1] = v; v[2] = v; interfaceinvoke v.("Policy not applied! Unknown member {} in policy entry {}", v); goto label; label: v = interfaceinvoke v.("objectClass"); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = 1; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v = v.; v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Policy not applied! Group {} does not have name attribute {} under entry {}", v); goto label; label: v = interfaceinvoke v.(); label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = 1; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v = v.; v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Policy not applied! User {} does not have name attribute {} under entry {}", v); goto label; label: interfaceinvoke v.(); goto label; label: v = 1; v = virtualinvoke v.("(cn|CN)=", ""); label: if v != 0 goto label; if v == 0 goto label; label: if v == 0 goto label; if v == 0 goto label; label: v = ; v = virtualinvoke v.(); interfaceinvoke v.("Policy not applied! Can\'t determine type of member {} under entry {}", v, v); goto label; label: if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; if v != 0 goto label; label: v = virtualinvoke v.(); v = staticinvoke (v, v); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new javax.naming.NamingException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Can\'t create a group \u of class \u0001"); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); throw v; label: if v != 0 goto label; if v == 0 goto label; v = new org.apache.activemq.jaas.UserPrincipal; specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); goto label; label: virtualinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Policy not applied! Error adding principals to ACL under {}", v, v); label: return; catch javax.naming.NamingException from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; } protected void applyAcl(org.apache.activemq.security.AuthorizationEntry, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType, java.util.Set) { java.util.Set v; org.apache.activemq.security.AuthorizationEntry v; java.lang.IllegalArgumentException v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; int[] v; int v, v; java.lang.String v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: org.apache.activemq.security.AuthorizationEntry; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType; v := @parameter: java.util.Set; v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; default: goto label; }; label: virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); goto label; label: v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown permission \u."); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } protected org.apache.activemq.command.ActiveMQDestination formatDestination(javax.naming.ldap.LdapName, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType) { javax.naming.ldap.LdapName v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType v; int[] v; int v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v; java.lang.IllegalArgumentException v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; javax.naming.ldap.Rdn v, v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: javax.naming.ldap.LdapName; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType; v = ; v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 2: goto label; case 3: goto label; default: goto label; }; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v + 2; if v != v goto label; v = virtualinvoke v.(); v = v - 2; v = virtualinvoke v.(v); v = virtualinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v + 1; if v != v goto label; v = virtualinvoke v.(); v = v - 1; v = virtualinvoke v.(v); v = virtualinvoke v.(v, v); goto label; label: v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Malformed DN for representing a permission or destination entry."); throw v; label: v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot format destination for destination type \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; } protected org.apache.activemq.command.ActiveMQDestination formatDestination(javax.naming.ldap.Rdn, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType) { org.apache.activemq.command.ActiveMQQueue v; java.lang.IllegalArgumentException v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ActiveMQTopic v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType v; javax.naming.ldap.Rdn v; int[] v; int v, v; java.lang.String v, v, v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: javax.naming.ldap.Rdn; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType; v = ; v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 2: goto label; case 3: goto label; default: goto label; }; label: v = new org.apache.activemq.command.ActiveMQQueue; v = virtualinvoke v.(v); specialinvoke v.(java.lang.String)>(v); v = v; goto label; label: v = new org.apache.activemq.command.ActiveMQTopic; v = virtualinvoke v.(v); specialinvoke v.(java.lang.String)>(v); v = v; goto label; label: v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown destination type: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; } protected java.lang.String formatDestinationName(javax.naming.ldap.Rdn) { org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; javax.naming.ldap.Rdn v; java.lang.Object v; java.lang.String v, v, v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: javax.naming.ldap.Rdn; v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v, ">"); return v; } protected java.util.Set transcribeSet(java.util.Set) { java.util.HashSet v; java.util.Set v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: java.util.Set; if v == null goto label; v = new java.util.HashSet; specialinvoke v.(java.util.Collection)>(v); return v; label: return null; } protected java.lang.String getFilterForPermissionType(org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType) { java.lang.IllegalArgumentException v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; int[] v; int v, v; java.lang.String v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType; v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; default: goto label; }; label: v = v.; goto label; label: v = v.; goto label; label: v = v.; goto label; label: v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown permission type \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; } protected int getPrefixLengthForDestinationType(org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType) { java.lang.IllegalArgumentException v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType v; int[] v; int v, v, v; java.lang.String v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType; v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; default: goto label; }; label: v = v.; goto label; label: v = v.; goto label; label: v = v.; goto label; label: v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown permission type \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; } protected void checkForUpdates() { java.util.concurrent.ThreadPoolExecutor v; long v, v, v, v; byte v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$2 v; int v, v, v; boolean v, v; org.slf4j.Logger v; javax.naming.directory.DirContext v, v; java.lang.Exception v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v = v.; v = v cmp -1L; if v != 0 goto label; label: virtualinvoke v.(); label: return; label: v := @caughtexception; v = ; interfaceinvoke v.("Error updating authorization map. Partial policy may be applied until the next successful update.", v); label: v = v.; if v == null goto label; v = v.; if v == 0 goto label; return; label: v = v.; if v == null goto label; v = v.; if v != 0 goto label; v = v.; v = (int) -1; if v == v goto label; v = staticinvoke (); v = v.; v = v.; v = v + v; v = v cmp v; if v < 0 goto label; label: v = v.; v = new org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$2; specialinvoke v.(org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap)>(v); virtualinvoke v.(v); label: return; catch java.lang.Exception from label to label with label; } public java.util.Set getTempDestinationAdminACLs() { org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; java.util.Set v, v; java.lang.Object v; java.util.concurrent.atomic.AtomicReference v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; } public java.util.Set getTempDestinationReadACLs() { org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; java.util.Set v, v; java.lang.Object v; java.util.concurrent.atomic.AtomicReference v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; } public java.util.Set getTempDestinationWriteACLs() { org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; java.util.Set v, v; java.lang.Object v; java.util.concurrent.atomic.AtomicReference v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; } public java.util.Set getAdminACLs(org.apache.activemq.command.ActiveMQDestination) { org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; java.util.Set v; java.lang.Object v; java.util.concurrent.atomic.AtomicReference v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: org.apache.activemq.command.ActiveMQDestination; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; } public java.util.Set getReadACLs(org.apache.activemq.command.ActiveMQDestination) { org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; java.util.Set v; java.lang.Object v; java.util.concurrent.atomic.AtomicReference v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: org.apache.activemq.command.ActiveMQDestination; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; } public java.util.Set getWriteACLs(org.apache.activemq.command.ActiveMQDestination) { org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; java.util.Set v; java.lang.Object v; java.util.concurrent.atomic.AtomicReference v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: org.apache.activemq.command.ActiveMQDestination; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; } public void objectAdded(javax.naming.event.NamingEvent, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType) { javax.naming.event.NamingEvent v; javax.naming.ldap.LdapName v; org.apache.activemq.security.AuthorizationEntry v; java.util.concurrent.atomic.AtomicReference v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType v; java.lang.String v, v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType v; boolean v; org.slf4j.Logger v, v, v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; javax.naming.InvalidNameException v; javax.naming.Binding v, v; java.lang.Object v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: javax.naming.event.NamingEvent; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Adding object: {}", v); v = virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = new javax.naming.ldap.LdapName; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v, v, v); virtualinvoke v.(v, v, v); v = v instanceof org.apache.activemq.security.TempDestinationAuthorizationEntry; if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Policy not applied! Error parsing DN for addition of {}", v, v); goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Policy not applied! Error processing object addition for addition of {}", v, v); label: return; catch javax.naming.InvalidNameException from label to label with label; catch java.lang.Exception from label to label with label; } public void objectRemoved(javax.naming.event.NamingEvent, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType) { javax.naming.event.NamingEvent v; javax.naming.ldap.LdapName v; org.apache.activemq.security.AuthorizationEntry v; java.util.concurrent.atomic.AtomicReference v; java.util.HashSet v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType v; java.lang.String v, v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType v; org.slf4j.Logger v, v, v; java.lang.Exception v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; javax.naming.InvalidNameException v; javax.naming.Binding v, v; java.lang.Object v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: javax.naming.event.NamingEvent; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Removing object: {}", v); v = virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = new javax.naming.ldap.LdapName; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v, v, v); v = new java.util.HashSet; specialinvoke v.()>(); virtualinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Policy not applied! Error parsing DN for object removal for removal of {}", v, v); goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Policy not applied! Error processing object removal for removal of {}", v, v); label: return; catch javax.naming.InvalidNameException from label to label with label; catch java.lang.Exception from label to label with label; } public void objectRenamed(javax.naming.event.NamingEvent, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType, org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType) { javax.naming.event.NamingEvent v; java.util.Map v, v; boolean v, v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v, v; javax.naming.NamingEnumeration v; java.lang.Object[] v, v; javax.naming.ldap.LdapName v, v; java.util.concurrent.atomic.AtomicReference v; javax.naming.directory.SearchControls v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType v; int v, v; java.lang.String v, v, v, v, v, v, v, v, v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType v, v; org.slf4j.Logger v, v, v, v, v; javax.naming.directory.DirContext v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType[] v; org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap v; javax.naming.InvalidNameException v; javax.naming.Binding v, v; java.lang.Object v, v; v := @this: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap; v := @parameter: javax.naming.event.NamingEvent; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$DestinationType; v := @parameter: org.apache.activemq.security.SimpleCachedLDAPAuthorizationMap$PermissionType; v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; interfaceinvoke v.("Renaming object: {} to {}", v, v); label: v = new javax.naming.ldap.LdapName; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v, v); v = new javax.naming.ldap.LdapName; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v, v); if v == null goto label; virtualinvoke v.(v, v, v); v = new javax.naming.directory.SearchControls; specialinvoke v.()>(); virtualinvoke v.(0); v = 0; v = staticinvoke (); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; v = virtualinvoke v.(v); v = interfaceinvoke v.(v, v, v); v = interfaceinvoke v.(); if v == 0 goto label; virtualinvoke v.(v, v, v); v = 1; goto label; label: v = v + 1; goto label; label: if v != 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("Policy not applied! Error processing object rename for rename of {} to {}. Could not determine permission type of new object.", v, v); goto label; label: if v == null goto label; if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; virtualinvoke v.(v); v = v.