in src/main/csharp/Transport/InactivityMonitor.cs [208:245]
protected override void OnCommand(ITransport sender, Command command)
{
commandReceived.Value = true;
inRead.Value = true;
try
{
if(command.IsWireFormatInfo)
{
lock(monitor)
{
remoteWireFormatInfo = command as WireFormatInfo;
try
{
StartMonitorThreads();
}
catch(IOException ex)
{
OnException(this, ex);
}
}
}
else if(command.IsKeepAliveInfo)
{
if(Tracer.IsDebugEnabled)
{
Tracer.DebugFormat("InactivityMonitor[{0}]: New Keep Alive Received at -> " +
DateTime.Now.ToLongTimeString().TrimEnd(" APM".ToCharArray()) +
"." + DateTime.Now.Millisecond, instanceId);
}
}
base.OnCommand(sender, command);
}
finally
{
inRead.Value = false;
}
}