public class org.apache.activemq.plugin.RuntimeConfigurationBroker extends org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker
{
public static final org.slf4j.Logger LOG;
public static final java.lang.String objectNamePropsAppendage;
org.apache.activemq.plugin.PropertiesPlaceHolderUtil placeHolderUtil;
private long checkPeriod;
private long lastModified;
private org.springframework.core.io.Resource configToMonitor;
private org.apache.activemq.schema.core.DtoBroker currentConfiguration;
private javax.xml.validation.Schema schema;
public void <init>(org.apache.activemq.broker.Broker)
{
org.apache.activemq.broker.Broker v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.broker.Broker;
specialinvoke v.<org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker: void <init>(org.apache.activemq.broker.Broker)>(v);
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.plugin.PropertiesPlaceHolderUtil placeHolderUtil> = null;
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: long lastModified> = -1L;
return;
}
public void start() throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v, v;
org.apache.activemq.broker.BrokerContext v;
org.apache.activemq.schema.core.DtoBroker v;
java.lang.Exception v;
org.apache.activemq.broker.Broker v;
java.lang.String v, v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
org.springframework.core.io.Resource v, v, v, v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
specialinvoke v.<org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker: void start()>();
label:
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.broker.Broker next>;
v = interfaceinvoke v.<org.apache.activemq.broker.Broker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.BrokerContext getBrokerContext()>();
if v == null goto label;
v = interfaceinvoke v.<org.apache.activemq.broker.BrokerContext: java.lang.String getConfigurationUrl()>();
v = staticinvoke <org.apache.activemq.spring.Utils: org.springframework.core.io.Resource resourceFromString(java.lang.String)>(v);
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.springframework.core.io.Resource configToMonitor> = v;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.springframework.core.io.Resource configToMonitor>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.core.io.Resource)>(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[])>("Configuration \u0001");
virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void info(java.lang.String)>(v);
goto label;
label:
v = <org.apache.activemq.plugin.RuntimeConfigurationBroker: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>("Null BrokerContext; impossible to determine configuration url resource from broker, updates cannot be tracked");
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.plugin.RuntimeConfigurationBroker: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("failed to determine configuration url resource from broker, updates cannot be tracked", v);
label:
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.springframework.core.io.Resource configToMonitor>;
v = specialinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.schema.core.DtoBroker loadConfiguration(org.springframework.core.io.Resource)>(v);
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.schema.core.DtoBroker currentConfiguration> = v;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.springframework.core.io.Resource configToMonitor>;
specialinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void monitorModification(org.springframework.core.io.Resource)>(v);
virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void registerMbean()>();
return;
catch java.lang.Exception from label to label with label;
}
protected void registerMbean()
{
org.apache.activemq.broker.BrokerService v, v, v;
org.slf4j.Logger v;
org.apache.activemq.plugin.jmx.RuntimeConfigurationView v;
javax.management.ObjectName v, v, v;
java.lang.Exception v;
org.apache.activemq.broker.jmx.ManagementContext v;
java.lang.String v, v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
boolean v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v = virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
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.jmx.ManagementContext getManagementContext()>();
label:
v = new javax.management.ObjectName;
v = virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = virtualinvoke v.<javax.management.ObjectName: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u,service=RuntimeConfiguration,name=Plugin");
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: javax.management.ObjectName objectName> = v;
v = new org.apache.activemq.plugin.jmx.RuntimeConfigurationView;
specialinvoke v.<org.apache.activemq.plugin.jmx.RuntimeConfigurationView: void <init>(org.apache.activemq.plugin.RuntimeConfigurationBroker)>(v);
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: javax.management.ObjectName objectName>;
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: javax.management.ObjectInstance registerMBean(java.lang.Object,javax.management.ObjectName)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.plugin.RuntimeConfigurationBroker: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>("failed to register RuntimeConfigurationMBean", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
protected void unregisterMbean()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.ManagementContext v;
javax.management.JMException v;
javax.management.ObjectName v, v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: javax.management.ObjectName objectName>;
if v == null goto label;
label:
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.jmx.ManagementContext getManagementContext()>();
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: javax.management.ObjectName objectName>;
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: void unregisterMBean(javax.management.ObjectName)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
return;
catch javax.management.JMException from label to label with label;
}
public java.lang.String updateNow()
{
org.slf4j.Logger v;
java.lang.String v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
org.springframework.core.io.Resource v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v = <org.apache.activemq.plugin.RuntimeConfigurationBroker: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Manual configuration update triggered");
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: java.lang.String infoString> = "";
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.springframework.core.io.Resource configToMonitor>;
specialinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void applyModifications(org.springframework.core.io.Resource)>(v);
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: java.lang.String infoString>;
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: java.lang.String infoString> = null;
return v;
}
private void monitorModification(org.springframework.core.io.Resource)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.plugin.RuntimeConfigurationBroker$1 v;
java.util.Date v;
long v, v, v, v, v;
java.lang.Runnable v;
byte v, v;
org.apache.activemq.thread.Scheduler v;
java.lang.String v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
org.springframework.core.io.Resource v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v := @parameter: org.springframework.core.io.Resource;
v = new org.apache.activemq.plugin.RuntimeConfigurationBroker$1;
specialinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker$1: void <init>(org.apache.activemq.plugin.RuntimeConfigurationBroker,org.springframework.core.io.Resource)>(v, v);
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: java.lang.Runnable monitorTask> = v;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: long lastModified>;
v = v cmp 0L;
if v <= 0 goto label;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: long checkPeriod>;
v = v cmp 0L;
if v <= 0 goto label;
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.thread.Scheduler getScheduler()>();
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: java.lang.Runnable monitorTask>;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: long checkPeriod>;
virtualinvoke v.<org.apache.activemq.thread.Scheduler: void executePeriodically(java.lang.Runnable,long)>(v, v);
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: long checkPeriod>;
v = new java.util.Date;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: long lastModified>;
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,org.springframework.core.io.Resource,java.util.Date)>(v, 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[])>("Monitoring for updates (every \u0001millis) : \u, lastUpdate: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void info(java.lang.String)>(v);
label:
return;
}
private void applyModifications(org.springframework.core.io.Resource)
{
java.util.Date v, v;
org.apache.activemq.schema.core.DtoBroker v, v, v, v;
long v, v;
java.lang.String v, v, v, v, v, v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
boolean v;
org.springframework.core.io.Resource v;
org.slf4j.Logger v, v, v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v := @parameter: org.springframework.core.io.Resource;
v = specialinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.schema.core.DtoBroker loadConfiguration(org.springframework.core.io.Resource)>(v);
if v == null goto label;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.schema.core.DtoBroker currentConfiguration>;
v = virtualinvoke v.<org.apache.activemq.schema.core.DtoBroker: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.activemq.plugin.RuntimeConfigurationBroker: org.slf4j.Logger LOG>;
v = new java.util.Date;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: long lastModified>;
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.core.io.Resource,java.util.Date)>(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[])>("change in \u at: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = <org.apache.activemq.plugin.RuntimeConfigurationBroker: org.slf4j.Logger LOG>;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.schema.core.DtoBroker currentConfiguration>;
v = virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: java.lang.String filterPasswords(java.lang.Object)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("current:\u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = <org.apache.activemq.plugin.RuntimeConfigurationBroker: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: java.lang.String filterPasswords(java.lang.Object)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("new    :\u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.schema.core.DtoBroker currentConfiguration>;
specialinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void processSelectiveChanges(org.apache.activemq.schema.core.DtoBroker,org.apache.activemq.schema.core.DtoBroker)>(v, v);
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.schema.core.DtoBroker currentConfiguration> = v;
goto label;
label:
v = new java.util.Date;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: long lastModified>;
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.core.io.Resource,java.util.Date)>(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[])>("No material change to configuration in \u at: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void info(java.lang.String)>(v);
label:
return;
}
private void processSelectiveChanges(org.apache.activemq.schema.core.DtoBroker, org.apache.activemq.schema.core.DtoBroker)
{
int v, v;
java.lang.Class[] v;
org.apache.activemq.schema.core.DtoBroker v, v;
java.lang.Class v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.schema.core.DtoBroker;
v := @parameter: org.apache.activemq.schema.core.DtoBroker;
v = newarray (java.lang.Class)[5];
v[0] = class "Lorg/apache/activemq/schema/core/DtoBroker$DestinationPolicy;";
v[1] = class "Lorg/apache/activemq/schema/core/DtoBroker$NetworkConnectors;";
v[2] = class "Lorg/apache/activemq/schema/core/DtoBroker$DestinationInterceptors;";
v[3] = class "Lorg/apache/activemq/schema/core/DtoBroker$Plugins;";
v[4] = class "Lorg/apache/activemq/schema/core/DtoBroker$Destinations;";
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
specialinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void processChanges(org.apache.activemq.schema.core.DtoBroker,org.apache.activemq.schema.core.DtoBroker,java.lang.Class)>(v, v, v);
v = v + 1;
goto label;
label:
return;
}
private void processChanges(org.apache.activemq.schema.core.DtoBroker, org.apache.activemq.schema.core.DtoBroker, java.lang.Class)
{
org.apache.activemq.plugin.ConfigurationProcessor v;
org.apache.activemq.schema.core.DtoBroker v, v;
java.lang.Class v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v := @parameter: org.apache.activemq.schema.core.DtoBroker;
v := @parameter: org.apache.activemq.schema.core.DtoBroker;
v := @parameter: java.lang.Class;
v = staticinvoke <org.apache.activemq.plugin.ProcessorFactory: org.apache.activemq.plugin.ConfigurationProcessor createProcessor(org.apache.activemq.plugin.RuntimeConfigurationBroker,java.lang.Class)>(v, v);
interfaceinvoke v.<org.apache.activemq.plugin.ConfigurationProcessor: void processChanges(org.apache.activemq.schema.core.DtoBroker,org.apache.activemq.schema.core.DtoBroker)>(v, v);
return;
}
private org.apache.activemq.schema.core.DtoBroker loadConfiguration(org.springframework.core.io.Resource)
{
java.lang.Throwable v;
long v;
javax.xml.validation.Schema v;
org.w3c.dom.Document v;
org.w3c.dom.Node v;
java.lang.Boolean v;
java.lang.String v, v, v, v, v, v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
javax.xml.bind.JAXBContext v;
boolean v;
org.springframework.core.io.Resource v;
javax.xml.bind.Unmarshaller v;
org.w3c.dom.NodeList v;
javax.xml.bind.JAXBElement v;
java.lang.Class[] v;
java.io.IOException v;
java.lang.Exception v;
javax.xml.parsers.ParserConfigurationException v;
javax.xml.parsers.DocumentBuilder v;
org.xml.sax.SAXException v;
java.lang.Object v;
javax.xml.parsers.DocumentBuilderFactory v;
java.io.InputStream v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v := @parameter: org.springframework.core.io.Resource;
if v == null goto label;
label:
v = newarray (java.lang.Class)[1];
v[0] = class "Lorg/apache/activemq/schema/core/DtoBroker;";
v = staticinvoke <javax.xml.bind.JAXBContext: javax.xml.bind.JAXBContext newInstance(java.lang.Class[])>(v);
v = virtualinvoke v.<javax.xml.bind.JAXBContext: javax.xml.bind.Unmarshaller createUnmarshaller()>();
v = specialinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: javax.xml.validation.Schema getSchema()>();
interfaceinvoke v.<javax.xml.bind.Unmarshaller: void setSchema(javax.xml.validation.Schema)>(v);
v = staticinvoke <javax.xml.parsers.DocumentBuilderFactory: javax.xml.parsers.DocumentBuilderFactory newInstance()>();
virtualinvoke v.<javax.xml.parsers.DocumentBuilderFactory: void setNamespaceAware(boolean)>(1);
v = <java.lang.Boolean: java.lang.Boolean TRUE>;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<javax.xml.parsers.DocumentBuilderFactory: void setFeature(java.lang.String,boolean)>("http://javax.xml.XMLConstants/feature/secure-processing", v);
virtualinvoke v.<javax.xml.parsers.DocumentBuilderFactory: void setFeature(java.lang.String,boolean)>("http://apache.org/xml/features/disallow-doctype-decl", 1);
v = virtualinvoke v.<javax.xml.parsers.DocumentBuilderFactory: javax.xml.parsers.DocumentBuilder newDocumentBuilder()>();
v = interfaceinvoke v.<org.springframework.core.io.Resource: java.io.InputStream getInputStream()>();
v = virtualinvoke v.<javax.xml.parsers.DocumentBuilder: org.w3c.dom.Document parse(java.io.InputStream)>(v);
v = interfaceinvoke v.<org.w3c.dom.Document: org.w3c.dom.NodeList getElementsByTagNameNS(java.lang.String,java.lang.String)>("*", "broker");
v = interfaceinvoke v.<org.w3c.dom.NodeList: org.w3c.dom.Node item(int)>(0);
if v == null goto label;
v = interfaceinvoke v.<javax.xml.bind.Unmarshaller: javax.xml.bind.JAXBElement unmarshal(org.w3c.dom.Node,java.lang.Class)>(v, class "Lorg/apache/activemq/schema/core/DtoBroker;");
v = virtualinvoke v.<javax.xml.bind.JAXBElement: java.lang.Object getValue()>();
v = interfaceinvoke v.<org.springframework.core.io.Resource: long lastModified()>();
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: long lastModified> = v;
specialinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void loadPropertiesPlaceHolderSupport(org.w3c.dom.Document)>(v);
goto label;
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.core.io.Resource)>(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 find \'broker\' element by tag in: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void info(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.core.io.Resource)>(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 access: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void info(java.lang.String,java.lang.Throwable)>(v, v);
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.core.io.Resource)>(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 parse: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void info(java.lang.String,java.lang.Throwable)>(v, v);
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.core.io.Resource)>(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 document parse: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void info(java.lang.String,java.lang.Throwable)>(v, v);
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.core.io.Resource)>(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 find broker element in: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void info(java.lang.String,java.lang.Throwable)>(v, v);
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.core.io.Resource)>(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[])>("Unexpected exception during load of: \u0001");
virtualinvoke v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: void info(java.lang.String,java.lang.Throwable)>(v, v);
label:
return v;
catch java.io.IOException from label to label with label;
catch javax.xml.bind.JAXBException from label to label with label;
catch javax.xml.parsers.ParserConfigurationException from label to label with label;
catch org.xml.sax.SAXException from label to label with label;
catch java.lang.Exception from label to label with label;
}
private void loadPropertiesPlaceHolderSupport(org.w3c.dom.Document)
{
org.apache.activemq.plugin.PropertiesPlaceHolderUtil v, v;
org.apache.activemq.broker.BrokerService v;
java.util.Properties v, v;
org.apache.activemq.broker.BrokerContext v;
org.w3c.dom.Document v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v := @parameter: org.w3c.dom.Document;
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.BrokerContext getBrokerContext()>();
if v == null goto label;
v = new java.util.Properties;
v = staticinvoke <java.lang.System: java.util.Properties getProperties()>();
specialinvoke v.<java.util.Properties: void <init>(java.util.Properties)>(v);
v = new org.apache.activemq.plugin.PropertiesPlaceHolderUtil;
specialinvoke v.<org.apache.activemq.plugin.PropertiesPlaceHolderUtil: void <init>(java.util.Properties)>(v);
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.plugin.PropertiesPlaceHolderUtil placeHolderUtil> = v;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.apache.activemq.plugin.PropertiesPlaceHolderUtil placeHolderUtil>;
virtualinvoke v.<org.apache.activemq.plugin.PropertiesPlaceHolderUtil: void mergeProperties(org.w3c.dom.Document,java.util.Properties,org.apache.activemq.broker.BrokerContext)>(v, v, v);
label:
return;
}
private javax.xml.validation.Schema getSchema() throws org.xml.sax.SAXException, java.io.IOException
{
java.lang.Object[] v;
java.net.URL v, v, v, v;
javax.xml.transform.stream.StreamSource v, v, v;
javax.xml.validation.Schema v, v, v;
java.util.ArrayList v;
java.lang.String v, v, v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
javax.xml.validation.SchemaFactory v;
javax.xml.transform.Source[] v;
java.lang.Class v, v, v, v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: javax.xml.validation.Schema schema>;
if v != null goto label;
v = staticinvoke <javax.xml.validation.SchemaFactory: javax.xml.validation.SchemaFactory newInstance(java.lang.String)>("http://www.w.org/2001/XMLSchema");
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new javax.xml.transform.stream.StreamSource;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.net.URL getResource(java.lang.String)>("/activemq.xsd");
v = virtualinvoke v.<java.net.URL: java.lang.String toExternalForm()>();
specialinvoke v.<javax.xml.transform.stream.StreamSource: void <init>(java.lang.String)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.net.URL getResource(java.lang.String)>("/org/springframework/beans/factory/xml/spring-beans-3.0.xsd");
if v == null goto label;
v = new javax.xml.transform.stream.StreamSource;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.net.URL getResource(java.lang.String)>("/org/springframework/beans/factory/xml/spring-beans-3.0.xsd");
v = virtualinvoke v.<java.net.URL: java.lang.String toExternalForm()>();
specialinvoke v.<javax.xml.transform.stream.StreamSource: void <init>(java.lang.String)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
goto label;
label:
v = new javax.xml.transform.stream.StreamSource;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.net.URL getResource(java.lang.String)>("/org/springframework/beans/factory/xml/spring-beans.xsd");
v = virtualinvoke v.<java.net.URL: java.lang.String toExternalForm()>();
specialinvoke v.<javax.xml.transform.stream.StreamSource: void <init>(java.lang.String)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
label:
v = newarray (javax.xml.transform.Source)[0];
v = virtualinvoke v.<java.util.ArrayList: java.lang.Object[] toArray(java.lang.Object[])>(v);
v = virtualinvoke v.<javax.xml.validation.SchemaFactory: javax.xml.validation.Schema newSchema(javax.xml.transform.Source[])>(v);
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: javax.xml.validation.Schema schema> = v;
label:
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: javax.xml.validation.Schema schema>;
return v;
}
public long getLastModified()
{
long v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: long lastModified>;
return v;
}
public org.springframework.core.io.Resource getConfigToMonitor()
{
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
org.springframework.core.io.Resource v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.springframework.core.io.Resource configToMonitor>;
return v;
}
public long getCheckPeriod()
{
long v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v = v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: long checkPeriod>;
return v;
}
public void setCheckPeriod(long)
{
long v;
org.apache.activemq.plugin.RuntimeConfigurationBroker v;
v := @this: org.apache.activemq.plugin.RuntimeConfigurationBroker;
v := @parameter: long;
v.<org.apache.activemq.plugin.RuntimeConfigurationBroker: long checkPeriod> = v;
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/plugin/RuntimeConfigurationBroker;");
<org.apache.activemq.plugin.RuntimeConfigurationBroker: org.slf4j.Logger LOG> = v;
return;
}
}