Package org.apache.pekko.http.scaladsl.settings

Class ServerSettings

java.lang.Object

org.apache.pekko.http.javadsl.settings.ServerSettings

org.apache.pekko.http.scaladsl.settings.ServerSettings

Direct Known Subclasses:

ServerSettingsImpl

public abstract class ServerSettings
extends ServerSettings

Public API but not intended for subclassing

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ServerSettings.LogUnencryptedNetworkBytes$
static interface	ServerSettings.Timeouts

Constructor Summary

Constructors

Constructor	Description
ServerSettings()

Method Summary

Modifier and Type	Method	Description
static ServerSettings	apply(com.typesafe.config.Config config)
static ServerSettings	apply(String configOverrides)
abstract int	backlog()
abstract Host	defaultHostHeader()
abstract int	defaultHttpPort()
abstract int	defaultHttpsPort()
abstract boolean	enableHttp2()	Configures the Http extension to bind using HTTP/2 if given an pekko.http.scaladsl.HttpsConnectionContext.
int	getBacklog()
Host	getDefaultHostHeader()
int	getDefaultHttpPort()
int	getDefaultHttpsPort()
Optional<Object>	getLogUnencryptedNetworkBytes()
int	getMaxConnections()
ParserSettings	getParserSettings()
String	getParsingErrorHandler()
int	getPipeliningLimit()
boolean	getRawRequestUriHeader()
boolean	getRemoteAddressAttribute()
int	getResponseHeaderSizeHint()
Optional<Server>	getServerHeader()
List<org.apache.pekko.io.Inet.SocketOption>	getSocketOptions()
scala.concurrent.duration.FiniteDuration	getStreamCancellationDelay()
HttpResponse	getTerminationDeadlineExceededResponse()
ServerSettings.Timeouts	getTimeouts()
boolean	getTransparentHeadRequests()
boolean	getVerboseErrorMessages()
WebSocketSettings	getWebsocketSettings()
abstract Http2ServerSettings	http2Settings()
abstract scala.Option<Object>	logUnencryptedNetworkBytes()
ServerSettings	mapHttp2Settings(scala.Function1<Http2ServerSettings,Http2ServerSettings> f)
ServerSettings	mapParserSettings(scala.Function1<ParserSettings,ParserSettings> f)
ServerSettings	mapTimeouts(scala.Function1<ServerSettings.Timeouts,ServerSettings.Timeouts> f)
ServerSettings	mapWebsocketSettings(scala.Function1<WebSocketSettings,WebSocketSettings> f)
abstract int	maxConnections()
abstract ParserSettings	parserSettings()
abstract String	parsingErrorHandler()
abstract ParsingErrorHandler	parsingErrorHandlerInstance(org.apache.pekko.actor.ActorSystem system)	INTERNAL API
abstract int	pipeliningLimit()
abstract boolean	rawRequestUriHeader()
abstract boolean	remoteAddressAttribute()
abstract int	responseHeaderSizeHint()
abstract scala.Option<Server>	serverHeader()
abstract scala.collection.immutable.Seq<org.apache.pekko.io.Inet.SocketOption>	socketOptions()
abstract scala.concurrent.duration.FiniteDuration	streamCancellationDelay()
abstract HttpResponse	terminationDeadlineExceededResponse()
abstract ServerSettings.Timeouts	timeouts()
static ServerSettings.Timeouts	timeoutsShortcut(ServerSettings s)
abstract boolean	transparentHeadRequests()
abstract boolean	verboseErrorMessages()
abstract WebSocketSettings	websocketSettings()
ServerSettings	withBacklog(int newValue)
ServerSettings	withDefaultHostHeader(Host newValue)
ServerSettings	withDefaultHttpPort(int newValue)
ServerSettings	withDefaultHttpsPort(int newValue)
ServerSettings	withEnableHttp2(boolean newValue)
ServerSettings	withHttp2Settings(Http2ServerSettings newValue)
ServerSettings	withLogUnencryptedNetworkBytes(scala.Option<Object> newValue)
ServerSettings	withMaxConnections(int newValue)
ServerSettings	withParserSettings(ParserSettings newValue)
ServerSettings	withParsingErrorHandler(String newValue)
ServerSettings	withPipeliningLimit(int newValue)
ServerSettings	withRawRequestUriHeader(boolean newValue)
ServerSettings	withRemoteAddressAttribute(boolean newValue)
ServerSettings	withResponseHeaderSizeHint(int newValue)
ServerSettings	withServerHeader(scala.Option<Server> newValue)
ServerSettings	withSocketOptions(Iterable<org.apache.pekko.io.Inet.SocketOption> newValue)
ServerSettings	withSocketOptions(scala.collection.immutable.Seq<org.apache.pekko.io.Inet.SocketOption> newValue)
ServerSettings	withStreamCancellationDelay(scala.concurrent.duration.FiniteDuration newValue)
ServerSettings	withTerminationDeadlineExceededResponse(HttpResponse response)
ServerSettings	withTimeouts(ServerSettings.Timeouts newValue)
ServerSettings	withTransparentHeadRequests(boolean newValue)
ServerSettings	withVerboseErrorMessages(boolean newValue)
ServerSettings	withWebsocketSettings(WebSocketSettings newValue)

