public class org.apache.activemq.broker.jmx.ManagedTransportConnector extends org.apache.activemq.broker.TransportConnector
{
static long nextConnectionId;
private final org.apache.activemq.broker.jmx.ManagementContext managementContext;
private final javax.management.ObjectName connectorName;
public void <init>(org.apache.activemq.broker.jmx.ManagementContext, javax.management.ObjectName, org.apache.activemq.transport.TransportServer)
{
org.apache.activemq.broker.jmx.ManagementContext v;
org.apache.activemq.broker.jmx.ManagedTransportConnector v;
org.apache.activemq.transport.TransportServer v;
javax.management.ObjectName v;
v := @this: org.apache.activemq.broker.jmx.ManagedTransportConnector;
v := @parameter: org.apache.activemq.broker.jmx.ManagementContext;
v := @parameter: javax.management.ObjectName;
v := @parameter: org.apache.activemq.transport.TransportServer;
specialinvoke v.<org.apache.activemq.broker.TransportConnector: void <init>(org.apache.activemq.transport.TransportServer)>(v);
v.<org.apache.activemq.broker.jmx.ManagedTransportConnector: org.apache.activemq.broker.jmx.ManagementContext managementContext> = v;
v.<org.apache.activemq.broker.jmx.ManagedTransportConnector: javax.management.ObjectName connectorName> = v;
return;
}
public org.apache.activemq.broker.jmx.ManagedTransportConnector asManagedConnector(javax.management.MBeanServer, javax.management.ObjectName) throws java.io.IOException, java.net.URISyntaxException
{
javax.management.ObjectName v;
org.apache.activemq.broker.jmx.ManagedTransportConnector v;
javax.management.MBeanServer v;
v := @this: org.apache.activemq.broker.jmx.ManagedTransportConnector;
v := @parameter: javax.management.MBeanServer;
v := @parameter: javax.management.ObjectName;
return v;
}
protected org.apache.activemq.broker.Connection createConnection(org.apache.activemq.transport.Transport) throws java.io.IOException
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.transport.Transport v;
javax.management.ObjectName v;
org.apache.activemq.broker.Broker v;
org.apache.activemq.broker.jmx.ManagementContext v;
org.apache.activemq.broker.jmx.ManagedTransportConnector v;
org.apache.activemq.thread.TaskRunnerFactory v, v;
org.apache.activemq.broker.jmx.ManagedTransportConnection v;
boolean v;
v := @this: org.apache.activemq.broker.jmx.ManagedTransportConnector;
v := @parameter: org.apache.activemq.transport.Transport;
v = new org.apache.activemq.broker.jmx.ManagedTransportConnection;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedTransportConnector: org.apache.activemq.broker.Broker getBroker()>();
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedTransportConnector: boolean isDisableAsyncDispatch()>();
if v == 0 goto label;
v = null;
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedTransportConnector: org.apache.activemq.thread.TaskRunnerFactory getTaskRunnerFactory()>();
label:
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedTransportConnector: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory getTaskRunnerFactory()>();
v = v.<org.apache.activemq.broker.jmx.ManagedTransportConnector: org.apache.activemq.broker.jmx.ManagementContext managementContext>;
v = v.<org.apache.activemq.broker.jmx.ManagedTransportConnector: javax.management.ObjectName connectorName>;
specialinvoke v.<org.apache.activemq.broker.jmx.ManagedTransportConnection: void <init>(org.apache.activemq.broker.TransportConnector,org.apache.activemq.transport.Transport,org.apache.activemq.broker.Broker,org.apache.activemq.thread.TaskRunnerFactory,org.apache.activemq.thread.TaskRunnerFactory,org.apache.activemq.broker.jmx.ManagementContext,javax.management.ObjectName)>(v, v, v, v, v, v, v);
return v;
}
protected static synchronized long getNextConnectionId()
{
long v, v;
v = <org.apache.activemq.broker.jmx.ManagedTransportConnector: long nextConnectionId>;
v = v + 1L;
<org.apache.activemq.broker.jmx.ManagedTransportConnector: long nextConnectionId> = v;
return v;
}
static void <clinit>()
{
<org.apache.activemq.broker.jmx.ManagedTransportConnector: long nextConnectionId> = 1L;
return;
}
}