Mailing-List: contact dev-help@geode.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@geode.apache.org
MIME-Version: 1.0
In-Reply-To: <1FAAFA7A34E1AE429F43B79CE5FD92460179F33186@ILRAADAGBE3.corp.amdocs.com>
References: <1FAAFA7A34E1AE429F43B79CE5FD92460179F330AA@ILRAADAGBE3.corp.amdocs.com>
 <CAEzsiBOLf2uQZ6MkrbEu7aD1WtQSz-h3S_mUafjHBMqNj3sxqg@mail.gmail.com> <1FAAFA7A34E1AE429F43B79CE5FD92460179F33186@ILRAADAGBE3.corp.amdocs.com>
From: Anilkumar Gingade <agingade@pivotal.io>
Date: Mon, 7 Aug 2017 12:12:23 -0700
Message-ID: <CAEzsiBNJTXh+q13TQK_0qDqW784OhiPzP7Ti=NHAz=c335NSMA@mail.gmail.com>
Subject: Re: continuous query internal mechanism
To: dev@geode.apache.org
Content-Type: multipart/alternative; boundary="001a11397ee2a1a01e05562ea17d"
archived-at: Mon, 07 Aug 2017 19:12:54 -0000

--001a11397ee2a1a01e05562ea17d
Content-Type: text/plain; charset="UTF-8"

CQ Processing on server side is same for all clients (Java, C++)...

The subscription events are sent to client as ClientUpdateMessage, which
holds information about registered events and CQ events. The client process
this and updates/invokes the client side cache/listeners with respective
event. Look into ClientUpdateMessageImpl and CacheClientUpdater (for client
side processing).

-Anil.


On Mon, Aug 7, 2017 at 11:01 AM, Roi Apelker <Roi.Apelker@amdocs.com> wrote:

> Thanks,
>
> By the way, is there any difference in the behaviour of the server, if the
> client that registered the CQ is a native (C++) client?
>
> I have been going over the classes and code for some time and can't seem
> to find the actual location where a CQ update/notification is sent...
>
> It's like CqEventImpl class is never even generated in this scenario.
>
> If anyone can help here I would be most grateful :-)
>
> Thanks
>
> Roi
>
>
>
> -----Original Message-----
> From: Anilkumar Gingade [mailto:agingade@pivotal.io]
> Sent: Monday, August 07, 2017 8:23 PM
> To: dev@geode.apache.org
> Subject: Re: continuous query internal mechanism
>
> You can find those in CqServiceImpl.process*()...
>
> -Anil.
>
>
> On Mon, Aug 7, 2017 at 9:14 AM, Roi Apelker <Roi.Apelker@amdocs.com>
> wrote:
>
> > Hello,
> >
> > I am trying to look into the code of the continuous query mechanism -
> > where the GEODE server sends the notification back to the client.
> >
> > Can anyone point me to the central classes of continuous query,
> > especially to the one that is responsible for the calculation of the
> > new data and packing it as a message back to the client?
> >
> > Thanks,
> >
> > Roi
> >
> > This message and the information contained herein is proprietary and
> > confidential and subject to the Amdocs policy statement,
> >
> > you may review at https://www.amdocs.com/about/email-disclaimer <
> > https://www.amdocs.com/about/email-disclaimer>
> >
> This message and the information contained herein is proprietary and
> confidential and subject to the Amdocs policy statement,
>
> you may review at https://www.amdocs.com/about/email-disclaimer <
> https://www.amdocs.com/about/email-disclaimer>
>

--001a11397ee2a1a01e05562ea17d--