public class org.apache.activemq.plugin.DestinationsProcessor extends org.apache.activemq.plugin.DefaultConfigurationProcessor
{
public void <init>(org.apache.activemq.plugin.RuntimeConfigurationBroker, java.lang.Class)
{
org.apache.activemq.plugin.DestinationsProcessor v;
java.lang.Class v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
v := @this: org.apache.activemq.plugin.DestinationsProcessor;
v := @parameter: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v := @parameter: java.lang.Class;
specialinvoke v.<org.apache.activemq.plugin.DefaultConfigurationProcessor: void <init>(org.apache.activemq.plugin.RuntimeConfigurationBroker,java.lang.Class)>(v, v);
return;
}
public void processChanges(java.util.List, java.util.List)
{
org.apache.activemq.plugin.DestinationsProcessor v;
org.apache.activemq.broker.ConnectionContext v;
java.lang.String v, v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v, v, v, v;
boolean v, v, v;
org.apache.activemq.broker.BrokerService v;
java.util.Iterator v, v;
java.lang.Exception v;
org.apache.activemq.command.ActiveMQDestination v;
java.util.List v, v, v;
java.lang.Object v, v;
v := @this: org.apache.activemq.plugin.DestinationsProcessor;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v = interfaceinvoke v.<java.util.List: 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.plugin.DestinationsProcessor: java.util.List getContents(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: 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()>();
label:
v = specialinvoke v.<org.apache.activemq.plugin.DestinationsProcessor: org.apache.activemq.command.ActiveMQDestination createDestination(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.activemq.plugin.DestinationsProcessor: boolean containsDestination(org.apache.activemq.command.ActiveMQDestination)>(v);
if v != 0 goto label;
v = v.<org.apache.activemq.plugin.DestinationsProcessor: org.apache.activemq.plugin.RuntimeConfigurationBroker plugin>;
v = v.<org.apache.activemq.plugin.DestinationsProcessor: org.apache.activemq.plugin.RuntimeConfigurationBroker plugin>;
v = virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: 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.RuntimeConfigurationBroker: org.apache.activemq.broker.region.Destination addDestination(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ActiveMQDestination,boolean)>(v, v, 1);
v = v.<org.apache.activemq.plugin.DestinationsProcessor: org.apache.activemq.plugin.RuntimeConfigurationBroker plugin>;
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.RuntimeConfigurationBroker: void info(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.activemq.plugin.DestinationsProcessor: org.apache.activemq.plugin.RuntimeConfigurationBroker plugin>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(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 DTO: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void info(java.lang.String,java.lang.Throwable)>(v, v);
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;
org.apache.activemq.plugin.DestinationsProcessor v;
org.apache.activemq.command.ActiveMQDestination v;
java.util.List v;
org.apache.activemq.broker.Broker v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v;
v := @this: org.apache.activemq.plugin.DestinationsProcessor;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = v.<org.apache.activemq.plugin.DestinationsProcessor: org.apache.activemq.plugin.RuntimeConfigurationBroker plugin>;
v = virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: 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 addNew(java.lang.Object)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.plugin.DestinationsProcessor v;
java.lang.Exception v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.broker.ConnectionContext v;
java.lang.Object v;
java.lang.String v, v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v, v, v, v;
v := @this: org.apache.activemq.plugin.DestinationsProcessor;
v := @parameter: java.lang.Object;
label:
v = specialinvoke v.<org.apache.activemq.plugin.DestinationsProcessor: org.apache.activemq.command.ActiveMQDestination createDestination(java.lang.Object)>(v);
v = v.<org.apache.activemq.plugin.DestinationsProcessor: org.apache.activemq.plugin.RuntimeConfigurationBroker plugin>;
v = v.<org.apache.activemq.plugin.DestinationsProcessor: org.apache.activemq.plugin.RuntimeConfigurationBroker plugin>;
v = virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: 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.RuntimeConfigurationBroker: org.apache.activemq.broker.region.Destination addDestination(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ActiveMQDestination,boolean)>(v, v, 1);
v = v.<org.apache.activemq.plugin.DestinationsProcessor: org.apache.activemq.plugin.RuntimeConfigurationBroker plugin>;
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.RuntimeConfigurationBroker: void info(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.activemq.plugin.DestinationsProcessor: org.apache.activemq.plugin.RuntimeConfigurationBroker plugin>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(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 DTO: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void info(java.lang.String,java.lang.Throwable)>(v, v);
label:
return;
catch java.lang.Exception from label to label with label;
}
private org.apache.activemq.command.ActiveMQDestination createDestination(java.lang.Object) throws java.lang.Exception
{
org.apache.activemq.plugin.DestinationsProcessor v;
org.apache.activemq.command.ActiveMQQueue v;
java.lang.Exception v;
org.apache.activemq.command.ActiveMQTopic v;
java.lang.Object v;
java.lang.String v, v, v;
boolean v, v;
v := @this: org.apache.activemq.plugin.DestinationsProcessor;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.activemq.schema.core.DtoQueue;
if v == 0 goto label;
v = new org.apache.activemq.command.ActiveMQQueue;
v = virtualinvoke v.<org.apache.activemq.schema.core.DtoQueue: java.lang.String getPhysicalName()>();
specialinvoke v.<org.apache.activemq.command.ActiveMQQueue: void <init>(java.lang.String)>(v);
return v;
label:
v = v instanceof org.apache.activemq.schema.core.DtoTopic;
if v == 0 goto label;
v = new org.apache.activemq.command.ActiveMQTopic;
v = virtualinvoke v.<org.apache.activemq.schema.core.DtoTopic: java.lang.String getPhysicalName()>();
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
label:
v = new java.lang.Exception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(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[])>("Unknown destination type for DTO \u0001");
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>(v);
throw v;
}
}