public final class MasterServerTerminator extends java.lang.Object implements ServerTerminator
Modifier and Type | Class and Description |
---|---|
static class |
MasterServerTerminator.AliveConnectionTerminators |
static class |
MasterServerTerminator.AliveConnectionTerminators$ |
static interface |
MasterServerTerminator.State |
static class |
MasterServerTerminator.Terminating |
static class |
MasterServerTerminator.Terminating$ |
Constructor and Description |
---|
MasterServerTerminator(org.apache.pekko.event.LoggingAdapter log) |
Modifier and Type | Method and Description |
---|---|
boolean |
registerConnection(ServerTerminator terminator,
scala.concurrent.ExecutionContext ec)
Registers an per-connection terminator.
|
void |
removeConnection(ServerTerminator terminator)
Removes a previously registered per-connection terminator.
|
scala.concurrent.Future<Http.HttpTerminated> |
terminate(scala.concurrent.duration.FiniteDuration timeout,
scala.concurrent.ExecutionContext ex)
Initiate the termination sequence of this server.
|
public MasterServerTerminator(org.apache.pekko.event.LoggingAdapter log)
public boolean registerConnection(ServerTerminator terminator, scala.concurrent.ExecutionContext ec)
terminator
- (undocumented)ec
- (undocumented)terminate()
will be invoked in that case automatically)public void removeConnection(ServerTerminator terminator)
terminator
- (undocumented)public scala.concurrent.Future<Http.HttpTerminated> terminate(scala.concurrent.duration.FiniteDuration timeout, scala.concurrent.ExecutionContext ex)
ServerTerminator
terminate
in interface ServerTerminator
timeout
- (undocumented)ex
- (undocumented)