Package org.infinispan.persistence.manager

Class OrderedUpdatesManagerImpl

java.lang.Object

org.infinispan.persistence.manager.OrderedUpdatesManagerImpl

All Implemented Interfaces:

OrderedUpdatesManager

public class OrderedUpdatesManagerImpl
extends java.lang.Object
implements OrderedUpdatesManager

Constructor Summary

Constructors

Constructor	Description
OrderedUpdatesManagerImpl()

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletionStage<java.lang.Void>	checkLockAndStore(java.lang.Object key, EntryVersion version, java.util.function.Function<java.util.concurrent.CompletableFuture<?>,java.util.concurrent.CompletableFuture<?>> enableTimeout, java.util.function.Function<java.lang.Object,java.util.concurrent.CompletionStage<java.lang.Void>> store)
java.util.concurrent.CompletableFuture<?>	invalidate(java.lang.Object[] keys)
java.util.concurrent.CompletableFuture<?>	waitFuture(java.lang.Object key)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OrderedUpdatesManagerImpl

public OrderedUpdatesManagerImpl()

Method Detail

waitFuture

public java.util.concurrent.CompletableFuture<?> waitFuture(java.lang.Object key)

Specified by:

waitFuture in interface OrderedUpdatesManager

checkLockAndStore

public java.util.concurrent.CompletionStage<java.lang.Void> checkLockAndStore(java.lang.Object key,
                                                                              EntryVersion version,
                                                                              java.util.function.Function<java.util.concurrent.CompletableFuture<?>,java.util.concurrent.CompletableFuture<?>> enableTimeout,
                                                                              java.util.function.Function<java.lang.Object,java.util.concurrent.CompletionStage<java.lang.Void>> store)

Specified by:

checkLockAndStore in interface OrderedUpdatesManager

invalidate

public java.util.concurrent.CompletableFuture<?> invalidate(java.lang.Object[] keys)

Specified by:

invalidate in interface OrderedUpdatesManager