I have a n implementation of CacheEntryExpired listener added via infinispan cache .addListener() method.
The listener event is fired on entry expiration. The problem is, that every time the event is fired twice.
I verified (using debugger and cache.getListeners()) that the cache does not contain two instances of the same Listener of mine. The result of getListeners is:
(java.util.Collections$UnmodifiableSet<E>) [org.infinispan.iteration.impl.LocalEntryRetriever$PartitionListener@666SAT, my.supercool.package.MyExpirationEventListenerImpl@666TAN]
So there is only one listener. The listener implements the interface:
@Listener
public interface TokenExpirationEventListener<T> {
@CacheEntryExpired
public void entryExpired(CacheEntryExpiredEvent<String, T> event);
}
And an implementation looks like:
@Override
@CacheEntryExpired
public void entryExpired(CacheEntryExpiredEvent<String, T> event) {
CODE
}
But removing @CacheEntryExpired and @Listener annotations from the interface (just trying) did not cause the event to occur only once.
Is there anything I am doing wrong, that I get TWO events on each entry expiration event?
The infinispan version is 8.2.0.final.
EDIT2: I was able to track down all the configuration that is causing trouble. The code that will allow to reproduce the error is:
import java.util.concurrent.TimeUnit;
import org.infinispan.Cache;
import org.infinispan.configuration.cache.CacheMode;
import org.infinispan.configuration.cache.ClusteringConfigurationBuilder;
import org.infinispan.configuration.cache.Configuration;
import org.infinispan.configuration.cache.ConfigurationBuilder;
import org.infinispan.configuration.global.GlobalConfigurationBuilder;
import org.infinispan.configuration.global.TransportConfigurationBuilder;
import org.infinispan.manager.DefaultCacheManager;
import org.infinispan.notifications.Listener;
import org.infinispan.notifications.cachelistener.annotation.CacheEntryExpired;
import org.infinispan.notifications.cachelistener.event.CacheEntryExpiredEvent;
@Listener
public class TestMain {
private Cache<String, String> cache;
public static void main(String[] args) throws Exception {
new TestMain().test();
}
private void test() throws Exception{
configureInfinispan();
cache.put("test", "test", 10, TimeUnit.SECONDS);
cache.put("test2", "test", 10, TimeUnit.SECONDS);
while(true){
Thread.sleep(100);
}
}
public void configureInfinispan(){
DefaultCacheManager defaultCacheManager = configureCachaManager();//globalConfigurationBuilder.build(), defaultConfigurationBuilder.build(), /*startNow*/ true)
Configuration conf = defaultCacheManager.getDefaultCacheConfiguration();
ConfigurationBuilder cacheConfigBuilder = new ConfigurationBuilder().read(conf);
cacheConfigBuilder.expiration().enableReaper().wakeUpInterval(5, TimeUnit.SECONDS); //to speed test results
duplicationReason2(cacheConfigBuilder);
defaultCacheManager.defineConfiguration("testCache", cacheConfigBuilder.build());
cache = defaultCacheManager.getCache("testCache");
cache.addListener(new TestMain());
System.out.println("conf");
}
public DefaultCacheManager configureCachaManager(){
GlobalConfigurationBuilder globalConfigurationBuilder = new GlobalConfigurationBuilder();
ConfigurationBuilder defaultConfigurationBuilder = new ConfigurationBuilder();
duplicationReason1(defaultConfigurationBuilder, globalConfigurationBuilder);
return new DefaultCacheManager(globalConfigurationBuilder.build(), defaultConfigurationBuilder.build(), true);
}
@CacheEntryExpired
public void entryExpired(CacheEntryExpiredEvent<String, String> event) {
System.out.println("Expired:" + event.getKey());
}
private void duplicationReason2(ConfigurationBuilder configurationBuilder) {
configurationBuilder.persistence() //enable persistence
.passivation(false)
.addSingleFileStore()
.location("C:/test/infinispan")
// Disable writing anything to the file except when we do shutdown
.maxEntries(0)
.shared(false)
.fetchPersistentState(true)
.async() //write-behind
.enable() //write-behind
.threadPoolSize(Runtime.getRuntime().availableProcessors()) //writing threads
.preload(true); //load data from file on startup
}
private void duplicationReason1(ConfigurationBuilder configurationBuilder, GlobalConfigurationBuilder globalConfigurationBuilder){
configureCacheOperationalMode(configurationBuilder);
configureTransport(globalConfigurationBuilder);
}
private void configureCacheOperationalMode(ConfigurationBuilder configurationBuilder) {
ClusteringConfigurationBuilder clusteringConfigurationBuilder = configurationBuilder.clustering();
clusteringConfigurationBuilder.cacheMode(CacheMode.REPL_ASYNC);
}
private void configureTransport(GlobalConfigurationBuilder globalConfigurationBuilder) {
TransportConfigurationBuilder transportConfigurationBuilder = globalConfigurationBuilder.transport().defaultTransport();
transportConfigurationBuilder.addProperty("configurationFile", "default-configs/default-jgroups-udp.xml");
}
}
Running this will (unfortunatelly you need to kill the main thread youself afterwards) cause the event to be printed twice.
There are two methods that together cause this. commenting one of them and leaving the second causes the event to fire once.
The methods are named duplicationReason1 and duplicationReason2.
Maybe there is something I do not understand in the configuration?