[
https://issues.apache.org/jira/browse/GEODE-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15398555#comment-15398555
]
ASF subversion and git services commented on GEODE-1687:
--------------------------------------------------------
Commit a4f93cdd634e02de13c169978e61851f810a8a32 in incubator-geode's branch
refs/heads/develop from [~agingade]
[ https://git-wip-us.apache.org/repos/asf?p=incubator-geode.git;h=a4f93cd ]
GEODE-1687: Added null check for CQs proxy connection.
When a connection relating to CQ is established or dropped, CqStatusListner is
invoked
to indicate connection/subscription status. This allows application to handle
if all
the subscription connection is lost for CQs.
Looking at the code path for CqStatusListener there is a chance of NPE getting
thrown
in CqServiceImpl.invokeCqsConnected when CQ is executed using the Bridge loader
interface (old way of client-server connection)...
> NPE during CqStatusListener method invocation.
> ----------------------------------------------
>
> Key: GEODE-1687
> URL: https://issues.apache.org/jira/browse/GEODE-1687
> Project: Geode
> Issue Type: Bug
> Components: cq
> Reporter: Anilkumar Gingade
> Assignee: Anilkumar Gingade
>
> When a connection relating to CQ is established or dropped, CqStatusListner
> is invoked to indicate connection/subscription status. This allows
> application to handle if all the subscription connection is lost for CQs.
> Looking at the code path for CqStatusListener there is a chance of NPE
> getting thrown in CqServiceImpl.invokeCqsConnected when CQ is executed using
> the Bridge loader interface (old way of client-server
> connection)....
> When a pool or bridge-loader connection is made or dropped, the code gets all
> the CQs; checks if the CQ is registered using that connection/pool name and
> invokes the CqStatusListner...
> The code to check if CQ is using the corresponding pool:
> Pool cqPool = cQuery.getCQProxy().getPool();
> If the CQ is getting executed using Bridge loader, the CqProxy for CQ is not
> set when its constructed; its set when it gets executed....During this time
> the call to cQuery.getCQProxy() could throw NPE.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
