[jira] [Created] (GEODE-4100) When an unresponsive client with CQs registered gets disconnected, the onCqDisconnected callback is not invoked

["Barry Oglesby (JIRA)" <ji...@apache.org>]

Barry Oglesby created GEODE-4100:
------------------------------------

             Summary: When an unresponsive client with CQs registered gets disconnected, the onCqDisconnected callback is not invoked
                 Key: GEODE-4100
                 URL: https://issues.apache.org/jira/browse/GEODE-4100
             Project: Geode
          Issue Type: Bug
          Components: client queues, cq
            Reporter: Barry Oglesby


Neither is the {{onCqConnected}} callback invoked when the client reconnects.

{{QueueManagerImpl.recoverPrimary}} attempts to invoke the {{onCqConnected}} callback (by {{cqsConnected}}), but it is short-circuited by this check in {{CqServiceImpl invokeCqsConnected}}:
{noformat}
if (cqPoolsConnected.containsKey(poolName) && connected == cqPoolsConnected.get(poolName)) {
  return;
}
{noformat}
That check basically means the previous time this method was called, it was called with {{connected==true}}, so this call to {{invokeCqsConnected}} will succeed once {{QueueManagerImpl}} calls {{cqsDisconnected}} at the appropriate spot after the client is disconnected.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)