public class org.apache.activemq.management.JMSSessionStatsImpl extends org.apache.activemq.management.StatsImpl
{
private java.util.List producers;
private java.util.List consumers;
private org.apache.activemq.management.CountStatisticImpl messageCount;
private org.apache.activemq.management.CountStatisticImpl pendingMessageCount;
private org.apache.activemq.management.CountStatisticImpl expiredMessageCount;
private org.apache.activemq.management.TimeStatisticImpl messageWaitTime;
private org.apache.activemq.management.CountStatisticImpl durableSubscriptionCount;
private org.apache.activemq.management.TimeStatisticImpl messageRateTime;
public void <init>(java.util.List, java.util.List)
{
org.apache.activemq.management.CountStatisticImpl v, v, v, v, v, v, v, v;
org.apache.activemq.management.JMSSessionStatsImpl v;
java.util.List v, v;
org.apache.activemq.management.TimeStatisticImpl v, v, v, v, v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
specialinvoke v.<org.apache.activemq.management.StatsImpl: void <init>()>();
v.<org.apache.activemq.management.JMSSessionStatsImpl: java.util.List producers> = v;
v.<org.apache.activemq.management.JMSSessionStatsImpl: java.util.List consumers> = v;
v = new org.apache.activemq.management.CountStatisticImpl;
specialinvoke v.<org.apache.activemq.management.CountStatisticImpl: void <init>(java.lang.String,java.lang.String)>("messageCount", "Number of messages exchanged");
v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl messageCount> = v;
v = new org.apache.activemq.management.CountStatisticImpl;
specialinvoke v.<org.apache.activemq.management.CountStatisticImpl: void <init>(java.lang.String,java.lang.String)>("pendingMessageCount", "Number of pending messages");
v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl pendingMessageCount> = v;
v = new org.apache.activemq.management.CountStatisticImpl;
specialinvoke v.<org.apache.activemq.management.CountStatisticImpl: void <init>(java.lang.String,java.lang.String)>("expiredMessageCount", "Number of expired messages");
v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl expiredMessageCount> = v;
v = new org.apache.activemq.management.TimeStatisticImpl;
specialinvoke v.<org.apache.activemq.management.TimeStatisticImpl: void <init>(java.lang.String,java.lang.String)>("messageWaitTime", "Time spent by a message before being delivered");
v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.TimeStatisticImpl messageWaitTime> = v;
v = new org.apache.activemq.management.CountStatisticImpl;
specialinvoke v.<org.apache.activemq.management.CountStatisticImpl: void <init>(java.lang.String,java.lang.String)>("durableSubscriptionCount", "The number of durable subscriptions");
v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl durableSubscriptionCount> = v;
v = new org.apache.activemq.management.TimeStatisticImpl;
specialinvoke v.<org.apache.activemq.management.TimeStatisticImpl: void <init>(java.lang.String,java.lang.String)>("messageWaitTime", "Time spent by a message before being delivered");
v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.TimeStatisticImpl messageWaitTime> = v;
v = new org.apache.activemq.management.TimeStatisticImpl;
specialinvoke v.<org.apache.activemq.management.TimeStatisticImpl: void <init>(java.lang.String,java.lang.String)>("messageRateTime", "Time taken to process a message (thoughtput rate)");
v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.TimeStatisticImpl messageRateTime> = v;
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl messageCount>;
virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: void addStatistic(java.lang.String,org.apache.activemq.management.StatisticImpl)>("messageCount", v);
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl pendingMessageCount>;
virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: void addStatistic(java.lang.String,org.apache.activemq.management.StatisticImpl)>("pendingMessageCount", v);
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl expiredMessageCount>;
virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: void addStatistic(java.lang.String,org.apache.activemq.management.StatisticImpl)>("expiredMessageCount", v);
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.TimeStatisticImpl messageWaitTime>;
virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: void addStatistic(java.lang.String,org.apache.activemq.management.StatisticImpl)>("messageWaitTime", v);
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl durableSubscriptionCount>;
virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: void addStatistic(java.lang.String,org.apache.activemq.management.StatisticImpl)>("durableSubscriptionCount", v);
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.TimeStatisticImpl messageRateTime>;
virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: void addStatistic(java.lang.String,org.apache.activemq.management.StatisticImpl)>("messageRateTime", v);
return;
}
public org.apache.activemq.management.JMSProducerStatsImpl[] getProducers()
{
java.lang.Object[] v;
org.apache.activemq.management.JMSProducerStatsImpl v;
java.util.List v;
int v, v;
java.lang.Object v;
org.apache.activemq.management.JMSProducerStatsImpl[] v;
org.apache.activemq.management.JMSSessionStatsImpl v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: java.util.List producers>;
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
v = lengthof v;
v = newarray (org.apache.activemq.management.JMSProducerStatsImpl)[v];
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.activemq.ActiveMQMessageProducer: org.apache.activemq.management.JMSProducerStatsImpl getProducerStats()>();
v[v] = v;
v = v + 1;
goto label;
label:
return v;
}
public org.apache.activemq.management.JMSConsumerStatsImpl[] getConsumers()
{
java.lang.Object[] v;
org.apache.activemq.management.JMSConsumerStatsImpl v;
org.apache.activemq.management.JMSConsumerStatsImpl[] v;
java.util.List v;
int v, v;
java.lang.Object v;
org.apache.activemq.management.JMSSessionStatsImpl v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: java.util.List consumers>;
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
v = lengthof v;
v = newarray (org.apache.activemq.management.JMSConsumerStatsImpl)[v];
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.activemq.ActiveMQMessageConsumer: org.apache.activemq.management.JMSConsumerStatsImpl getConsumerStats()>();
v[v] = v;
v = v + 1;
goto label;
label:
return v;
}
public void reset()
{
org.apache.activemq.management.JMSConsumerStatsImpl v;
org.apache.activemq.management.JMSProducerStatsImpl v;
org.apache.activemq.management.JMSConsumerStatsImpl[] v;
int v, v, v, v;
org.apache.activemq.management.JMSProducerStatsImpl[] v;
org.apache.activemq.management.JMSSessionStatsImpl v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
specialinvoke v.<org.apache.activemq.management.StatsImpl: void reset()>();
v = virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.JMSConsumerStatsImpl[] getConsumers()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<org.apache.activemq.management.JMSConsumerStatsImpl: void reset()>();
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.JMSProducerStatsImpl[] getProducers()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<org.apache.activemq.management.JMSProducerStatsImpl: void reset()>();
v = v + 1;
goto label;
label:
return;
}
public void setEnabled(boolean)
{
org.apache.activemq.management.JMSConsumerStatsImpl v;
org.apache.activemq.management.JMSProducerStatsImpl v;
org.apache.activemq.management.JMSConsumerStatsImpl[] v;
int v, v, v, v;
org.apache.activemq.management.JMSProducerStatsImpl[] v;
org.apache.activemq.management.JMSSessionStatsImpl v;
boolean v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v := @parameter: boolean;
specialinvoke v.<org.apache.activemq.management.StatsImpl: void setEnabled(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.JMSConsumerStatsImpl[] getConsumers()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<org.apache.activemq.management.JMSConsumerStatsImpl: void setEnabled(boolean)>(v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.JMSProducerStatsImpl[] getProducers()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<org.apache.activemq.management.JMSProducerStatsImpl: void setEnabled(boolean)>(v);
v = v + 1;
goto label;
label:
return;
}
public org.apache.activemq.management.CountStatisticImpl getMessageCount()
{
org.apache.activemq.management.CountStatisticImpl v;
org.apache.activemq.management.JMSSessionStatsImpl v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl messageCount>;
return v;
}
public org.apache.activemq.management.CountStatisticImpl getPendingMessageCount()
{
org.apache.activemq.management.CountStatisticImpl v;
org.apache.activemq.management.JMSSessionStatsImpl v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl pendingMessageCount>;
return v;
}
public org.apache.activemq.management.CountStatisticImpl getExpiredMessageCount()
{
org.apache.activemq.management.CountStatisticImpl v;
org.apache.activemq.management.JMSSessionStatsImpl v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl expiredMessageCount>;
return v;
}
public org.apache.activemq.management.TimeStatisticImpl getMessageWaitTime()
{
org.apache.activemq.management.TimeStatisticImpl v;
org.apache.activemq.management.JMSSessionStatsImpl v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.TimeStatisticImpl messageWaitTime>;
return v;
}
public org.apache.activemq.management.CountStatisticImpl getDurableSubscriptionCount()
{
org.apache.activemq.management.CountStatisticImpl v;
org.apache.activemq.management.JMSSessionStatsImpl v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl durableSubscriptionCount>;
return v;
}
public org.apache.activemq.management.TimeStatisticImpl getMessageRateTime()
{
org.apache.activemq.management.TimeStatisticImpl v;
org.apache.activemq.management.JMSSessionStatsImpl v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.TimeStatisticImpl messageRateTime>;
return v;
}
public java.lang.String toString()
{
org.apache.activemq.management.JMSProducerStatsImpl v;
org.apache.activemq.management.JMSConsumerStatsImpl[] v;
org.apache.activemq.management.CountStatisticImpl v, v, v, v;
java.lang.StringBuffer v;
int v, v, v, v;
java.lang.String v, v, v;
org.apache.activemq.management.JMSProducerStatsImpl[] v;
org.apache.activemq.management.JMSSessionStatsImpl v;
org.apache.activemq.management.JMSConsumerStatsImpl v;
org.apache.activemq.management.TimeStatisticImpl v, v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v = new java.lang.StringBuffer;
specialinvoke v.<java.lang.StringBuffer: void <init>(java.lang.String)>(" ");
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl messageCount>;
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(" ");
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.TimeStatisticImpl messageRateTime>;
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(" ");
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl pendingMessageCount>;
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(" ");
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl expiredMessageCount>;
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(" ");
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.TimeStatisticImpl messageWaitTime>;
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(" ");
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl durableSubscriptionCount>;
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(" producers{ ");
v = virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.JMSProducerStatsImpl[] getProducers()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
if v <= 0 goto label;
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(", ");
label:
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(" = ");
v = v[v];
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(" } consumers{ ");
v = virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.JMSConsumerStatsImpl[] getConsumers()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
if v <= 0 goto label;
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(", ");
label:
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(" = ");
v = v[v];
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
virtualinvoke v.<java.lang.StringBuffer: java.lang.StringBuffer append(java.lang.String)>(" }");
v = virtualinvoke v.<java.lang.StringBuffer: java.lang.String toString()>();
return v;
}
public void dump(org.apache.activemq.util.IndentPrinter)
{
org.apache.activemq.management.JMSProducerStatsImpl v;
org.apache.activemq.management.JMSConsumerStatsImpl[] v;
org.apache.activemq.management.CountStatisticImpl v, v, v, v;
int v, v, v, v;
org.apache.activemq.management.JMSProducerStatsImpl[] v;
org.apache.activemq.management.JMSSessionStatsImpl v;
org.apache.activemq.management.JMSConsumerStatsImpl v;
org.apache.activemq.util.IndentPrinter v;
org.apache.activemq.management.TimeStatisticImpl v, v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v := @parameter: org.apache.activemq.util.IndentPrinter;
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void printIndent()>();
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl messageCount>;
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void println(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void printIndent()>();
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.TimeStatisticImpl messageRateTime>;
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void println(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void printIndent()>();
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl pendingMessageCount>;
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void println(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void printIndent()>();
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl expiredMessageCount>;
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void println(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void printIndent()>();
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.TimeStatisticImpl messageWaitTime>;
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void println(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void printIndent()>();
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl durableSubscriptionCount>;
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void println(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void println()>();
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void printIndent()>();
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void println(java.lang.String)>("producers {");
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void incrementIndent()>();
v = virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.JMSProducerStatsImpl[] getProducers()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
virtualinvoke v.<org.apache.activemq.management.JMSProducerStatsImpl: void dump(org.apache.activemq.util.IndentPrinter)>(v);
v = v + 1;
goto label;
label:
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void decrementIndent()>();
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void printIndent()>();
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void println(java.lang.String)>("}");
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void printIndent()>();
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void println(java.lang.String)>("consumers {");
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void incrementIndent()>();
v = virtualinvoke v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.JMSConsumerStatsImpl[] getConsumers()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
virtualinvoke v.<org.apache.activemq.management.JMSConsumerStatsImpl: void dump(org.apache.activemq.util.IndentPrinter)>(v);
v = v + 1;
goto label;
label:
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void decrementIndent()>();
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void printIndent()>();
virtualinvoke v.<org.apache.activemq.util.IndentPrinter: void println(java.lang.String)>("}");
return;
}
public void onCreateDurableSubscriber()
{
org.apache.activemq.management.CountStatisticImpl v;
org.apache.activemq.management.JMSSessionStatsImpl v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl durableSubscriptionCount>;
virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: void increment()>();
return;
}
public void onRemoveDurableSubscriber()
{
org.apache.activemq.management.CountStatisticImpl v;
org.apache.activemq.management.JMSSessionStatsImpl v;
v := @this: org.apache.activemq.management.JMSSessionStatsImpl;
v = v.<org.apache.activemq.management.JMSSessionStatsImpl: org.apache.activemq.management.CountStatisticImpl durableSubscriptionCount>;
virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: void decrement()>();
return;
}
}