MongoDbAsCacheStoreTest.java

@Test
@SuppressWarnings("unchecked")
public void configurationTest() throws InterruptedException {
    ConfigurationBuilder builder = new ConfigurationBuilder();

    builder.loaders().addStore(MongoDBCacheStoreConfigurationBuilder.class)
            .host("localhost")
            .port(27017)
            .timeout(2000)
            .acknowledgment(0)
            .database("infinispan_cachestore")
            .collection("entries");

    final Configuration config = builder.build(true);
    MongoDBCacheStoreConfiguration store = (MongoDBCacheStoreConfiguration) config.loaders().cacheLoaders().get(0);

    DefaultCacheManager manager = new DefaultCacheManager();
    manager.defineConfiguration("entries", config);

    Cache cache = manager.getCache("entry");
    assertThat(cache).isNotNull();

    for (int i = 0; i < 5000; i++) {
        cache.put("Element-" + i, "Value-" + i);
    }
    Thread.sleep(100);
    assertThat(cache.get("Element-0")).isEqualTo("Value-0");

    manager.stop();
}