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)
