org.apache.pekko.http.javadsl.settings

Class ClientConnectionSettings

java.lang.Object

org.apache.pekko.http.javadsl.settings.ClientConnectionSettings

Direct Known Subclasses:

ClientConnectionSettings

public abstract class ClientConnectionSettings
extends java.lang.Object

Public API but not intended for subclassing

Constructor Summary

Constructors

Constructor and Description
ClientConnectionSettings()

Method Summary

Modifier and Type	Method and Description
static ClientConnectionSettings	create(org.apache.pekko.actor.ActorSystem system)
static ClientConnectionSettings	create(com.typesafe.config.Config config)
static ClientConnectionSettings	create(java.lang.String configOverrides)
scala.concurrent.duration.FiniteDuration	getConnectingTimeout()
scala.concurrent.duration.Duration	getIdleTimeout()
java.util.Optional<java.net.InetSocketAddress>	getLocalAddress()
java.util.Optional<java.lang.Object>	getLogUnencryptedNetworkBytes()
ParserSettings	getParserSettings()
int	getRequestHeaderSizeHint()
java.lang.Iterable<org.apache.pekko.io.Inet.SocketOption>	getSocketOptions()
scala.concurrent.duration.FiniteDuration	getStreamCancellationDelay()
ClientTransport	getTransport() The underlying transport used to connect to hosts.
java.util.Optional<UserAgent>	getUserAgentHeader()
java.util.function.Supplier<java.util.Random>	getWebsocketRandomFactory()
WebSocketSettings	getWebsocketSettings()
abstract ClientConnectionSettings	withConnectingTimeout(scala.concurrent.duration.FiniteDuration newValue)
abstract ClientConnectionSettings	withIdleTimeout(scala.concurrent.duration.Duration newValue)
ClientConnectionSettings	withLocalAddress(java.util.Optional<java.net.InetSocketAddress> newValue)
ClientConnectionSettings	withLogUnencryptedNetworkBytes(java.util.Optional<java.lang.Object> newValue)
ClientConnectionSettings	withParserSettings(ParserSettings newValue)
abstract ClientConnectionSettings	withRequestHeaderSizeHint(int newValue)
ClientConnectionSettings	withSocketOptions(java.lang.Iterable<org.apache.pekko.io.Inet.SocketOption> newValue)
abstract ClientConnectionSettings	withStreamCancellationDelay(scala.concurrent.duration.FiniteDuration newValue)
ClientConnectionSettings	withTransport(ClientTransport newValue)
ClientConnectionSettings	withUserAgentHeader(java.util.Optional<UserAgent> newValue)
ClientConnectionSettings	withWebsocketRandomFactory(java.util.function.Supplier<java.util.Random> newValue)
ClientConnectionSettings	withWebsocketSettings(WebSocketSettings newValue)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientConnectionSettings

public ClientConnectionSettings()

Method Detail

create

public static ClientConnectionSettings create(com.typesafe.config.Config config)

create

public static ClientConnectionSettings create(java.lang.String configOverrides)

create

public static ClientConnectionSettings create(org.apache.pekko.actor.ActorSystem system)

getConnectingTimeout

public final scala.concurrent.duration.FiniteDuration getConnectingTimeout()

getParserSettings

public final ParserSettings getParserSettings()

getIdleTimeout

public final scala.concurrent.duration.Duration getIdleTimeout()

getSocketOptions

public final java.lang.Iterable<org.apache.pekko.io.Inet.SocketOption> getSocketOptions()

getUserAgentHeader

public final java.util.Optional<UserAgent> getUserAgentHeader()

getLogUnencryptedNetworkBytes

public final java.util.Optional<java.lang.Object> getLogUnencryptedNetworkBytes()

getStreamCancellationDelay

public final scala.concurrent.duration.FiniteDuration getStreamCancellationDelay()

getRequestHeaderSizeHint

public final int getRequestHeaderSizeHint()

getWebsocketSettings

public final WebSocketSettings getWebsocketSettings()

getWebsocketRandomFactory

public final java.util.function.Supplier<java.util.Random> getWebsocketRandomFactory()

getLocalAddress

public final java.util.Optional<java.net.InetSocketAddress> getLocalAddress()

getTransport

public ClientTransport getTransport()

The underlying transport used to connect to hosts. By default ClientTransport.TCP is used.

withConnectingTimeout

public abstract ClientConnectionSettings withConnectingTimeout(scala.concurrent.duration.FiniteDuration newValue)

withIdleTimeout

public abstract ClientConnectionSettings withIdleTimeout(scala.concurrent.duration.Duration newValue)

withRequestHeaderSizeHint

public abstract ClientConnectionSettings withRequestHeaderSizeHint(int newValue)

withStreamCancellationDelay

public abstract ClientConnectionSettings withStreamCancellationDelay(scala.concurrent.duration.FiniteDuration newValue)

withUserAgentHeader

public ClientConnectionSettings withUserAgentHeader(java.util.Optional<UserAgent> newValue)

withLogUnencryptedNetworkBytes

public ClientConnectionSettings withLogUnencryptedNetworkBytes(java.util.Optional<java.lang.Object> newValue)

withWebsocketRandomFactory

public ClientConnectionSettings withWebsocketRandomFactory(java.util.function.Supplier<java.util.Random> newValue)

withWebsocketSettings

public ClientConnectionSettings withWebsocketSettings(WebSocketSettings newValue)

withSocketOptions

public ClientConnectionSettings withSocketOptions(java.lang.Iterable<org.apache.pekko.io.Inet.SocketOption> newValue)

withParserSettings

public ClientConnectionSettings withParserSettings(ParserSettings newValue)

withLocalAddress

public ClientConnectionSettings withLocalAddress(java.util.Optional<java.net.InetSocketAddress> newValue)

withTransport

public ClientConnectionSettings withTransport(ClientTransport newValue)