Mailing-List: contact user-help@ignite.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@ignite.apache.org
From: Alex Osmakoff <Alex.Osmakoff@macquarie.com>
To: "user@ignite.apache.org" <user@ignite.apache.org>
Subject: Continuous Query
Thread-Topic: Continuous Query
Thread-Index: AdHRnu4JUWeNdl0ATpOOVa0+rBYV1w==
Date: Wed, 29 Jun 2016 00:58:48 +0000
Message-ID: <ME1PR01MB04664C45E8E1420D22EE2248EB230@ME1PR01MB0466.ausprd01.prod.outlook.com>
Accept-Language: en-US
Content-Language: en-US
received-spf: None (protection.outlook.com: macquarie.com does not designate
 permitted sender hosts)
spamdiagnosticoutput: 1:99
spamdiagnosticmetadata: NSPM
Content-Type: multipart/alternative;
	boundary="_000_ME1PR01MB04664C45E8E1420D22EE2248EB230ME1PR01MB0466ausp_"
MIME-Version: 1.0
X-MS-Exchange-CrossTenant-originalarrivaltime: 29 Jun 2016 00:58:48.1156
 (UTC)
X-MS-Exchange-CrossTenant-fromentityheader: Hosted
X-MS-Exchange-CrossTenant-id: 568a5434-7d3f-4714-b824-fe722e2748c0
X-MS-Exchange-Transport-CrossTenantHeadersStamped: ME1PR01MB0466
X-OriginatorOrg: macquarie.com
X-Brightmail-Tracker: H4sIAAAAAAAAA+NgFupileLIzCtJLcpLzFFi42Lh6vwpp+svWxxucHOuqMWnT59YHBg9Oiab
	BTBGcdmkpOZklqUW6dslcGUs2fWEseC3TkX7rzlsDYyH1bsYOTkkBEwk9nV/Zu5i5OIQEtjC
	KLHyyVlWCOcio8T+txugnKOMEhuO7mKBcE4yShxasBDMYRGYwiyx+PhJqLIrjBILOl5DTTvC
	KPF96lW2LkYODjYBQ4nXN91ANooImEp0zPnBBmILC0hKdF76xQ4Rl5NY+/gfC4StJ3HtzkRW
	EJtFQFXi5+k3YDavQIzErA99YPWMAmIS30+tYQKxmQXEJW49mc8E8ZGAxJI955khbFGJl4//
	sULUx0m0/3nBAhFXlGi/9pcdwvaVaG5fBPaAhEAvs8Sh901sEAk3iZPvDrJC2GISH9ZNhGrO
	lvjZvxSq2UqiY+JxqObljBJv3y6AKpKRuDH9BBtEYj6bxMK274wgCSGBNIkL3/tYId6Xkrh7
	pZNxAqPmLCRfQNj5Em2fJrHOAvtaUOLkzCcsEHEdiQW7P7FB2NoSyxa+Zoaxzxx4zIQsvoCR
	fRWjZFlicWVKanqBhYG5Xm5icmFpYlFmql5yfu4mRmDiWSN4JWwH47w3rocYBTgYlXh4L+wv
	ChdiTSwrrsw9xCjNwaIkzvuy+3mYkEB6YklqdmpqQWpRfFFpTmrxIUYmDk6pBsbAmN6EpDdS
	mfHObpxF5wrv3tOf4S4lptLYV2j7oTbjhaXX5omXOCMapp9PTuy2skrRtj69/MyP9jUr/2oq
	XJF/bpTeLP911828vPrCNZ+yG/cWdebNNsjc5Kwz2dY3+nTdAj6e28GB/1nqDsmsjY3bJae4
	NmQVy3wfhmcMqicznU6tntAfq8RSnJFoqMVcVJwIABfNr34dAwAA
archived-at: Wed, 29 Jun 2016 00:59:10 -0000

--_000_ME1PR01MB04664C45E8E1420D22EE2248EB230ME1PR01MB0466ausp_
Content-Type: text/plain; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable

Hi There,

I am using Continuous Query mechanism and most of the time it works just f=
ine. However, in some cases, it seems intermittently, CQ does not pick up =
the update in the cache where it should.

Could you please clarify the behaviour of Continuous Query in the followin=
g scenario:

My business logic might create multiple identical CQs in separate processi=
ng tasks. As I have no control on where the particular task gets executed =
within the grid it is possible that two identical queries gets created on =
the same node. Now when the cache gets updated and remote filter picks up =
the update to pass it to the local listener of the query, would local list=
eners in both queries be notified or only one? I think the same applies to=
 CACHE_PUT_EVENT propagation in general: if there are two (or more) listen=
ers and only one event would all the listeners be notified regardless of t=
heir location?

Many thanks,

Regards,

Alex

