@Internal public abstract class AbstractDispatcherLeaderProcess extends Object
DispatcherLeaderProcess
.Modifier and Type | Class and Description |
---|---|
static interface |
AbstractDispatcherLeaderProcess.DispatcherGatewayService
An accessor of the
DispatcherGateway . |
static interface |
AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory
|
protected static class |
AbstractDispatcherLeaderProcess.State
The state of the
DispatcherLeaderProcess . |
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
log |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
closeAsync()
Trigger the closing of the resource and return the corresponding close future.
|
CompletableFuture<DispatcherGateway> |
getDispatcherGateway() |
protected Optional<AbstractDispatcherLeaderProcess.DispatcherGatewayService> |
getDispatcherService() |
CompletableFuture<String> |
getLeaderAddressFuture() |
UUID |
getLeaderSessionId() |
CompletableFuture<ApplicationStatus> |
getShutDownFuture() |
protected CompletableFuture<Void> |
onClose() |
protected abstract void |
onStart() |
void |
start() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public final void start()
public final UUID getLeaderSessionId()
public final CompletableFuture<DispatcherGateway> getDispatcherGateway()
public final CompletableFuture<String> getLeaderAddressFuture()
public CompletableFuture<ApplicationStatus> getShutDownFuture()
protected final Optional<AbstractDispatcherLeaderProcess.DispatcherGatewayService> getDispatcherService()
public final CompletableFuture<Void> closeAsync()
AutoCloseableAsync
protected abstract void onStart()
protected CompletableFuture<Void> onClose()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.