public class org.apache.activemq.broker.jmx.ProducerView extends java.lang.Object implements org.apache.activemq.broker.jmx.ProducerViewMBean
{
protected final org.apache.activemq.command.ProducerInfo info;
protected final java.lang.String clientId;
protected final java.lang.String userName;
protected final org.apache.activemq.broker.jmx.ManagedRegionBroker broker;
protected org.apache.activemq.command.ActiveMQDestination lastUsedDestination;
public void <init>(org.apache.activemq.command.ProducerInfo, java.lang.String, java.lang.String, org.apache.activemq.broker.jmx.ManagedRegionBroker)
{
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v;
java.lang.String v, v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v := @parameter: org.apache.activemq.command.ProducerInfo;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.activemq.broker.jmx.ManagedRegionBroker;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info> = v;
v.<org.apache.activemq.broker.jmx.ProducerView: java.lang.String clientId> = v;
v.<org.apache.activemq.broker.jmx.ProducerView: java.lang.String userName> = v;
v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.broker.jmx.ManagedRegionBroker broker> = v;
return;
}
public java.lang.String getClientId()
{
java.lang.String v;
org.apache.activemq.broker.jmx.ProducerView v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: java.lang.String clientId>;
return v;
}
public java.lang.String getConnectionId()
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v, v;
java.lang.String v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ProducerId getProducerId()>();
v = virtualinvoke v.<org.apache.activemq.command.ProducerId: java.lang.String getConnectionId()>();
return v;
label:
return "NOTSET";
}
public long getSessionId()
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v, v;
long v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ProducerId getProducerId()>();
v = virtualinvoke v.<org.apache.activemq.command.ProducerId: long getSessionId()>();
return v;
label:
return 0L;
}
public java.lang.String getProducerId()
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v, v;
java.lang.String v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ProducerId getProducerId()>();
v = virtualinvoke v.<org.apache.activemq.command.ProducerId: java.lang.String toString()>();
return v;
label:
return "NOTSET";
}
public java.lang.String getDestinationName()
{
org.apache.activemq.command.ActiveMQDestination v, v, v, v;
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v, v, v;
java.lang.String v, v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
return v;
label:
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ActiveMQDestination lastUsedDestination>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ActiveMQDestination lastUsedDestination>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
return v;
label:
return "NOTSET";
}
public boolean isDestinationQueue()
{
org.apache.activemq.command.ActiveMQDestination v, v, v, v;
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v, v, v;
boolean v, v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
return v;
label:
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ActiveMQDestination lastUsedDestination>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ActiveMQDestination lastUsedDestination>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
return v;
label:
return 0;
}
public boolean isDestinationTopic()
{
org.apache.activemq.command.ActiveMQDestination v, v, v, v;
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v, v, v;
boolean v, v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
return v;
label:
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ActiveMQDestination lastUsedDestination>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ActiveMQDestination lastUsedDestination>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
return v;
label:
return 0;
}
public boolean isDestinationTemporary()
{
org.apache.activemq.command.ActiveMQDestination v, v, v, v;
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v, v, v;
boolean v, v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTemporary()>();
return v;
label:
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ActiveMQDestination lastUsedDestination>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ActiveMQDestination lastUsedDestination>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTemporary()>();
return v;
label:
return 0;
}
public int getProducerWindowSize()
{
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v, v;
int v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: int getWindowSize()>();
return v;
label:
return 0;
}
public boolean isDispatchAsync()
{
org.apache.activemq.broker.jmx.ProducerView v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
return 0;
}
public java.lang.String toString()
{
org.apache.activemq.broker.jmx.ProducerView v;
java.lang.String v, v, v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ProducerView: java.lang.String getClientId()>();
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ProducerView: java.lang.String getConnectionId()>();
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[])>("ProducerView: \u0001:\u0001");
return v;
}
void setLastUsedDestinationName(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ActiveMQDestination lastUsedDestination> = v;
return;
}
public java.lang.String getUserName()
{
java.lang.String v;
org.apache.activemq.broker.jmx.ProducerView v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: java.lang.String userName>;
return v;
}
public boolean isProducerBlocked()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v;
org.apache.activemq.broker.ProducerBrokerExchange v;
boolean v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.broker.jmx.ManagedRegionBroker broker>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.ProducerBrokerExchange getProducerBrokerExchange(org.apache.activemq.command.ProducerInfo)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.ProducerBrokerExchange: boolean isBlockedForFlowControl()>();
return v;
label:
return 0;
}
public long getTotalTimeBlocked()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v;
long v;
org.apache.activemq.broker.ProducerBrokerExchange v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.broker.jmx.ManagedRegionBroker broker>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.ProducerBrokerExchange getProducerBrokerExchange(org.apache.activemq.command.ProducerInfo)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.ProducerBrokerExchange: long getTotalTimeBlocked()>();
return v;
label:
return 0L;
}
public int getPercentageBlocked()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v;
int v;
org.apache.activemq.broker.ProducerBrokerExchange v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.broker.jmx.ManagedRegionBroker broker>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.ProducerBrokerExchange getProducerBrokerExchange(org.apache.activemq.command.ProducerInfo)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.ProducerBrokerExchange: int getPercentageBlocked()>();
return v;
label:
return 0;
}
public void resetFlowControlStats()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v;
org.apache.activemq.broker.ProducerBrokerExchange v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.broker.jmx.ManagedRegionBroker broker>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.ProducerBrokerExchange getProducerBrokerExchange(org.apache.activemq.command.ProducerInfo)>(v);
if v == null goto label;
virtualinvoke v.<org.apache.activemq.broker.ProducerBrokerExchange: void resetFlowControl()>();
label:
return;
}
public void resetStatistics()
{
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v, v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
virtualinvoke v.<org.apache.activemq.command.ProducerInfo: void resetSentCount()>();
label:
return;
}
public long getSentCount()
{
org.apache.activemq.broker.jmx.ProducerView v;
org.apache.activemq.command.ProducerInfo v, v;
long v;
v := @this: org.apache.activemq.broker.jmx.ProducerView;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
if v == null goto label;
v = v.<org.apache.activemq.broker.jmx.ProducerView: org.apache.activemq.command.ProducerInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: long getSentCount()>();
goto label;
label:
v = 0L;
label:
return v;
}
}