public class org.apache.activemq.transport.stomp.StompInactivityMonitor extends org.apache.activemq.transport.AbstractInactivityMonitor
{
private static final org.slf4j.Logger LOG;
private boolean isConfigured;
public void <init>(org.apache.activemq.transport.Transport, org.apache.activemq.wireformat.WireFormat)
{
org.apache.activemq.transport.Transport v;
org.apache.activemq.transport.stomp.StompInactivityMonitor v;
org.apache.activemq.wireformat.WireFormat v;
v := @this: org.apache.activemq.transport.stomp.StompInactivityMonitor;
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.stomp.StompInactivityMonitor: boolean isConfigured> = 0;
return;
}
public void startMonitoring() throws java.io.IOException
{
org.apache.activemq.transport.stomp.StompInactivityMonitor v;
v := @this: org.apache.activemq.transport.stomp.StompInactivityMonitor;
v.<org.apache.activemq.transport.stomp.StompInactivityMonitor: boolean isConfigured> = 1;
virtualinvoke v.<org.apache.activemq.transport.stomp.StompInactivityMonitor: void stopConnectCheckTask()>();
virtualinvoke v.<org.apache.activemq.transport.stomp.StompInactivityMonitor: void startMonitorThreads()>();
return;
}
protected void processInboundWireFormatInfo(org.apache.activemq.command.WireFormatInfo) throws java.io.IOException
{
org.apache.activemq.transport.stomp.StompInactivityMonitor v;
org.apache.activemq.command.WireFormatInfo v;
v := @this: org.apache.activemq.transport.stomp.StompInactivityMonitor;
v := @parameter: org.apache.activemq.command.WireFormatInfo;
return;
}
protected void processOutboundWireFormatInfo(org.apache.activemq.command.WireFormatInfo) throws java.io.IOException
{
org.apache.activemq.transport.stomp.StompInactivityMonitor v;
org.apache.activemq.command.WireFormatInfo v;
v := @this: org.apache.activemq.transport.stomp.StompInactivityMonitor;
v := @parameter: org.apache.activemq.command.WireFormatInfo;
return;
}
protected boolean configuredOk() throws java.io.IOException
{
org.slf4j.Logger v;
long v, v, v, v;
org.apache.activemq.transport.stomp.StompInactivityMonitor v;
byte v, v;
java.lang.Long v, v;
boolean v, v;
v := @this: org.apache.activemq.transport.stomp.StompInactivityMonitor;
v = v.<org.apache.activemq.transport.stomp.StompInactivityMonitor: boolean isConfigured>;
if v != 0 goto label;
return 0;
label:
v = <org.apache.activemq.transport.stomp.StompInactivityMonitor: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.StompInactivityMonitor: long getReadCheckTime()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = virtualinvoke v.<org.apache.activemq.transport.stomp.StompInactivityMonitor: long getWriteCheckTime()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Stomp Inactivity Monitor read check interval: {}ms, write check interval: {}ms", v, v);
v = virtualinvoke v.<org.apache.activemq.transport.stomp.StompInactivityMonitor: long getReadCheckTime()>();
v = v cmp 0L;
if v < 0 goto label;
v = virtualinvoke v.<org.apache.activemq.transport.stomp.StompInactivityMonitor: long getWriteCheckTime()>();
v = v cmp 0L;
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/transport/stomp/StompInactivityMonitor;");
<org.apache.activemq.transport.stomp.StompInactivityMonitor: org.slf4j.Logger LOG> = v;
return;
}
}