Mailing-List: contact user-help@ignite.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@ignite.apache.org
MIME-Version: 1.0
In-Reply-To: <5E6758C3-0CD0-4706-8768-CD85955C70E5@gridgain.com>
References: <tencent_0C249E9122A26E99303B5E7D@qq.com> <5E6758C3-0CD0-4706-8768-CD85955C70E5@gridgain.com>
From: Nikolay Tikhonov <ntikhonov@gridgain.com>
Date: Thu, 7 Jul 2016 08:21:19 +0300
Message-ID: <CAP3QaUE46zkg12z76=bHp1_8U8DLVQjXqOgAEcD8RKo5BVEt_w@mail.gmail.com>
Subject: Re: Why the Continuous Queries ignore expired event permanently?
To: Denis Magda <dmagda@gridgain.com>
Cc: user@ignite.apache.org
Content-Type: multipart/alternative; boundary=001a1149b5c42c58cf053704db39
archived-at: Thu, 07 Jul 2016 05:21:27 -0000

--001a1149b5c42c58cf053704db39
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

Hi Lin,

CQ doesn't support expired events by historical reason. But you can use
CacheEntryListener [1] which support the same functionality that CQ and
allow to get expired events [2].

[1] IgniteCache#registerCacheEntryListener
[2] javax.cache.event.CacheEntryExpiredListener

On Wed, Jul 6, 2016 at 7:14 PM, Denis Magda <dmagda@gridgain.com> wrote:

> Hi Lin,
>
> As far as I recall this kind of events are not supported by CQ (continuou=
s
> queries) right know. However I=E2=80=99m not sure about the reason.
>
> *Nick*, can you comment this?
>
> =E2=80=94
> Denis
>
> On Jul 6, 2016, at 10:17 AM, Lin <me@linlyu.com> wrote:
>
> Hi all,
>
> I am trying to switch my event listener application from event subsystem
> with CacheEvent to the Continuous Queries with CacheEntryEvent, and I fou=
nd
> that the system will ignore all the expired events.
>
> Please see the code
> in org.apache.ignite.internal.processors.cache.query.continuous.CacheCont=
inuousQueryManager#executeQuery
> and
>
> org.apache.ignite.internal.processors.cache.query.continuous.CacheContinu=
ousQueryListener#onEntryUpdated.
>
> No matter CacheContinuousQueryHandlerV2 or CacheContinuousQueryHandler,
> the parameter of ignoreExpired is always true.
>
> 1. What do you consider to ignore expired events?
> 2. What if I set the parameter ignoreExpired to false?
>
>
> Regards,
>
> Lin.
>
>
>

--001a1149b5c42c58cf053704db39
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr">Hi Lin,<div><br></div><div>CQ doesn&#39;t support expired =
events by historical=C2=A0reason. But you can use CacheEntryListener [1] wh=
ich support the same functionality that CQ and allow to get expired events =
[2].</div><div><br></div><div>[1] IgniteCache#registerCacheEntryListener<br=
></div><div>[2]=C2=A0javax.cache.event.CacheEntryExpiredListener</div></div=
><div class=3D"gmail_extra"><br><div class=3D"gmail_quote">On Wed, Jul 6, 2=
016 at 7:14 PM, Denis Magda <span dir=3D"ltr">&lt;<a href=3D"mailto:dmagda@=
gridgain.com" target=3D"_blank">dmagda@gridgain.com</a>&gt;</span> wrote:<b=
r><blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:=
1px #ccc solid;padding-left:1ex"><div style=3D"word-wrap:break-word">Hi Lin=
,<div><br></div><div>As far as I recall this kind of events are not support=
ed by CQ (continuous queries) right know. However I=E2=80=99m not sure abou=
t the reason.</div><div><br></div><div><b>Nick</b>, can you comment this?</=
div><div><br></div><div>=E2=80=94</div><span class=3D"HOEnZb"><font color=
=3D"#888888"><div>Denis</div></font></span><div><div class=3D"h5"><div><br>=
<div><blockquote type=3D"cite"><div>On Jul 6, 2016, at 10:17 AM, Lin &lt;<a=
 href=3D"mailto:me@linlyu.com" target=3D"_blank">me@linlyu.com</a>&gt; wrot=
e:</div><br><div><div>Hi all,</div><div><br></div><div>I am trying to switc=
h my event listener application from event subsystem with CacheEvent to the=
 Continuous Queries with CacheEntryEvent, and I found that the system will =
ignore all the expired events.</div><div><br></div><div>Please see the code=
 in=C2=A0org.apache.ignite.internal.processors.cache.query.continuous.Cache=
ContinuousQueryManager#executeQuery and=C2=A0</div><div>org.apache.ignite.i=
nternal.processors.cache.query.continuous.CacheContinuousQueryListener#onEn=
tryUpdated.=C2=A0</div><div><br></div><div>No matter=C2=A0CacheContinuousQu=
eryHandlerV2 or=C2=A0CacheContinuousQueryHandler, the parameter of=C2=A0ign=
oreExpired is always true.</div><div><br></div><div>1. What do you consider=
 to ignore expired events?</div><div>2. What if I set the parameter ignoreE=
xpired to false?</div><div><br></div><div><br></div><div>Regards,</div><div=
><br></div><div>Lin.</div></div></blockquote></div><br></div></div></div></=
div></blockquote></div><br></div>

--001a1149b5c42c58cf053704db39--