Class Lease
- java.lang.Object
-
- akka.coordination.lease.javadsl.Lease
-
- Direct Known Subclasses:
LeaseAdapter
public abstract class Lease extends java.lang.Object
Try to acquire the lease. The returnedCompletionStage
will be completed withtrue
if the lease could be acquired, i.e. no other owner is holding the lease.The returned
Future
will be completed withfalse
if the lease for certain couldn't be acquired, e.g. because some other owner is holding it. It's completed withLeaseException
failure if it might not have been able to acquire the lease, e.g. communication timeout with the lease resource.The lease will be held by the
LeaseSettings.ownerName
until it is released withLease.release
. A Lease implementation will typically also loose the ownership if it can't maintain its authority, e.g. if it crashes or is partitioned from the lease resource for too long.Lease.checkLease
can be used to verify that the owner still has the lease.
-
-
Constructor Summary
Constructors Constructor Description Lease()
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description abstract java.util.concurrent.CompletionStage<java.lang.Boolean>
acquire()
Try to acquire the lease.abstract java.util.concurrent.CompletionStage<java.lang.Boolean>
acquire(java.util.function.Consumer<java.util.Optional<java.lang.Throwable>> leaseLostCallback)
Same as acquire with an additional callback that is called if the lease is lost.abstract boolean
checkLease()
Check if the owner still holds the lease.abstract LeaseSettings
getSettings()
abstract java.util.concurrent.CompletionStage<java.lang.Boolean>
release()
Release the lease so some other owner can acquire it.
-
-
-
Method Detail
-
acquire
public abstract java.util.concurrent.CompletionStage<java.lang.Boolean> acquire()
Try to acquire the lease. The returnedCompletionStage
will be completed withtrue
if the lease could be acquired, i.e. no other owner is holding the lease.The returned
Future
will be completed withfalse
if the lease for certain couldn't be acquired, e.g. because some other owner is holding it. It's completed withLeaseException
failure if it might not have been able to acquire the lease, e.g. communication timeout with the lease resource.The lease will be held by the
LeaseSettings.ownerName
until it is released withLease.release
. A Lease implementation will typically also loose the ownership if it can't maintain its authority, e.g. if it crashes or is partitioned from the lease resource for too long.Lease.checkLease
can be used to verify that the owner still has the lease.- Returns:
- (undocumented)
-
acquire
public abstract java.util.concurrent.CompletionStage<java.lang.Boolean> acquire(java.util.function.Consumer<java.util.Optional<java.lang.Throwable>> leaseLostCallback)
Same as acquire with an additional callback that is called if the lease is lost. The lease can be lose due to being unable to communicate with the lease provider. Implementations should not call leaseLostCallback until after the returned future has been completed- Parameters:
leaseLostCallback
- (undocumented)- Returns:
- (undocumented)
-
checkLease
public abstract boolean checkLease()
Check if the owner still holds the lease.true
means that it certainly holds the lease.false
means that it might not hold the lease, but it could, and for more certain response you would have to use {@link Lease#acquire()*} orrelease()
.- Returns:
- (undocumented)
-
getSettings
public abstract LeaseSettings getSettings()
-
release
public abstract java.util.concurrent.CompletionStage<java.lang.Boolean> release()
Release the lease so some other owner can acquire it.- Returns:
- (undocumented)
-
-