[infinispan-issues] [JBoss JIRA] (ISPN-4973) DataRehashed an CacheEntryInvalidated events are not fired on cache

[Vitalii Chepeliuk (JIRA)]

     [ https://issues.jboss.org/browse/ISPN-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Vitalii Chepeliuk updated ISPN-4973:
------------------------------------
    Description: 
Two async listeners created  {InvalidationListener, DistributionListener} and check if async events are fired on cache 
* InvalidationListener
{code}
/**
 * Custom listener for handling notification events.
 */
@Listener(sync=false)
public class InvalidationListener {
   public AtomicInteger keyId = new AtomicInteger();
   public String nodeName;
   public Thread threadRunningNotif;
   public boolean isInvalidated = false;

   public InvalidationListener(final String nodeName) {
      this.nodeName = nodeName;
   }

   /**
    * Handles the entry created event.
    * @param event
    */
   @CacheEntryCreated
   public void handleCreationAndModification(Event event) {
      if(event.isPre()) {
         threadRunningNotif = Thread.currentThread();
         keyId.getAndIncrement();
      }
   }

   /**
    * Handles the entry invalidated event.
    * @param event
    */
   @CacheEntryInvalidated
   public void handleInvalidation(CacheEntryInvalidatedEvent event) {
      if (event.isPre()) {
         System.out.println("Data is invalidated.");
         isInvalidated = true;
         threadRunningNotif = Thread.currentThread();
         keyId.getAndIncrement();
      }
   }
{code}
* DistributionListener
{code}
/**
 * Custom listener for verifying all notificaitions.
 */
@Listener(sync=false)
public class DistributionListener {
   public AtomicInteger keyId = new AtomicInteger();
   public String nodeName;
   public Thread topologyThreadRunningNotif = null;
   public Thread threadRunningNotif;
   public boolean isRehashed= false;
   public boolean isTopologyChanged = false;

   public DistributionListener(final String nodeName) {
      this.nodeName = nodeName;
   }

   /**
    * Handling data creation event.
    * @param event
    */
   @CacheEntryCreated
   public void handleCreationAndModification(Event event) {
      if(event.isPre()) {
         threadRunningNotif = Thread.currentThread();
         keyId.getAndIncrement();
      }
   }

   /**
    * Handles data rehashed event.
    * @param evn
    */
   @DataRehashed
   public void handleDataRehash(Event evn) {
      if(evn.isPre()) {
         System.out.println("Data Rehashed on " + nodeName);
         isRehashed = true;
         threadRunningNotif = Thread.currentThread();
      }

   }

   /**
    * Handles cluster topology changed event.
    * @param event
    */
   @TopologyChanged
   public void handleTopologyChange(TopologyChangedEvent event) {
      if(!event.isPre()) {
         System.out.println("Topology changed." + nodeName);

         isTopologyChanged = true;
         topologyThreadRunningNotif = Thread.currentThread();
      }
   }
}
{code}



  was:
Two listeners created: 
* InvalidationListener
{code}
/**
 * Custom listener for handling notification events.
 */
@Listener(sync=false)
public class InvalidationListener {
   public AtomicInteger keyId = new AtomicInteger();
   public String nodeName;
   public Thread threadRunningNotif;
   public boolean isInvalidated = false;

   public InvalidationListener(final String nodeName) {
      this.nodeName = nodeName;
   }

   /**
    * Handles the entry created event.
    * @param event
    */
   @CacheEntryCreated
   public void handleCreationAndModification(Event event) {
      if(event.isPre()) {
         threadRunningNotif = Thread.currentThread();
         keyId.getAndIncrement();
      }
   }

   /**
    * Handles the entry invalidated event.
    * @param event
    */
   @CacheEntryInvalidated
   public void handleInvalidation(CacheEntryInvalidatedEvent event) {
      if (event.isPre()) {
         System.out.println("Data is invalidated.");
         isInvalidated = true;
         threadRunningNotif = Thread.currentThread();
         keyId.getAndIncrement();
      }
   }
{code}
* DistributionListener
{code}
/**
 * Custom listener for verifying all notificaitions.
 */
@Listener(sync=false)
public class DistributionListener {
   public AtomicInteger keyId = new AtomicInteger();
   public String nodeName;
   public Thread topologyThreadRunningNotif = null;
   public Thread threadRunningNotif;
   public boolean isRehashed= false;
   public boolean isTopologyChanged = false;

   public DistributionListener(final String nodeName) {
      this.nodeName = nodeName;
   }

   /**
    * Handling data creation event.
    * @param event
    */
   @CacheEntryCreated
   public void handleCreationAndModification(Event event) {
      if(event.isPre()) {
         threadRunningNotif = Thread.currentThread();
         keyId.getAndIncrement();
      }
   }

   /**
    * Handles data rehashed event.
    * @param evn
    */
   @DataRehashed
   public void handleDataRehash(Event evn) {
      if(evn.isPre()) {
         System.out.println("Data Rehashed on " + nodeName);
         isRehashed = true;
         threadRunningNotif = Thread.currentThread();
      }

   }

   /**
    * Handles cluster topology changed event.
    * @param event
    */
   @TopologyChanged
   public void handleTopologyChange(TopologyChangedEvent event) {
      if(!event.isPre()) {
         System.out.println("Topology changed." + nodeName);

         isTopologyChanged = true;
         topologyThreadRunningNotif = Thread.currentThread();
      }
   }
}
{code}





> DataRehashed an CacheEntryInvalidated events are not fired on cache
> -------------------------------------------------------------------
>
>                 Key: ISPN-4973
>                 URL: https://issues.jboss.org/browse/ISPN-4973
>             Project: Infinispan
>          Issue Type: Bug
>          Components: Core
>    Affects Versions: 7.0.0.CR1, 7.0.0.CR2, 7.0.0.Final
>            Reporter: Vitalii Chepeliuk
>
> Two async listeners created  {InvalidationListener, DistributionListener} and check if async events are fired on cache 
> * InvalidationListener
> {code}
> /**
>  * Custom listener for handling notification events.
>  */
> @Listener(sync=false)
> public class InvalidationListener {
>    public AtomicInteger keyId = new AtomicInteger();
>    public String nodeName;
>    public Thread threadRunningNotif;
>    public boolean isInvalidated = false;
>    public InvalidationListener(final String nodeName) {
>       this.nodeName = nodeName;
>    }
>    /**
>     * Handles the entry created event.
>     * @param event
>     */
>    @CacheEntryCreated
>    public void handleCreationAndModification(Event event) {
>       if(event.isPre()) {
>          threadRunningNotif = Thread.currentThread();
>          keyId.getAndIncrement();
>       }
>    }
>    /**
>     * Handles the entry invalidated event.
>     * @param event
>     */
>    @CacheEntryInvalidated
>    public void handleInvalidation(CacheEntryInvalidatedEvent event) {
>       if (event.isPre()) {
>          System.out.println("Data is invalidated.");
>          isInvalidated = true;
>          threadRunningNotif = Thread.currentThread();
>          keyId.getAndIncrement();
>       }
>    }
> {code}
> * DistributionListener
> {code}
> /**
>  * Custom listener for verifying all notificaitions.
>  */
> @Listener(sync=false)
> public class DistributionListener {
>    public AtomicInteger keyId = new AtomicInteger();
>    public String nodeName;
>    public Thread topologyThreadRunningNotif = null;
>    public Thread threadRunningNotif;
>    public boolean isRehashed= false;
>    public boolean isTopologyChanged = false;
>    public DistributionListener(final String nodeName) {
>       this.nodeName = nodeName;
>    }
>    /**
>     * Handling data creation event.
>     * @param event
>     */
>    @CacheEntryCreated
>    public void handleCreationAndModification(Event event) {
>       if(event.isPre()) {
>          threadRunningNotif = Thread.currentThread();
>          keyId.getAndIncrement();
>       }
>    }
>    /**
>     * Handles data rehashed event.
>     * @param evn
>     */
>    @DataRehashed
>    public void handleDataRehash(Event evn) {
>       if(evn.isPre()) {
>          System.out.println("Data Rehashed on " + nodeName);
>          isRehashed = true;
>          threadRunningNotif = Thread.currentThread();
>       }
>    }
>    /**
>     * Handles cluster topology changed event.
>     * @param event
>     */
>    @TopologyChanged
>    public void handleTopologyChange(TopologyChangedEvent event) {
>       if(!event.isPre()) {
>          System.out.println("Topology changed." + nodeName);
>          isTopologyChanged = true;
>          topologyThreadRunningNotif = Thread.currentThread();
>       }
>    }
> }
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.8#6338)