public class org.apache.activemq.transport.InactivityMonitor extends org.apache.activemq.transport.AbstractInactivityMonitor
{
private static final org.slf4j.Logger LOG;
private org.apache.activemq.command.WireFormatInfo localWireFormatInfo;
private org.apache.activemq.command.WireFormatInfo remoteWireFormatInfo;
private boolean ignoreRemoteWireFormat;
private boolean ignoreAllWireFormatInfo;
public void <init>(org.apache.activemq.transport.Transport, org.apache.activemq.wireformat.WireFormat)
{
org.apache.activemq.transport.InactivityMonitor v;
org.apache.activemq.wireformat.WireFormat v, v;
org.apache.activemq.transport.Transport v;
v := @this: org.apache.activemq.transport.InactivityMonitor;
v := @parameter: org.apache.activemq.transport.Transport;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
specialinvoke v.<org.apache.activemq.transport.AbstractInactivityMonitor: void <init>(org.apache.activemq.transport.Transport,org.apache.activemq.wireformat.WireFormat)>(v, v);
v.<org.apache.activemq.transport.InactivityMonitor: boolean ignoreRemoteWireFormat> = 0;
v.<org.apache.activemq.transport.InactivityMonitor: boolean ignoreAllWireFormatInfo> = 0;
v = v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.wireformat.WireFormat wireFormat>;
if v != null goto label;
v.<org.apache.activemq.transport.InactivityMonitor: boolean ignoreAllWireFormatInfo> = 1;
label:
return;
}
public void start() throws java.lang.Exception
{
boolean v;
org.apache.activemq.transport.InactivityMonitor v;
v := @this: org.apache.activemq.transport.InactivityMonitor;
v = virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: boolean isMonitorStarted()>();
if v != 0 goto label;
virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: void startConnectCheckTask()>();
label:
specialinvoke v.<org.apache.activemq.transport.AbstractInactivityMonitor: void start()>();
return;
}
protected void processInboundWireFormatInfo(org.apache.activemq.command.WireFormatInfo) throws java.io.IOException
{
org.apache.activemq.transport.InactivityMonitor v;
java.io.IOException v, v;
org.apache.activemq.command.WireFormatInfo v;
v := @this: org.apache.activemq.transport.InactivityMonitor;
v := @parameter: org.apache.activemq.command.WireFormatInfo;
virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: void stopConnectCheckTask()>();
v = null;
v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo remoteWireFormatInfo> = v;
label:
virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: void startMonitorThreads()>();
label:
goto label;
label:
v := @caughtexception;
v = v;
label:
if v == null goto label;
virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: void onException(java.io.IOException)>(v);
label:
return;
catch java.io.IOException from label to label with label;
}
protected void processOutboundWireFormatInfo(org.apache.activemq.command.WireFormatInfo) throws java.io.IOException
{
org.apache.activemq.command.WireFormatInfo v;
org.apache.activemq.transport.InactivityMonitor v;
v := @this: org.apache.activemq.transport.InactivityMonitor;
v := @parameter: org.apache.activemq.command.WireFormatInfo;
v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo localWireFormatInfo> = v;
virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: void startMonitorThreads()>();
return;
}
protected synchronized void startMonitorThreads() throws java.io.IOException
{
byte v;
org.apache.activemq.transport.InactivityMonitor v;
long v, v;
boolean v;
v := @this: org.apache.activemq.transport.InactivityMonitor;
v = virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: boolean isMonitorStarted()>();
if v == 0 goto label;
return;
label:
v = virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: long getReadCheckTime()>();
v = v cmp 0L;
if v <= 0 goto label;
v = specialinvoke v.<org.apache.activemq.transport.InactivityMonitor: long writeCheckValueFromReadCheck(long)>(v);
virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: void setWriteCheckTime(long)>(v);
label:
specialinvoke v.<org.apache.activemq.transport.AbstractInactivityMonitor: void startMonitorThreads()>();
return;
}
private long writeCheckValueFromReadCheck(long)
{
byte v;
org.apache.activemq.transport.InactivityMonitor v;
long v, v;
v := @this: org.apache.activemq.transport.InactivityMonitor;
v := @parameter: long;
v = v cmp 3L;
if v <= 0 goto label;
v = v / 3L;
goto label;
label:
v = v;
label:
return v;
}
protected boolean configuredOk() throws java.io.IOException
{
org.apache.activemq.transport.InactivityMonitor v;
boolean v, v, v, v, v;
org.apache.activemq.command.WireFormatInfo v, v, v, v, v, v, v, v, v, v, v;
long v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v;
org.slf4j.Logger v, v, v, v;
v := @this: org.apache.activemq.transport.InactivityMonitor;
v = 0;
v = v.<org.apache.activemq.transport.InactivityMonitor: boolean ignoreAllWireFormatInfo>;
if v == 0 goto label;
v = 1;
goto label;
label:
v = v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo localWireFormatInfo>;
if v == null goto label;
v = v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo remoteWireFormatInfo>;
if v == null goto label;
v = v.<org.apache.activemq.transport.InactivityMonitor: boolean ignoreRemoteWireFormat>;
if v != 0 goto label;
v = <org.apache.activemq.transport.InactivityMonitor: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.activemq.transport.InactivityMonitor: org.slf4j.Logger LOG>;
v = v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo localWireFormatInfo>;
v = v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo remoteWireFormatInfo>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.WireFormatInfo,org.apache.activemq.command.WireFormatInfo)>(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[])>("Using min of local: \u and remote: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
v = v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo localWireFormatInfo>;
v = virtualinvoke v.<org.apache.activemq.command.WireFormatInfo: long getMaxInactivityDuration()>();
v = v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo remoteWireFormatInfo>;
v = virtualinvoke v.<org.apache.activemq.command.WireFormatInfo: long getMaxInactivityDuration()>();
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = specialinvoke v.<org.apache.activemq.transport.InactivityMonitor: long writeCheckValueFromReadCheck(long)>(v);
virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: void setReadCheckTime(long)>(v);
v = v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo localWireFormatInfo>;
v = virtualinvoke v.<org.apache.activemq.command.WireFormatInfo: long getMaxInactivityDurationInitalDelay()>();
v = v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo remoteWireFormatInfo>;
v = virtualinvoke v.<org.apache.activemq.command.WireFormatInfo: long getMaxInactivityDurationInitalDelay()>();
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: void setInitialDelayTime(long)>(v);
virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: void setWriteCheckTime(long)>(v);
goto label;
label:
v = <org.apache.activemq.transport.InactivityMonitor: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.activemq.transport.InactivityMonitor: org.slf4j.Logger LOG>;
v = v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo localWireFormatInfo>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.WireFormatInfo)>(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[])>("Using local: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
v = v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo localWireFormatInfo>;
v = virtualinvoke v.<org.apache.activemq.command.WireFormatInfo: long getMaxInactivityDuration()>();
v = specialinvoke v.<org.apache.activemq.transport.InactivityMonitor: long writeCheckValueFromReadCheck(long)>(v);
virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: void setReadCheckTime(long)>(v);
v = v.<org.apache.activemq.transport.InactivityMonitor: org.apache.activemq.command.WireFormatInfo localWireFormatInfo>;
v = virtualinvoke v.<org.apache.activemq.command.WireFormatInfo: long getMaxInactivityDurationInitalDelay()>();
virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: void setInitialDelayTime(long)>(v);
virtualinvoke v.<org.apache.activemq.transport.InactivityMonitor: void setWriteCheckTime(long)>(v);
label:
v = 1;
label:
return v;
}
public boolean isIgnoreAllWireFormatInfo()
{
boolean v;
org.apache.activemq.transport.InactivityMonitor v;
v := @this: org.apache.activemq.transport.InactivityMonitor;
v = v.<org.apache.activemq.transport.InactivityMonitor: boolean ignoreAllWireFormatInfo>;
return v;
}
public void setIgnoreAllWireFormatInfo(boolean)
{
boolean v;
org.apache.activemq.transport.InactivityMonitor v;
v := @this: org.apache.activemq.transport.InactivityMonitor;
v := @parameter: boolean;
v.<org.apache.activemq.transport.InactivityMonitor: boolean ignoreAllWireFormatInfo> = v;
return;
}
public boolean isIgnoreRemoteWireFormat()
{
boolean v;
org.apache.activemq.transport.InactivityMonitor v;
v := @this: org.apache.activemq.transport.InactivityMonitor;
v = v.<org.apache.activemq.transport.InactivityMonitor: boolean ignoreRemoteWireFormat>;
return v;
}
public void setIgnoreRemoteWireFormat(boolean)
{
boolean v;
org.apache.activemq.transport.InactivityMonitor v;
v := @this: org.apache.activemq.transport.InactivityMonitor;
v := @parameter: boolean;
v.<org.apache.activemq.transport.InactivityMonitor: boolean ignoreRemoteWireFormat> = v;
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/transport/InactivityMonitor;");
<org.apache.activemq.transport.InactivityMonitor: org.slf4j.Logger LOG> = v;
return;
}
}