public class org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker extends org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker
{
public static final org.slf4j.Logger LOG;
public void <init>(org.apache.activemq.broker.Broker)
{
org.apache.activemq.broker.Broker v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.broker.Broker;
specialinvoke v.<org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker: void <init>(org.apache.activemq.broker.Broker)>(v);
return;
}
public void setVirtualDestinations(org.apache.activemq.broker.region.virtual.VirtualDestination[])
{
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
org.apache.activemq.broker.region.virtual.VirtualDestination[] v;
java.util.concurrent.ConcurrentLinkedQueue v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker$1 v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.broker.region.virtual.VirtualDestination[];
v = v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: java.util.concurrent.ConcurrentLinkedQueue addDestinationWork>;
v = new org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker$1;
specialinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker$1: void <init>(org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker,org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker,org.apache.activemq.broker.region.virtual.VirtualDestination[])>(v, v, v);
virtualinvoke v.<java.util.concurrent.ConcurrentLinkedQueue: boolean add(java.lang.Object)>(v);
return;
}
public void setVirtualDestinations(org.apache.activemq.broker.region.virtual.VirtualDestination[], boolean) throws java.lang.Exception
{
org.apache.activemq.broker.region.virtual.VirtualDestination[] v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
boolean v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.broker.region.virtual.VirtualDestination[];
v := @parameter: boolean;
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void setVirtualDestinations(org.apache.activemq.broker.region.virtual.VirtualDestination[])>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void applyDestinationWork()>();
label:
return;
}
public void setDestinations(org.apache.activemq.command.ActiveMQDestination[])
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
java.lang.Exception v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.broker.ConnectionContext v;
int v, v;
java.lang.String v, v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.command.ActiveMQDestination[];
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
label:
v = virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: boolean containsDestination(org.apache.activemq.command.ActiveMQDestination)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.ConnectionContext getAdminConnectionContext()>();
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.region.Destination addDestination(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ActiveMQDestination,boolean)>(v, v, 1);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ActiveMQDestination)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Added destination \u0001");
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ActiveMQDestination)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to add a new destination for: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String,java.lang.Throwable)>(v, v);
label:
v = v + 1;
goto label;
label:
return;
catch java.lang.Exception from label to label with label;
}
protected boolean containsDestination(org.apache.activemq.command.ActiveMQDestination) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
org.apache.activemq.broker.Broker v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getRegionBroker()>();
v = interfaceinvoke v.<org.apache.activemq.broker.Broker: org.apache.activemq.command.ActiveMQDestination[] getDestinations()>();
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>(v);
return v;
}
public void addNewDestination(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
java.lang.String v, v;
java.lang.Exception v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
label:
v = virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.ConnectionContext getAdminConnectionContext()>();
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.region.Destination addDestination(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ActiveMQDestination,boolean)>(v, v, 1);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ActiveMQDestination)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Added destination \u0001");
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ActiveMQDestination)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to add a new destination for: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String,java.lang.Throwable)>(v, v);
label:
return;
catch java.lang.Exception from label to label with label;
}
public void addNetworkConnector(org.apache.activemq.network.DiscoveryNetworkConnector)
{
org.apache.activemq.broker.BrokerService v, v, v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
java.lang.Exception v;
java.util.List v;
java.lang.String v, v, v;
boolean v;
org.apache.activemq.network.DiscoveryNetworkConnector v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.network.DiscoveryNetworkConnector;
label:
v = virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.util.List getNetworkConnectors()>();
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.network.NetworkConnector addNetworkConnector(org.apache.activemq.network.NetworkConnector)>(v);
v = virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void startNetworkConnector(org.apache.activemq.network.NetworkConnector,java.util.concurrent.ThreadPoolExecutor)>(v, null);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.network.DiscoveryNetworkConnector)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("started new network connector: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String)>(v);
goto label;
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.network.DiscoveryNetworkConnector)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("skipping network connector add, already exists: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.network.DiscoveryNetworkConnector)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to add new networkConnector \u0001");
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String,java.lang.Throwable)>(v, v);
label:
return;
catch java.lang.Exception from label to label with label;
}
public void updateNetworkConnector(org.apache.activemq.network.DiscoveryNetworkConnector)
{
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
org.apache.activemq.network.DiscoveryNetworkConnector v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.network.DiscoveryNetworkConnector;
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void removeNetworkConnector(org.apache.activemq.network.DiscoveryNetworkConnector)>(v);
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void addNetworkConnector(org.apache.activemq.network.DiscoveryNetworkConnector)>(v);
return;
}
public void removeNetworkConnector(org.apache.activemq.network.DiscoveryNetworkConnector)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
java.lang.String v, v;
java.lang.Exception v;
boolean v;
org.apache.activemq.network.DiscoveryNetworkConnector v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.network.DiscoveryNetworkConnector;
v = virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean removeNetworkConnector(org.apache.activemq.network.NetworkConnector)>(v);
if v == 0 goto label;
label:
virtualinvoke v.<org.apache.activemq.network.DiscoveryNetworkConnector: void stop()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.network.DiscoveryNetworkConnector)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("stopped and removed networkConnector: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.network.DiscoveryNetworkConnector)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to stop removed network connector: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String)>(v);
label:
return;
catch java.lang.Exception from label to label with label;
}
public void addNewPolicyEntry(org.apache.activemq.broker.region.policy.PolicyEntry)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.region.policy.PolicyEntry v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
org.apache.activemq.broker.region.policy.PolicyMap v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination v, v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.broker.region.policy.PolicyEntry;
v = virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.policy.PolicyMap getDestinationPolicy()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: org.apache.activemq.command.ActiveMQDestination getDestination()>();
virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyMap: void put(org.apache.activemq.command.ActiveMQDestination,java.lang.Object)>(v, v);
staticinvoke <org.apache.activemq.plugin.util.PolicyEntryUtil: void applyRetrospectively(org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker,org.apache.activemq.broker.region.policy.PolicyEntry,java.util.Set)>(v, v, null);
v = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ActiveMQDestination)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("added policy for: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String)>(v);
return;
}
public void modifyPolicyEntry(org.apache.activemq.broker.region.policy.PolicyEntry)
{
org.apache.activemq.broker.region.policy.PolicyEntry v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.broker.region.policy.PolicyEntry;
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void modifyPolicyEntry(org.apache.activemq.broker.region.policy.PolicyEntry,boolean)>(v, 0);
return;
}
public void modifyPolicyEntry(org.apache.activemq.broker.region.policy.PolicyEntry, boolean)
{
org.apache.activemq.broker.region.policy.PolicyEntry v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
boolean v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.broker.region.policy.PolicyEntry;
v := @parameter: boolean;
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void modifyPolicyEntry(org.apache.activemq.broker.region.policy.PolicyEntry,boolean,java.util.Set)>(v, v, null);
return;
}
public void modifyPolicyEntry(org.apache.activemq.broker.region.policy.PolicyEntry, boolean, java.util.Set)
{
java.lang.Throwable v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
org.apache.activemq.broker.region.policy.PolicyMap v;
java.lang.String v, v;
boolean v, v, v;
org.apache.activemq.broker.BrokerService v;
java.util.Set v;
java.lang.IllegalArgumentException v;
org.apache.activemq.command.ActiveMQDestination v, v, v, v, v;
org.apache.activemq.broker.region.policy.PolicyEntry v, v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.broker.region.policy.PolicyEntry;
v := @parameter: boolean;
v := @parameter: java.util.Set;
v = virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.policy.PolicyMap getDestinationPolicy()>();
v = staticinvoke <org.apache.activemq.plugin.util.PolicyEntryUtil: org.apache.activemq.broker.region.policy.PolicyEntry findEntryByDestination(org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker,org.apache.activemq.broker.region.policy.PolicyEntry)>(v, v);
if v == 0 goto label;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: org.apache.activemq.command.ActiveMQDestination getDestination()>();
virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyMap: void put(org.apache.activemq.command.ActiveMQDestination,java.lang.Object)>(v, v);
v = v;
goto label;
label:
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: org.apache.activemq.command.ActiveMQDestination getDestination()>();
virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyMap: void remove(org.apache.activemq.command.ActiveMQDestination,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: org.apache.activemq.command.ActiveMQDestination getDestination()>();
virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyMap: void put(org.apache.activemq.command.ActiveMQDestination,java.lang.Object)>(v, v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v;
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
staticinvoke <org.apache.activemq.plugin.util.PolicyEntryUtil: void applyRetrospectively(org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker,org.apache.activemq.broker.region.policy.PolicyEntry,java.util.Set)>(v, v, v);
v = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ActiveMQDestination)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("updated policy for: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String)>(v);
goto label;
label:
v = new java.lang.IllegalArgumentException;
v = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.broker.region.policy.PolicyEntry,org.apache.activemq.command.ActiveMQDestination)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("The policy can not be updated because it either does not exist or the PolicyEntry reference does not match an existing PolicyEntry in the PolicyMap.  To replace an entry (versus modifying) or add, set createOrReplace to true. \u, destination:\u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void updateSimpleAuthenticationPlugin(org.apache.activemq.security.SimpleAuthenticationPlugin)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
org.apache.activemq.security.SimpleAuthenticationPlugin v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker$2 v;
java.lang.Exception v;
org.apache.activemq.broker.Broker v, v;
java.util.concurrent.ConcurrentLinkedQueue v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.security.SimpleAuthenticationPlugin;
label:
v = virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getBroker()>();
v = interfaceinvoke v.<org.apache.activemq.broker.Broker: org.apache.activemq.broker.Broker getAdaptor(java.lang.Class)>(class "Lorg/apache/activemq/security/SimpleAuthenticationBroker;");
v = v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: java.util.concurrent.ConcurrentLinkedQueue addConnectionWork>;
v = new org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker$2;
specialinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker$2: void <init>(org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker,org.apache.activemq.security.SimpleAuthenticationBroker,org.apache.activemq.security.SimpleAuthenticationPlugin)>(v, v, v);
virtualinvoke v.<java.util.concurrent.ConcurrentLinkedQueue: boolean add(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String,java.lang.Throwable)>("failed to apply SimpleAuthenticationPlugin modifications to SimpleAuthenticationBroker", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
public void updateAuthorizationMap(org.apache.activemq.security.AuthorizationMap)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.Broker v, v;
org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker v;
org.apache.activemq.security.AuthorizationMap v;
java.lang.Exception v;
v := @this: org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.security.AuthorizationMap;
label:
v = virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getBroker()>();
v = interfaceinvoke v.<org.apache.activemq.broker.Broker: org.apache.activemq.broker.Broker getAdaptor(java.lang.Class)>(class "Lorg/apache/activemq/security/AuthorizationBroker;");
virtualinvoke v.<org.apache.activemq.security.AuthorizationBroker: void setAuthorizationMap(org.apache.activemq.security.AuthorizationMap)>(v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: void info(java.lang.String,java.lang.Throwable)>("failed to apply modified AuthorizationMap to AuthorizationBroker", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/plugin/java/JavaRuntimeConfigurationBroker;");
<org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker: org.slf4j.Logger LOG> = v;
return;
}
}