public class org.apache.activemq.transport.vm.VMTransportFactory extends org.apache.activemq.transport.TransportFactory
{
public static final java.util.concurrent.ConcurrentMap BROKERS;
public static final java.util.concurrent.ConcurrentMap CONNECTORS;
public static final java.util.concurrent.ConcurrentMap SERVERS;
private static final org.slf4j.Logger LOG;
org.apache.activemq.broker.BrokerFactoryHandler brokerFactoryHandler;
public void <init>()
{
org.apache.activemq.transport.vm.VMTransportFactory v;
v := @this: org.apache.activemq.transport.vm.VMTransportFactory;
specialinvoke v.<org.apache.activemq.transport.TransportFactory: void <init>()>();
return;
}
public org.apache.activemq.transport.Transport doConnect(java.net.URI) throws java.lang.Exception
{
org.apache.activemq.transport.Transport v, v;
org.apache.activemq.transport.vm.VMTransportFactory v;
java.net.URI v;
v := @this: org.apache.activemq.transport.vm.VMTransportFactory;
v := @parameter: java.net.URI;
v = virtualinvoke v.<org.apache.activemq.transport.vm.VMTransportFactory: org.apache.activemq.transport.Transport doCompositeConnect(java.net.URI)>(v);
v = staticinvoke <org.apache.activemq.transport.vm.VMTransportServer: org.apache.activemq.transport.Transport configure(org.apache.activemq.transport.Transport)>(v);
return v;
}
public org.apache.activemq.transport.Transport doCompositeConnect(java.net.URI) throws java.lang.Exception
{
java.util.Map v, v, v;
org.apache.activemq.transport.MarshallingTransportFilter v;
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.BrokerRegistry v, v, v;
org.apache.activemq.thread.TaskRunnerFactory v;
java.lang.Throwable v;
org.apache.activemq.transport.vm.VMTransport v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
java.io.IOException v, v, v;
org.apache.activemq.util.URISupport$CompositeData v, v;
java.net.URISyntaxException v, v;
java.net.URI[] v, v, v;
java.net.URI v, v, v, v, v, v, v, v;
boolean v, v, v, v, v, v;
org.apache.activemq.wireformat.WireFormat v, v;
org.apache.activemq.transport.Transport v;
org.apache.activemq.transport.vm.VMTransportFactory v;
java.util.HashMap v, v;
java.util.concurrent.ConcurrentMap v, v, v, v;
org.apache.activemq.broker.TransportConnector v;
int v, v, v;
org.apache.activemq.broker.BrokerFactoryHandler v, v;
java.lang.IllegalArgumentException v;
java.lang.Object v, v, v, v, v, v, v;
v := @this: org.apache.activemq.transport.vm.VMTransportFactory;
v := @parameter: java.net.URI;
v = 1;
v = (int) -1;
v = v;
v = staticinvoke <org.apache.activemq.util.URISupport: org.apache.activemq.util.URISupport$CompositeData parseComposite(java.net.URI)>(v);
v = virtualinvoke v.<org.apache.activemq.util.URISupport$CompositeData: java.net.URI[] getComponents()>();
v = lengthof v;
if v != 1 goto label;
v = "broker";
v = virtualinvoke v.<org.apache.activemq.util.URISupport$CompositeData: java.net.URI[] getComponents()>();
v = v[0];
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.util.URISupport$CompositeData: java.net.URI[] getComponents()>();
v = v[0];
v = staticinvoke <org.apache.activemq.util.URISupport: org.apache.activemq.util.URISupport$CompositeData parseComposite(java.net.URI)>(v);
v = virtualinvoke v.<org.apache.activemq.util.URISupport$CompositeData: java.util.Map getParameters()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("brokerName");
if v != null goto label;
v = "localhost";
label:
v = virtualinvoke v.<org.apache.activemq.util.URISupport$CompositeData: java.lang.String getPath()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.util.URISupport$CompositeData: java.lang.String getPath()>();
label:
v = virtualinvoke v.<org.apache.activemq.util.URISupport$CompositeData: java.util.Map getParameters()>();
v = new java.net.URI;
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[])>("vm://\u0001");
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
v = v;
goto label;
label:
v = staticinvoke <org.apache.activemq.transport.vm.VMTransportFactory: java.lang.String extractHost(java.net.URI)>(v);
v = staticinvoke <org.apache.activemq.util.URISupport: java.util.Map parseParameters(java.net.URI)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("brokerConfig");
if v == null goto label;
v = new java.net.URI;
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
v = v;
goto label;
label:
v = staticinvoke <org.apache.activemq.util.IntrospectionSupport: java.util.Map extractProperties(java.util.Map,java.lang.String)>(v, "broker.");
v = new java.net.URI;
v = staticinvoke <org.apache.activemq.util.URISupport: java.lang.String createQueryString(java.util.Map)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("broker://()/\u0001?\u0001");
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
v = v;
label:
v = "false";
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("create");
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = 0;
label:
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("waitForStart");
if v == null goto label;
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.Exception)>(v);
throw v;
label:
v = new java.net.URI;
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[])>("vm://\u0001");
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
v = v;
label:
if v != null goto label;
v = "localhost";
label:
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap SERVERS>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
v = specialinvoke v.<org.apache.activemq.transport.vm.VMTransportFactory: boolean validateBroker(java.lang.String)>(v);
if v == 0 goto label;
if v != null goto label;
label:
v = staticinvoke <org.apache.activemq.broker.BrokerRegistry: org.apache.activemq.broker.BrokerRegistry getInstance()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerRegistry: java.lang.Object getRegistryMutext()>();
entermonitor v;
label:
v = staticinvoke <org.apache.activemq.broker.BrokerRegistry: org.apache.activemq.broker.BrokerRegistry getInstance()>();
v = specialinvoke v.<org.apache.activemq.transport.vm.VMTransportFactory: org.apache.activemq.broker.BrokerService lookupBroker(org.apache.activemq.broker.BrokerRegistry,java.lang.String,int)>(v, v, v);
if v != null goto label;
if v != 0 goto label;
v = new java.io.IOException;
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[])>("Broker named \'\u0001\' does not exist.");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.activemq.transport.vm.VMTransportFactory: org.apache.activemq.broker.BrokerFactoryHandler brokerFactoryHandler>;
if v == null goto label;
v = v.<org.apache.activemq.transport.vm.VMTransportFactory: org.apache.activemq.broker.BrokerFactoryHandler brokerFactoryHandler>;
v = interfaceinvoke v.<org.apache.activemq.broker.BrokerFactoryHandler: org.apache.activemq.broker.BrokerService createBroker(java.net.URI)>(v);
goto label;
label:
v = staticinvoke <org.apache.activemq.broker.BrokerFactory: org.apache.activemq.broker.BrokerService createBroker(java.net.URI)>(v);
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void start()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("activemq.broker", v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.Exception)>(v);
throw v;
label:
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap BROKERS>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <org.apache.activemq.broker.BrokerRegistry: org.apache.activemq.broker.BrokerRegistry getInstance()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerRegistry: java.lang.Object getRegistryMutext()>();
virtualinvoke v.<java.lang.Object: void notifyAll()>();
label:
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap SERVERS>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
specialinvoke v.<org.apache.activemq.transport.vm.VMTransportFactory: org.apache.activemq.transport.TransportServer bind(java.net.URI,boolean)>(v, 1);
v = new org.apache.activemq.broker.TransportConnector;
specialinvoke v.<org.apache.activemq.broker.TransportConnector: void <init>(org.apache.activemq.transport.TransportServer)>(v);
virtualinvoke v.<org.apache.activemq.broker.TransportConnector: void setBrokerService(org.apache.activemq.broker.BrokerService)>(v);
virtualinvoke v.<org.apache.activemq.broker.TransportConnector: void setUri(java.net.URI)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory getTaskRunnerFactory()>();
virtualinvoke v.<org.apache.activemq.broker.TransportConnector: void setTaskRunnerFactory(org.apache.activemq.thread.TaskRunnerFactory)>(v);
virtualinvoke v.<org.apache.activemq.broker.TransportConnector: void start()>();
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap CONNECTORS>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = virtualinvoke v.<org.apache.activemq.transport.vm.VMTransportServer: org.apache.activemq.transport.vm.VMTransport connect()>();
v = v.<org.apache.activemq.transport.vm.VMTransport: org.apache.activemq.transport.vm.VMTransport peer>;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
staticinvoke <org.apache.activemq.util.IntrospectionSupport: boolean setProperties(java.lang.Object,java.util.Map)>(v, v);
staticinvoke <org.apache.activemq.util.IntrospectionSupport: boolean setProperties(java.lang.Object,java.util.Map)>(v, v);
v = v;
v = virtualinvoke v.<org.apache.activemq.transport.vm.VMTransport: boolean isMarshal()>();
if v == 0 goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = new org.apache.activemq.transport.MarshallingTransportFilter;
v = virtualinvoke v.<org.apache.activemq.transport.vm.VMTransportFactory: org.apache.activemq.wireformat.WireFormat createWireFormat(java.util.Map)>(v);
v = virtualinvoke v.<org.apache.activemq.transport.vm.VMTransportFactory: org.apache.activemq.wireformat.WireFormat createWireFormat(java.util.Map)>(v);
specialinvoke v.<org.apache.activemq.transport.MarshallingTransportFilter: void <init>(org.apache.activemq.transport.Transport,org.apache.activemq.wireformat.WireFormat,org.apache.activemq.wireformat.WireFormat)>(v, v, v);
v = v;
label:
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.Map)>(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[])>("Invalid connect parameters: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
catch java.net.URISyntaxException from label to label with label;
catch java.net.URISyntaxException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private static java.lang.String extractHost(java.net.URI)
{
int v, v;
java.lang.String v;
java.net.URI v;
v := @parameter: java.net.URI;
v = virtualinvoke v.<java.net.URI: java.lang.String getHost()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
if v != 0 goto label;
label:
v = virtualinvoke v.<java.net.URI: java.lang.String getAuthority()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
if v != 0 goto label;
label:
v = "localhost";
label:
return v;
}
private org.apache.activemq.broker.BrokerService lookupBroker(org.apache.activemq.broker.BrokerRegistry, java.lang.String, int)
{
java.lang.Throwable v;
long v, v, v, v, v, v, v, v, v, v;
byte v;
int v;
java.lang.String v, v, v;
boolean v, v, v;
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v, v;
org.apache.activemq.broker.BrokerRegistry v;
java.lang.InterruptedException v;
java.lang.Object v, v;
org.apache.activemq.transport.vm.VMTransportFactory v;
v := @this: org.apache.activemq.transport.vm.VMTransportFactory;
v := @parameter: org.apache.activemq.broker.BrokerRegistry;
v := @parameter: java.lang.String;
v := @parameter: int;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerRegistry: java.lang.Object getRegistryMutext()>();
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerRegistry: org.apache.activemq.broker.BrokerService lookup(java.lang.String)>(v);
if v == null goto label;
if v <= 0 goto label;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v + v;
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isStarted()>();
if v != 0 goto label;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
v = v cmp 0L;
if v >= 0 goto label;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
v = staticinvoke <java.lang.Math: long max(long,long)>(0L, v);
if v != null goto label;
label:
v = <org.apache.activemq.transport.vm.VMTransportFactory: org.slf4j.Logger LOG>;
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[])>("waiting for broker named: \u to enter registry");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerRegistry: java.lang.Object getRegistryMutext()>();
virtualinvoke v.<java.lang.Object: void wait(long)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerRegistry: org.apache.activemq.broker.BrokerService lookup(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isStarted()>();
if v != 0 goto label;
v = <org.apache.activemq.transport.vm.VMTransportFactory: org.slf4j.Logger LOG>;
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[])>("waiting for broker named: \u to start");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
v = staticinvoke <java.lang.Math: long max(long,long)>(0L, v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean waitUntilStarted(long)>(v);
if v != 0 goto label;
v = null;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return v;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activemq.transport.TransportServer doBind(java.net.URI) throws java.io.IOException
{
org.apache.activemq.transport.TransportServer v;
org.apache.activemq.transport.vm.VMTransportFactory v;
java.net.URI v;
v := @this: org.apache.activemq.transport.vm.VMTransportFactory;
v := @parameter: java.net.URI;
v = specialinvoke v.<org.apache.activemq.transport.vm.VMTransportFactory: org.apache.activemq.transport.TransportServer bind(java.net.URI,boolean)>(v, 0);
return v;
}
private org.apache.activemq.transport.TransportServer bind(java.net.URI, boolean) throws java.io.IOException
{
org.slf4j.Logger v;
java.io.IOException v;
org.apache.activemq.transport.vm.VMTransportServer v;
java.util.concurrent.ConcurrentMap v, v;
java.lang.Object v;
org.apache.activemq.transport.vm.VMTransportFactory v;
java.lang.String v, v, v;
java.net.URI v;
boolean v;
v := @this: org.apache.activemq.transport.vm.VMTransportFactory;
v := @parameter: java.net.URI;
v := @parameter: boolean;
v = staticinvoke <org.apache.activemq.transport.vm.VMTransportFactory: java.lang.String extractHost(java.net.URI)>(v);
v = <org.apache.activemq.transport.vm.VMTransportFactory: org.slf4j.Logger LOG>;
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[])>("binding to broker: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = new org.apache.activemq.transport.vm.VMTransportServer;
specialinvoke v.<org.apache.activemq.transport.vm.VMTransportServer: void <init>(java.net.URI,boolean)>(v, v);
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap SERVERS>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.net.URI)>(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[])>("VMTransportServer already bound at: \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap SERVERS>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
public static void stopped(org.apache.activemq.transport.vm.VMTransportServer)
{
java.lang.String v;
java.net.URI v;
org.apache.activemq.transport.vm.VMTransportServer v;
v := @parameter: org.apache.activemq.transport.vm.VMTransportServer;
v = virtualinvoke v.<org.apache.activemq.transport.vm.VMTransportServer: java.net.URI getBindURI()>();
v = staticinvoke <org.apache.activemq.transport.vm.VMTransportFactory: java.lang.String extractHost(java.net.URI)>(v);
staticinvoke <org.apache.activemq.transport.vm.VMTransportFactory: void stopped(java.lang.String)>(v);
return;
}
public static void stopped(java.lang.String)
{
org.slf4j.Logger v;
java.util.concurrent.ConcurrentMap v, v, v;
java.lang.Object v, v;
java.lang.String v, v;
v := @parameter: java.lang.String;
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap SERVERS>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap CONNECTORS>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = <org.apache.activemq.transport.vm.VMTransportFactory: org.slf4j.Logger LOG>;
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[])>("Shutting down VM connectors for broker: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
staticinvoke <org.apache.activemq.util.ServiceSupport: void dispose(org.apache.activemq.Service)>(v);
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap BROKERS>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
staticinvoke <org.apache.activemq.util.ServiceSupport: void dispose(org.apache.activemq.Service)>(v);
label:
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("activemq.broker");
label:
return;
}
public org.apache.activemq.broker.BrokerFactoryHandler getBrokerFactoryHandler()
{
org.apache.activemq.transport.vm.VMTransportFactory v;
org.apache.activemq.broker.BrokerFactoryHandler v;
v := @this: org.apache.activemq.transport.vm.VMTransportFactory;
v = v.<org.apache.activemq.transport.vm.VMTransportFactory: org.apache.activemq.broker.BrokerFactoryHandler brokerFactoryHandler>;
return v;
}
public void setBrokerFactoryHandler(org.apache.activemq.broker.BrokerFactoryHandler)
{
org.apache.activemq.transport.vm.VMTransportFactory v;
org.apache.activemq.broker.BrokerFactoryHandler v;
v := @this: org.apache.activemq.transport.vm.VMTransportFactory;
v := @parameter: org.apache.activemq.broker.BrokerFactoryHandler;
v.<org.apache.activemq.transport.vm.VMTransportFactory: org.apache.activemq.broker.BrokerFactoryHandler brokerFactoryHandler> = v;
return;
}
private boolean validateBroker(java.lang.String)
{
java.util.concurrent.ConcurrentMap v, v, v, v, v, v, v;
org.apache.activemq.broker.Broker v;
java.lang.String v;
boolean v, v, v, v, v;
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.BrokerRegistry v;
java.lang.Object v;
org.apache.activemq.transport.vm.VMTransportFactory v;
v := @this: org.apache.activemq.transport.vm.VMTransportFactory;
v := @parameter: java.lang.String;
v = 1;
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap BROKERS>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap SERVERS>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap CONNECTORS>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap CONNECTORS>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
v = staticinvoke <org.apache.activemq.broker.BrokerRegistry: org.apache.activemq.broker.BrokerRegistry getInstance()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerRegistry: org.apache.activemq.broker.BrokerService lookup(java.lang.String)>(v);
if v == null goto label;
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: org.apache.activemq.broker.Broker getBroker()>();
v = interfaceinvoke v.<org.apache.activemq.broker.Broker: boolean isStopped()>();
if v == 0 goto label;
label:
v = 0;
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap BROKERS>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap SERVERS>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = <org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap CONNECTORS>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
staticinvoke <org.apache.activemq.util.ServiceSupport: void dispose(org.apache.activemq.Service)>(v);
label:
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
java.util.concurrent.ConcurrentHashMap v, v, v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
<org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap BROKERS> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
<org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap CONNECTORS> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
<org.apache.activemq.transport.vm.VMTransportFactory: java.util.concurrent.ConcurrentMap SERVERS> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/transport/vm/VMTransportFactory;");
<org.apache.activemq.transport.vm.VMTransportFactory: org.slf4j.Logger LOG> = v;
return;
}
}