Cache Listeners post event call returning old values(for 100 milliseconds) instead of updated values

[sudheerk84]

Hi,

I am using Infinispan 5.0.0.FINAL version.

i am using cache listeners to get event notifications which are happening in a transaction. I use teh following code

    @CacheEntryCreated

    @CacheEntryModified

    @CacheEntryRemoved

    public void cacheChangeEvent(CacheEntryEvent<Long, MyPojo> event) {

        logger.debug("Cache change event called : {}", event.getType().toString());

        try {

            if (!event.isPre()) {

                MyPojo pojo = event.getCache().get(event.getKey());

                logger.debug("value", pojo);

            }

        } catch (Exception e) {

        }

    }

BUt teh issue issue i see is i  get old value even though i check its a post event call.

When i put a sleep of 100 milliseconds everything seems to work fine. IS it a know issue/bug ? OR Am i doing anything wrong ?

working code

    @CacheEntryCreated

    @CacheEntryModified

    @CacheEntryRemoved

    public void cacheChangeEvent(CacheEntryEvent<Long, MyPojo> event) {

        logger.debug("Cache change event called : {}", event.getType().toString());

        try {

            if (!event.isPre()) {

                Thread.sleep(100);   -> this ensures that updated valued is obtained .

                MyPojo pojo = event.getCache().get(event.getKey());

                logger.debug("value", pojo);

            }

        } catch (Exception e) {

        }

    }

[sudheerk84]

One more point to add is teh listener is asynch @Listener(sync = false).

Also in the cacheModified event , the updated valued is not directly accesible through apis , hence i use event.getCache().get(event.getKey()) to get the value.

[sudheerk84]

I figured out why this was happening.

Since the listener was asynchronous and isolation mode was repetable reads, before teh transaction committed it was always retruning old value. When i put a delay of 100 milliseconds , teh commit woudl go ahead and i woudl get new values.

So i figured out the that i shoudl not be accessing values from teh cache , instead i shoudl be using the Cache Modified event or Cacheremoved event, which will give teh new value. But i have issue with teh getting the value for cache created event (which i will post as seperate thread).

[galder.zamarreno]

Indeed. This is already noted in our FAQs: https://docs.jboss.org/author/pages/viewpage.action?pageId=5832860

[sudheerk84]

Thanks you for the confirmation for cache modified entries.

How exactly do i access teh cache entry for cache created event ? (i have posted this as a seperate thread https://community.jboss.org/thread/177541?tstart=0 )

Sicne i am using tansactions , i need to get teh element and use this on successful transaction commit.