public class org.apache.activemq.plugin.util.PolicyEntryUtil extends java.lang.Object
{
public void <init>()
{
org.apache.activemq.plugin.util.PolicyEntryUtil v;
v := @this: org.apache.activemq.plugin.util.PolicyEntryUtil;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static org.apache.activemq.broker.region.policy.PolicyEntry findEntryByDestination(org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker, org.apache.activemq.broker.region.policy.PolicyEntry)
{
org.apache.activemq.broker.BrokerService v;
java.util.Iterator v;
java.util.Set v;
org.apache.activemq.broker.region.policy.PolicyMap v;
org.apache.activemq.command.ActiveMQDestination v, v, v;
org.apache.activemq.broker.region.policy.PolicyEntry v, v;
java.lang.Object v;
boolean v, v;
org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker v;
v := @parameter: org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.broker.region.policy.PolicyEntry;
v = virtualinvoke v.<org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker: 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()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyMap: java.util.Set get(org.apache.activemq.command.ActiveMQDestination)>(v);
v = null;
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 = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = v;
label:
return v;
}
public static void applyRetrospectively(org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker, org.apache.activemq.broker.region.policy.PolicyEntry)
{
org.apache.activemq.broker.region.policy.PolicyEntry v;
org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker v;
v := @parameter: org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.broker.region.policy.PolicyEntry;
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);
return;
}
public static void applyRetrospectively(org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker, org.apache.activemq.broker.region.policy.PolicyEntry, java.util.Set)
{
org.apache.activemq.broker.region.policy.PolicyMap v;
org.apache.activemq.broker.Broker v;
java.lang.String v;
boolean v, v, v, v, v;
org.apache.activemq.broker.BrokerService v;
java.util.Iterator v;
java.util.Set v, v;
org.apache.activemq.command.ActiveMQDestination v, v, v, v;
org.apache.activemq.broker.region.policy.PolicyEntry v, v;
java.lang.Object v;
org.apache.activemq.broker.region.Destination v;
org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker v;
v := @parameter: org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.broker.region.policy.PolicyEntry;
v := @parameter: java.util.Set;
v = virtualinvoke v.<org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getRegionBroker()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.RegionBroker: java.util.Set getDestinations(org.apache.activemq.command.ActiveMQDestination)>(v);
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 = virtualinvoke v.<org.apache.activemq.broker.region.RegionBroker: org.apache.activemq.broker.region.policy.PolicyMap getDestinationPolicy()>();
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.ActiveMQDestination getActiveMQDestination()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyMap: org.apache.activemq.broker.region.policy.PolicyEntry getEntryFor(org.apache.activemq.command.ActiveMQDestination)>(v);
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = v;
label:
v = v instanceof org.apache.activemq.broker.region.DestinationFilter;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationFilter: org.apache.activemq.broker.region.Destination getNext()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.ActiveMQDestination getActiveMQDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: void update(org.apache.activemq.broker.region.Queue,java.util.Set)>(v, v);
goto label;
label:
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.ActiveMQDestination getActiveMQDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: void update(org.apache.activemq.broker.region.Topic,java.util.Set)>(v, v);
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.broker.region.Destination)>(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[])>("applied update to:\u0001");
virtualinvoke v.<org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker: void debug(java.lang.String)>(v);
goto label;
label:
return;
}
}