This email and any attachment is confidential. If you are not the intended=
 recipient, please delete this message. Macquarie does not guarantee the i=
ntegrity of any emails or attachments. For important disclosures and infor=
mation about the incorporation and regulated status of Macquarie Group ent=
ities please see: www.macquarie.com/disclosures
--_000_ME1PR01MB04664C45E8E1420D22EE2248EB230ME1PR01MB0466ausp_
Content-Type: text/html; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable

<html xmlns:v=3D"urn:schemas-microsoft-com:vml" xmlns:o=3D"urn:schemas-mic=
rosoft-com:office:office" xmlns:w=3D"urn:schemas-microsoft-com:office:word=
" xmlns:m=3D"http://schemas.microsoft.com/office/2004/12/omml" xmlns=3D"ht=
tp://www.w3.org/TR/REC-html40">
<head>
<meta http-equiv=3D"Content-Type" content=3D"text/html; charset=3Dus-ascii=
">
<meta name=3D"Generator" content=3D"Microsoft Word 15 (filtered medium)">
<style><!--
/* Font Definitions */
@font-face
=09{font-family:"Cambria Math";
=09panose-1:2 4 5 3 5 4 6 3 2 4;}
@font-face
=09{font-family:Calibri;
=09panose-1:2 15 5 2 2 2 4 3 2 4;}
/* Style Definitions */
p.MsoNormal, li.MsoNormal, div.MsoNormal
=09{margin:0cm;
=09margin-bottom:.0001pt;
=09font-size:11.0pt;
=09font-family:"Calibri",sans-serif;
=09mso-fareast-language:EN-US;}
a:link, span.MsoHyperlink
=09{mso-style-priority:99;
=09color:#0563C1;
=09text-decoration:underline;}
a:visited, span.MsoHyperlinkFollowed
=09{mso-style-priority:99;
=09color:#954F72;
=09text-decoration:underline;}
span.EmailStyle17
=09{mso-style-type:personal-compose;
=09font-family:"Arial",sans-serif;
=09color:windowtext;
=09font-weight:normal;
=09font-style:normal;
=09text-decoration:none none;}
.MsoChpDefault
=09{mso-style-type:export-only;
=09font-family:"Calibri",sans-serif;
=09mso-fareast-language:EN-US;}
@page WordSection1
=09{size:612.0pt 792.0pt;
=09margin:72.0pt 72.0pt 72.0pt 72.0pt;}
div.WordSection1
=09{page:WordSection1;}
--></style><!--[if gte mso 9]><xml>
<o:shapedefaults v:ext=3D"edit" spidmax=3D"1026" />
</xml><![endif]--><!--[if gte mso 9]><xml>
<o:shapelayout v:ext=3D"edit">
<o:idmap v:ext=3D"edit" data=3D"1" />
</o:shapelayout></xml><![endif]-->
</head>
<body lang=3D"EN-AU" link=3D"#0563C1" vlink=3D"#954F72">
<div class=3D"WordSection1">
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif">Hi There,<o:p></o:p></span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif"><o:p>&nbsp;</o:p></span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif">I am using Continuous Query mechanism and most of t=
he time it works just fine. However, in some cases, it seems intermittentl=
y, CQ does not pick up the update in the cache where
 it should. <o:p></o:p></span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif"><o:p>&nbsp;</o:p></span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif">Could you please clarify the behaviour of Continuou=
s Query in the following scenario:<o:p></o:p></span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif"><o:p>&nbsp;</o:p></span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif">My business logic might create multiple identical C=
Qs in separate processing tasks. As I have no control on where the particu=
lar task gets executed within the grid it is possible
 that two identical queries gets created on the same node. Now when the ca=
che gets updated and remote filter picks up the update to pass it to the l=
ocal listener of the query, would local listeners in both queries be notif=
ied or only one? I think the same applies
 to CACHE_PUT_EVENT propagation in general: if there are two (or more) lis=
teners and only one event would all the listeners be notified regardless o=
f their location?<o:p></o:p></span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif"><o:p>&nbsp;</o:p></span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif">Many thanks,<o:p></o:p></span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif"><o:p>&nbsp;</o:p></span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif">Regards,<o:p></o:p></span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif"><o:p>&nbsp;</o:p></span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:10.0pt;font-family:&quot;A=
rial&quot;,sans-serif">Alex<o:p></o:p></span></p>
</div>
<br clear=3D"both">
This email and any attachment is confidential. If you are not the intended=
 recipient, please delete this message. Macquarie does not guarantee the i=
ntegrity of any emails or attachments. For important disclosures and infor=
mation about the incorporation and regulated status of Macquarie Group ent=
ities please see: www.macquarie.com/disclosures<BR>
</body>
</html>

--_000_ME1PR01MB04664C45E8E1420D22EE2248EB230ME1PR01MB0466ausp_--