public class psiprobe.beans.ClusterWrapperBean extends java.lang.Object
{
public void <init>()
{
psiprobe.beans.ClusterWrapperBean v;
v := @this: psiprobe.beans.ClusterWrapperBean;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public psiprobe.model.jmx.Cluster getCluster(java.lang.String, java.lang.String, boolean) throws java.lang.Exception
{
java.util.Set v, v;
psiprobe.beans.ClusterWrapperBean v;
psiprobe.model.jmx.AsyncClusterSender v;
long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
psiprobe.model.jmx.SyncClusterSender v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
psiprobe.model.jmx.PooledClusterSender v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v;
javax.management.ObjectName v, v, v, v, v, v;
java.util.List v;
javax.management.MBeanServer v;
int v, v, v, v, v, v, v, v, v, v, v, v;
psiprobe.model.jmx.ClusterSender v, v;
java.util.Iterator v;
psiprobe.model.jmx.Cluster v, v;
java.lang.Object v, v, v, v, v, v;
v := @this: psiprobe.beans.ClusterWrapperBean;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = null;
v = staticinvoke <java.lang.management.ManagementFactory: javax.management.MBeanServer getPlatformMBeanServer()>();
v = new javax.management.ObjectName;
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[])>("\u0001:type=ClusterMembership,host=\u0001");
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v = new javax.management.ObjectName;
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[])>("\u0001:type=ClusterReceiver,host=\u0001");
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v = new javax.management.ObjectName;
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[])>("\u0001:type=ClusterSender,host=\u0001");
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v = new javax.management.ObjectName;
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[])>("*:type=Cluster,host=\u0001");
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v = interfaceinvoke v.<javax.management.MBeanServer: java.util.Set queryMBeans(javax.management.ObjectName,javax.management.QueryExp)>(v, null);
v = interfaceinvoke v.<javax.management.MBeanServer: java.util.Set queryMBeans(javax.management.ObjectName,javax.management.QueryExp)>(v, null);
if v == null goto label;
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
if v == null goto label;
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<javax.management.ObjectInstance: javax.management.ObjectName getObjectName()>();
v = new psiprobe.model.jmx.Cluster;
specialinvoke v.<psiprobe.model.jmx.Cluster: void <init>()>();
v = v;
v = staticinvoke <psiprobe.tools.JmxTools: java.lang.String getStringAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "clusterName");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setName(java.lang.String)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: java.lang.String getStringAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "info");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setInfo(java.lang.String)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: java.lang.String getStringAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "managerClassName");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setManagerClassName(java.lang.String)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: java.lang.String getStringAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "mcastAddr");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setMcastAddress(java.lang.String)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: java.lang.String getStringAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "mcastBindAddress");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setMcastBindAddress(java.lang.String)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: java.lang.String getStringAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "mcastClusterDomain");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setMcastClusterDomain(java.lang.String)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "mcastDropTime");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setMcastDropTime(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "mcastFrequency");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setMcastFrequency(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: int getIntAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "mcastPort");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setMcastPort(int)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: int getIntAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "mcastSoTimeout");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setMcastSoTimeout(int)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: int getIntAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "mcastTTL");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setMcastTtl(int)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: java.lang.String getStringAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "tcpListenAddress");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setTcpListenAddress(java.lang.String)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: int getIntAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "tcpListenPort");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setTcpListenPort(int)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "nrOfMsgsReceived");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setNrOfMsgsReceived(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "totalReceivedBytes");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setTotalReceivedBytes(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "ackTimeout");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setSenderAckTimeout(long)>(v);
v = interfaceinvoke v.<javax.management.MBeanServer: java.lang.Object getAttribute(javax.management.ObjectName,java.lang.String)>(v, "autoConnect");
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setSenderAutoConnect(boolean)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "failureCounter");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setSenderFailureCounter(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "nrOfRequests");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setSenderNrOfRequests(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: java.lang.String getStringAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "replicationMode");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setSenderReplicationMode(java.lang.String)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "totalBytes");
virtualinvoke v.<psiprobe.model.jmx.Cluster: void setSenderTotalBytes(long)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<javax.management.MBeanServer: java.lang.Object getAttribute(javax.management.ObjectName,java.lang.String)>(v, "senderObjectNames");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = "pooled";
v = virtualinvoke v.<psiprobe.model.jmx.Cluster: java.lang.String getSenderReplicationMode()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = new psiprobe.model.jmx.PooledClusterSender;
specialinvoke v.<psiprobe.model.jmx.PooledClusterSender: void <init>()>();
v = v;
goto label;
label:
v = "synchronous";
v = virtualinvoke v.<psiprobe.model.jmx.Cluster: java.lang.String getSenderReplicationMode()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = new psiprobe.model.jmx.SyncClusterSender;
specialinvoke v.<psiprobe.model.jmx.SyncClusterSender: void <init>()>();
v = v;
goto label;
label:
v = "asynchronous";
v = virtualinvoke v.<psiprobe.model.jmx.Cluster: java.lang.String getSenderReplicationMode()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = "fastasyncqueue";
v = virtualinvoke v.<psiprobe.model.jmx.Cluster: java.lang.String getSenderReplicationMode()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = new psiprobe.model.jmx.AsyncClusterSender;
specialinvoke v.<psiprobe.model.jmx.AsyncClusterSender: void <init>()>();
v = v;
goto label;
label:
v = new psiprobe.model.jmx.ClusterSender;
specialinvoke v.<psiprobe.model.jmx.ClusterSender: void <init>()>();
v = v;
label:
v = staticinvoke <psiprobe.tools.JmxTools: java.lang.String getStringAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "address");
virtualinvoke v.<psiprobe.model.jmx.ClusterSender: void setAddress(java.lang.String)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: int getIntAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "port");
virtualinvoke v.<psiprobe.model.jmx.ClusterSender: void setPort(int)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String,long)>(v, v, "avgMessageSize", -1L);
virtualinvoke v.<psiprobe.model.jmx.ClusterSender: void setAvgMessageSize(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String,long)>(v, v, "avgProcessingTime", -1L);
virtualinvoke v.<psiprobe.model.jmx.ClusterSender: void setAvgProcessingTime(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "connectCounter");
virtualinvoke v.<psiprobe.model.jmx.ClusterSender: void setConnectCounter(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "disconnectCounter");
virtualinvoke v.<psiprobe.model.jmx.ClusterSender: void setDisconnectCounter(long)>(v);
v = interfaceinvoke v.<javax.management.MBeanServer: java.lang.Object getAttribute(javax.management.ObjectName,java.lang.String)>(v, "connected");
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<psiprobe.model.jmx.ClusterSender: void setConnected(boolean)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "keepAliveTimeout");
virtualinvoke v.<psiprobe.model.jmx.ClusterSender: void setKeepAliveTimeout(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "nrOfRequests");
virtualinvoke v.<psiprobe.model.jmx.ClusterSender: void setNrOfRequests(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "totalBytes");
virtualinvoke v.<psiprobe.model.jmx.ClusterSender: void setTotalBytes(long)>(v);
v = interfaceinvoke v.<javax.management.MBeanServer: java.lang.Object getAttribute(javax.management.ObjectName,java.lang.String)>(v, "resend");
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<psiprobe.model.jmx.ClusterSender: void setResend(boolean)>(v);
v = interfaceinvoke v.<javax.management.MBeanServer: java.lang.Object getAttribute(javax.management.ObjectName,java.lang.String)>(v, "suspect");
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<psiprobe.model.jmx.ClusterSender: void setSuspect(boolean)>(v);
v = v instanceof psiprobe.model.jmx.PooledClusterSender;
if v == 0 goto label;
v = staticinvoke <psiprobe.tools.JmxTools: int getIntAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "maxPoolSocketLimit");
virtualinvoke v.<psiprobe.model.jmx.PooledClusterSender: void setMaxPoolSocketLimit(int)>(v);
label:
v = v instanceof psiprobe.model.jmx.SyncClusterSender;
if v == 0 goto label;
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "dataFailureCounter");
virtualinvoke v.<psiprobe.model.jmx.SyncClusterSender: void setDataFailureCounter(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "dataResendCounter");
virtualinvoke v.<psiprobe.model.jmx.SyncClusterSender: void setDataResendCounter(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: int getIntAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "socketOpenCounter");
virtualinvoke v.<psiprobe.model.jmx.SyncClusterSender: void setSocketOpenCounter(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: int getIntAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "socketCloseCounter");
virtualinvoke v.<psiprobe.model.jmx.SyncClusterSender: void setSocketCloseCounter(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: int getIntAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "socketOpenFailureCounter");
virtualinvoke v.<psiprobe.model.jmx.SyncClusterSender: void setSocketOpenFailureCounter(long)>(v);
label:
v = v instanceof psiprobe.model.jmx.AsyncClusterSender;
if v == 0 goto label;
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "inQueueCounter");
virtualinvoke v.<psiprobe.model.jmx.AsyncClusterSender: void setInQueueCounter(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "outQueueCounter");
virtualinvoke v.<psiprobe.model.jmx.AsyncClusterSender: void setOutQueueCounter(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: int getIntAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "queueSize");
virtualinvoke v.<psiprobe.model.jmx.AsyncClusterSender: void setQueueSize(long)>(v);
v = staticinvoke <psiprobe.tools.JmxTools: long getLongAttr(javax.management.MBeanServer,javax.management.ObjectName,java.lang.String)>(v, v, "queuedNrOfBytes");
virtualinvoke v.<psiprobe.model.jmx.AsyncClusterSender: void setQueuedNrOfBytes(long)>(v);
label:
v = virtualinvoke v.<psiprobe.model.jmx.Cluster: java.util.List getMembers()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
return v;
}
}