Methods inherited from class org.apache.pekko.http.javadsl.settings.ServerSettings

create, create, create, getHttp2Settings, withDefaultHostHeader, withHttp2Settings, withLogUnencryptedNetworkBytes, withParserSettings, withServerHeader, withTimeouts, withWebsocketSettings

Methods inherited from class java.lang.Object

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

Constructor Details

ServerSettings

public ServerSettings()

Method Details

timeoutsShortcut

public static ServerSettings.Timeouts timeoutsShortcut(ServerSettings s)

apply

public static ServerSettings apply(com.typesafe.config.Config config)

apply

public static ServerSettings apply(String configOverrides)

serverHeader

public abstract scala.Option<Server> serverHeader()

timeouts

public abstract ServerSettings.Timeouts timeouts()

maxConnections

public abstract int maxConnections()

pipeliningLimit

public abstract int pipeliningLimit()

remoteAddressAttribute

public abstract boolean remoteAddressAttribute()

rawRequestUriHeader

public abstract boolean rawRequestUriHeader()

transparentHeadRequests

public abstract boolean transparentHeadRequests()

verboseErrorMessages

public abstract boolean verboseErrorMessages()

responseHeaderSizeHint

public abstract int responseHeaderSizeHint()

backlog

public abstract int backlog()

socketOptions

public abstract scala.collection.immutable.Seq<org.apache.pekko.io.Inet.SocketOption> socketOptions()

defaultHostHeader

public abstract Host defaultHostHeader()

websocketSettings

public abstract WebSocketSettings websocketSettings()

parserSettings

public abstract ParserSettings parserSettings()

logUnencryptedNetworkBytes

public abstract scala.Option<Object> logUnencryptedNetworkBytes()

http2Settings

public abstract Http2ServerSettings http2Settings()

defaultHttpPort

public abstract int defaultHttpPort()

defaultHttpsPort

public abstract int defaultHttpsPort()

terminationDeadlineExceededResponse

public abstract HttpResponse terminationDeadlineExceededResponse()

parsingErrorHandler

public abstract String parsingErrorHandler()

streamCancellationDelay

public abstract scala.concurrent.duration.FiniteDuration streamCancellationDelay()

enableHttp2

public abstract boolean enableHttp2()

Configures the Http extension to bind using HTTP/2 if given an pekko.http.scaladsl.HttpsConnectionContext. Otherwise binds as plain HTTP.

Specified by:

enableHttp2 in class ServerSettings

Returns:

(undocumented)

Since:

1.3.0

getBacklog

public int getBacklog()

Specified by:

getBacklog in class ServerSettings

getDefaultHostHeader

public Host getDefaultHostHeader()

Specified by:

getDefaultHostHeader in class ServerSettings

getPipeliningLimit

public int getPipeliningLimit()

Specified by:

getPipeliningLimit in class ServerSettings

getParserSettings

public ParserSettings getParserSettings()

Specified by:

getParserSettings in class ServerSettings

getMaxConnections

public int getMaxConnections()

Specified by:

getMaxConnections in class ServerSettings

getTransparentHeadRequests

public boolean getTransparentHeadRequests()

Specified by:

getTransparentHeadRequests in class ServerSettings

getResponseHeaderSizeHint

public int getResponseHeaderSizeHint()

Specified by:

getResponseHeaderSizeHint in class ServerSettings

getVerboseErrorMessages

public boolean getVerboseErrorMessages()

Specified by:

getVerboseErrorMessages in class ServerSettings

getSocketOptions

public List<org.apache.pekko.io.Inet.SocketOption> getSocketOptions()

Specified by:

getSocketOptions in class ServerSettings

getServerHeader

public Optional<Server> getServerHeader()

Specified by:

getServerHeader in class ServerSettings

getTimeouts

public ServerSettings.Timeouts getTimeouts()

Specified by:

getTimeouts in class ServerSettings

getRawRequestUriHeader

public boolean getRawRequestUriHeader()

Specified by:

getRawRequestUriHeader in class ServerSettings

getRemoteAddressAttribute

public boolean getRemoteAddressAttribute()

Specified by:

getRemoteAddressAttribute in class ServerSettings

getLogUnencryptedNetworkBytes

public Optional<Object> getLogUnencryptedNetworkBytes()

Specified by:

getLogUnencryptedNetworkBytes in class ServerSettings

getDefaultHttpPort

public int getDefaultHttpPort()

Specified by:

getDefaultHttpPort in class ServerSettings

getDefaultHttpsPort

