public class org.apache.activemq.broker.UserIDBroker extends org.apache.activemq.broker.BrokerFilter
{
boolean useAuthenticatePrincipal;
public void <init>(org.apache.activemq.broker.Broker)
{
org.apache.activemq.broker.Broker v;
org.apache.activemq.broker.UserIDBroker v;
v := @this: org.apache.activemq.broker.UserIDBroker;
v := @parameter: org.apache.activemq.broker.Broker;
specialinvoke v.<org.apache.activemq.broker.BrokerFilter: void <init>(org.apache.activemq.broker.Broker)>(v);
v.<org.apache.activemq.broker.UserIDBroker: boolean useAuthenticatePrincipal> = 0;
return;
}
public void send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message) throws java.lang.Exception
{
org.apache.activemq.security.SecurityContext v;
java.util.Iterator v;
java.util.Set v;
org.apache.activemq.broker.UserIDBroker v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
java.lang.Object v;
java.lang.String v, v;
org.apache.activemq.broker.ProducerBrokerExchange v;
boolean v, v, v, v;
v := @this: org.apache.activemq.broker.UserIDBroker;
v := @parameter: org.apache.activemq.broker.ProducerBrokerExchange;
v := @parameter: org.apache.activemq.command.Message;
v = virtualinvoke v.<org.apache.activemq.broker.ProducerBrokerExchange: org.apache.activemq.broker.ConnectionContext getConnectionContext()>();
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: boolean isNetworkConnection()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: java.lang.String getUserID()>();
if v == null goto label;
specialinvoke v.<org.apache.activemq.broker.BrokerFilter: void send(org.apache.activemq.broker.ProducerBrokerExchange,org.apache.activemq.command.Message)>(v, v);
return;
label:
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: java.lang.String getUserName()>();
v = virtualinvoke v.<org.apache.activemq.broker.UserIDBroker: boolean isUseAuthenticatePrincipal()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.security.SecurityContext getSecurityContext()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.security.SecurityContext: java.util.Set getPrincipals()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v instanceof org.apache.activemq.jaas.UserPrincipal;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.jaas.UserPrincipal: java.lang.String getName()>();
label:
virtualinvoke v.<org.apache.activemq.command.Message: void setUserID(java.lang.String)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerFilter: void send(org.apache.activemq.broker.ProducerBrokerExchange,org.apache.activemq.command.Message)>(v, v);
return;
}
public boolean isUseAuthenticatePrincipal()
{
org.apache.activemq.broker.UserIDBroker v;
boolean v;
v := @this: org.apache.activemq.broker.UserIDBroker;
v = v.<org.apache.activemq.broker.UserIDBroker: boolean useAuthenticatePrincipal>;
return v;
}
public void setUseAuthenticatePrincipal(boolean)
{
org.apache.activemq.broker.UserIDBroker v;
boolean v;
v := @this: org.apache.activemq.broker.UserIDBroker;
v := @parameter: boolean;
v.<org.apache.activemq.broker.UserIDBroker: boolean useAuthenticatePrincipal> = v;
return;
}
}