[ https://issues.jboss.org/browse/ISPN-4973?page=com.atlassian.jira.plugin.... ] 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} -- This message was sent by Atlassian JIRA (v6.3.8#6338)