public class org.apache.activemq.broker.jmx.ConnectionView extends java.lang.Object implements org.apache.activemq.broker.jmx.ConnectionViewMBean
{
private final org.apache.activemq.broker.Connection connection;
private final org.apache.activemq.broker.jmx.ManagementContext managementContext;
private java.lang.String userName;
public void <init>(org.apache.activemq.broker.Connection)
{
org.apache.activemq.broker.Connection v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v := @parameter: org.apache.activemq.broker.Connection;
specialinvoke v.<org.apache.activemq.broker.jmx.ConnectionView: void <init>(org.apache.activemq.broker.Connection,org.apache.activemq.broker.jmx.ManagementContext)>(v, null);
return;
}
public void <init>(org.apache.activemq.broker.Connection, org.apache.activemq.broker.jmx.ManagementContext)
{
org.apache.activemq.broker.jmx.ManagementContext v;
org.apache.activemq.broker.Connection v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v := @parameter: org.apache.activemq.broker.Connection;
v := @parameter: org.apache.activemq.broker.jmx.ManagementContext;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection> = v;
v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.jmx.ManagementContext managementContext> = v;
return;
}
public void start() throws java.lang.Exception
{
org.apache.activemq.broker.Connection v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
interfaceinvoke v.<org.apache.activemq.broker.Connection: void start()>();
return;
}
public void stop() throws java.lang.Exception
{
org.apache.activemq.broker.Connection v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
interfaceinvoke v.<org.apache.activemq.broker.Connection: void stop()>();
return;
}
public boolean isSlow()
{
org.apache.activemq.broker.Connection v;
boolean v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: boolean isSlow()>();
return v;
}
public boolean isBlocked()
{
org.apache.activemq.broker.Connection v;
boolean v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: boolean isBlocked()>();
return v;
}
public boolean isConnected()
{
org.apache.activemq.broker.Connection v;
boolean v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: boolean isConnected()>();
return v;
}
public boolean isActive()
{
org.apache.activemq.broker.Connection v;
boolean v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: boolean isActive()>();
return v;
}
public int getDispatchQueueSize()
{
int v;
org.apache.activemq.broker.Connection v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: int getDispatchQueueSize()>();
return v;
}
public void resetStatistics()
{
org.apache.activemq.broker.Connection v;
org.apache.activemq.broker.region.ConnectionStatistics v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: org.apache.activemq.broker.region.ConnectionStatistics getStatistics()>();
virtualinvoke v.<org.apache.activemq.broker.region.ConnectionStatistics: void reset()>();
return;
}
public java.lang.String getRemoteAddress()
{
java.lang.String v;
org.apache.activemq.broker.Connection v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: java.lang.String getRemoteAddress()>();
return v;
}
public java.lang.String getClientId()
{
java.lang.String v;
org.apache.activemq.broker.Connection v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: java.lang.String getConnectionId()>();
return v;
}
public java.lang.String getConnectionId()
{
java.lang.String v;
org.apache.activemq.broker.Connection v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: java.lang.String getConnectionId()>();
return v;
}
public java.lang.String getUserName()
{
java.lang.String v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: java.lang.String userName>;
return v;
}
public void setUserName(java.lang.String)
{
java.lang.String v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v := @parameter: java.lang.String;
v.<org.apache.activemq.broker.jmx.ConnectionView: java.lang.String userName> = v;
return;
}
public javax.management.ObjectName[] getConsumers()
{
java.lang.Object[] v;
java.util.Set v;
javax.management.ObjectName v;
java.lang.Exception v;
org.apache.activemq.broker.jmx.ConnectionView v;
org.apache.activemq.broker.jmx.ManagementContext v, v;
javax.management.ObjectName[] v;
java.lang.String v;
org.apache.activemq.broker.Connection v, v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.jmx.ManagementContext managementContext>;
if v == null goto label;
label:
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: java.lang.String getConnectionId()>();
v = specialinvoke v.<org.apache.activemq.broker.jmx.ConnectionView: javax.management.ObjectName createConsumerQueury(java.lang.String)>(v);
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.jmx.ManagementContext managementContext>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: java.util.Set queryNames(javax.management.ObjectName,javax.management.QueryExp)>(v, null);
v = newarray (javax.management.ObjectName)[0];
v = interfaceinvoke v.<java.util.Set: java.lang.Object[] toArray(java.lang.Object[])>(v);
label:
goto label;
label:
v := @caughtexception;
label:
return v;
catch java.lang.Exception from label to label with label;
}
public javax.management.ObjectName[] getProducers()
{
java.lang.Object[] v;
java.util.Set v;
javax.management.ObjectName v;
java.lang.Exception v;
org.apache.activemq.broker.jmx.ConnectionView v;
org.apache.activemq.broker.jmx.ManagementContext v, v;
javax.management.ObjectName[] v;
java.lang.String v;
org.apache.activemq.broker.Connection v, v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.jmx.ManagementContext managementContext>;
if v == null goto label;
label:
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: java.lang.String getConnectionId()>();
v = specialinvoke v.<org.apache.activemq.broker.jmx.ConnectionView: javax.management.ObjectName createProducerQueury(java.lang.String)>(v);
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.jmx.ManagementContext managementContext>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: java.util.Set queryNames(javax.management.ObjectName,javax.management.QueryExp)>(v, null);
v = newarray (javax.management.ObjectName)[0];
v = interfaceinvoke v.<java.util.Set: java.lang.Object[] toArray(java.lang.Object[])>(v);
label:
goto label;
label:
v := @caughtexception;
label:
return v;
catch java.lang.Exception from label to label with label;
}
private javax.management.ObjectName createConsumerQueury(java.lang.String) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.broker.jmx.ManagementContext v;
java.io.IOException v;
java.lang.String v, v;
javax.management.ObjectName v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.jmx.ManagementContext managementContext>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: java.lang.String getJmxDomainName()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createConsumerQueury(java.lang.String,java.lang.String)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.Throwable)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
}
private javax.management.ObjectName createProducerQueury(java.lang.String) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.broker.jmx.ManagementContext v;
java.io.IOException v;
java.lang.String v, v;
javax.management.ObjectName v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.jmx.ManagementContext managementContext>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: java.lang.String getJmxDomainName()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createProducerQueury(java.lang.String,java.lang.String)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.Throwable)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
}
public int getActiveTransactionCount()
{
int v;
org.apache.activemq.broker.Connection v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: int getActiveTransactionCount()>();
return v;
}
public java.lang.Long getOldestActiveTransactionDuration()
{
org.apache.activemq.broker.Connection v;
java.lang.Long v;
org.apache.activemq.broker.jmx.ConnectionView v;
v := @this: org.apache.activemq.broker.jmx.ConnectionView;
v = v.<org.apache.activemq.broker.jmx.ConnectionView: org.apache.activemq.broker.Connection connection>;
v = interfaceinvoke v.<org.apache.activemq.broker.Connection: java.lang.Long getOldestActiveTransactionDuration()>();
return v;
}
}