public int getDefaultHttpsPort()

Specified by:

getDefaultHttpsPort in class ServerSettings

getTerminationDeadlineExceededResponse

public HttpResponse getTerminationDeadlineExceededResponse()

Specified by:

getTerminationDeadlineExceededResponse in class ServerSettings

getParsingErrorHandler

public String getParsingErrorHandler()

Specified by:

getParsingErrorHandler in class ServerSettings

getStreamCancellationDelay

public scala.concurrent.duration.FiniteDuration getStreamCancellationDelay()

Specified by:

getStreamCancellationDelay in class ServerSettings

withMaxConnections

public ServerSettings withMaxConnections(int newValue)

Overrides:

withMaxConnections in class ServerSettings

withPipeliningLimit

public ServerSettings withPipeliningLimit(int newValue)

Overrides:

withPipeliningLimit in class ServerSettings

withRemoteAddressAttribute

public ServerSettings withRemoteAddressAttribute(boolean newValue)

Overrides:

withRemoteAddressAttribute in class ServerSettings

withRawRequestUriHeader

public ServerSettings withRawRequestUriHeader(boolean newValue)

Overrides:

withRawRequestUriHeader in class ServerSettings

withTransparentHeadRequests

public ServerSettings withTransparentHeadRequests(boolean newValue)

Overrides:

withTransparentHeadRequests in class ServerSettings

withVerboseErrorMessages

public ServerSettings withVerboseErrorMessages(boolean newValue)

Overrides:

withVerboseErrorMessages in class ServerSettings

withResponseHeaderSizeHint

public ServerSettings withResponseHeaderSizeHint(int newValue)

Overrides:

withResponseHeaderSizeHint in class ServerSettings

withBacklog

public ServerSettings withBacklog(int newValue)

Overrides:

withBacklog in class ServerSettings

withSocketOptions

public ServerSettings withSocketOptions(Iterable<org.apache.pekko.io.Inet.SocketOption> newValue)

Overrides:

withSocketOptions in class ServerSettings

getWebsocketSettings

public WebSocketSettings getWebsocketSettings()

Specified by:

getWebsocketSettings in class ServerSettings

withDefaultHttpPort

public ServerSettings withDefaultHttpPort(int newValue)

Overrides:

withDefaultHttpPort in class ServerSettings

withDefaultHttpsPort

public ServerSettings withDefaultHttpsPort(int newValue)

Overrides:

withDefaultHttpsPort in class ServerSettings

withTerminationDeadlineExceededResponse

public ServerSettings withTerminationDeadlineExceededResponse(HttpResponse response)

Overrides:

withTerminationDeadlineExceededResponse in class ServerSettings

withParsingErrorHandler

public ServerSettings withParsingErrorHandler(String newValue)

Overrides:

withParsingErrorHandler in class ServerSettings

withStreamCancellationDelay

public ServerSettings withStreamCancellationDelay(scala.concurrent.duration.FiniteDuration newValue)

Overrides:

withStreamCancellationDelay in class ServerSettings

withEnableHttp2

public ServerSettings withEnableHttp2(boolean newValue)

Overrides:

withEnableHttp2 in class ServerSettings

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

withTimeouts

public ServerSettings withTimeouts(ServerSettings.Timeouts newValue)

withServerHeader

public ServerSettings withServerHeader(scala.Option<Server> newValue)

withLogUnencryptedNetworkBytes

public ServerSettings withLogUnencryptedNetworkBytes(scala.Option<Object> newValue)

withDefaultHostHeader

public ServerSettings withDefaultHostHeader(Host newValue)

withParserSettings

public ServerSettings withParserSettings(ParserSettings newValue)

withWebsocketSettings

public ServerSettings withWebsocketSettings(WebSocketSettings newValue)

withSocketOptions

public ServerSettings withSocketOptions(scala.collection.immutable.Seq<org.apache.pekko.io.Inet.SocketOption> newValue)

withHttp2Settings

public ServerSettings withHttp2Settings(Http2ServerSettings newValue)

mapHttp2Settings

public ServerSettings mapHttp2Settings(scala.Function1<Http2ServerSettings,Http2ServerSettings> f)

mapParserSettings

public ServerSettings mapParserSettings(scala.Function1<ParserSettings,ParserSettings> f)

mapWebsocketSettings

public ServerSettings mapWebsocketSettings(scala.Function1<WebSocketSettings,WebSocketSettings> f)

mapTimeouts

public ServerSettings mapTimeouts(scala.Function1<ServerSettings.Timeouts,ServerSettings.Timeouts> f)

parsingErrorHandlerInstance

public abstract ParsingErrorHandler parsingErrorHandlerInstance(org.apache.pekko.actor.ActorSystem system)

INTERNAL API

Returns an instance of the ParsingErrorHandler as specified by parsingErrorHandler

Parameters:

system - (undocumented)

Returns:

(undocumented)