Package 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 Object

Public API but not intended for subclassing

Constructor Summary

Constructors

Constructor	Description
ClientConnectionSettings()

Method Summary

Modifier and Type	Method	Description
static ClientConnectionSettings	create(com.typesafe.config.Config config)
static ClientConnectionSettings	create(String configOverrides)
static ClientConnectionSettings	create(org.apache.pekko.actor.ActorSystem system)
final Duration	getConnectingTimeout()	In 2.0.0, the return type of this method changed from scala.concurrent.duration.Duration to java.time.Duration.
final Duration	getIdleTimeout()	In 2.0.0, the return type of this method changed from scala.concurrent.duration.Duration to java.time.Duration.
final Optional<InetSocketAddress>	getLocalAddress()
final Optional<Object>	getLogUnencryptedNetworkBytes()
final ParserSettings	getParserSettings()
final int	getRequestHeaderSizeHint()
final Iterable<org.apache.pekko.io.Inet.SocketOption>	getSocketOptions()
final Duration	getStreamCancellationDelay()	In 2.0.0, the return type of this method changed from scala.concurrent.duration.Duration to java.time.Duration.
ClientTransport	getTransport()	The underlying transport used to connect to hosts.
final Optional<UserAgent>	getUserAgentHeader()
final Supplier<Random>	getWebsocketRandomFactory()
final WebSocketSettings	getWebsocketSettings()
abstract ClientConnectionSettings	withConnectingTimeout(Duration newValue)	Java API
abstract ClientConnectionSettings	withConnectingTimeout(scala.concurrent.duration.FiniteDuration newValue)
abstract ClientConnectionSettings	withIdleTimeout(Duration newValue)	Java API
abstract ClientConnectionSettings	withIdleTimeout(scala.concurrent.duration.Duration newValue)
ClientConnectionSettings	withLocalAddress(Optional<InetSocketAddress> newValue)
ClientConnectionSettings	withLogUnencryptedNetworkBytes(Optional<Object> newValue)
ClientConnectionSettings	withParserSettings(ParserSettings newValue)
abstract ClientConnectionSettings	withRequestHeaderSizeHint(int newValue)
ClientConnectionSettings	withSocketOptions(Iterable<org.apache.pekko.io.Inet.SocketOption> newValue)
abstract ClientConnectionSettings	withStreamCancellationDelay(Duration newValue)	Java API
abstract ClientConnectionSettings	withStreamCancellationDelay(scala.concurrent.duration.FiniteDuration newValue)
ClientConnectionSettings	withTransport(ClientTransport newValue)
ClientConnectionSettings	withUserAgentHeader(Optional<UserAgent> newValue)
ClientConnectionSettings	withWebsocketRandomFactory(Supplier<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 Details

ClientConnectionSettings

public ClientConnectionSettings()

Method Details

create

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

create

public static ClientConnectionSettings create(String configOverrides)

create

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

getConnectingTimeout

public final Duration getConnectingTimeout()

In 2.0.0, the return type of this method changed from scala.concurrent.duration.Duration to java.time.Duration.

Returns:

(undocumented)

getParserSettings

public final ParserSettings getParserSettings()

getIdleTimeout

public final Duration getIdleTimeout()

In 2.0.0, the return type of this method changed from scala.concurrent.duration.Duration to java.time.Duration.

Returns:

(undocumented)

getSocketOptions

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

getUserAgentHeader

public final Optional<UserAgent> getUserAgentHeader()

getLogUnencryptedNetworkBytes

public final Optional<Object> getLogUnencryptedNetworkBytes()

getStreamCancellationDelay

public final Duration getStreamCancellationDelay()

In 2.0.0, the return type of this method changed from scala.concurrent.duration.Duration to java.time.Duration.

Returns:

(undocumented)

getRequestHeaderSizeHint

public final int getRequestHeaderSizeHint()

getWebsocketSettings

public final WebSocketSettings getWebsocketSettings()

getWebsocketRandomFactory

public final Supplier<Random> getWebsocketRandomFactory()

getLocalAddress

public final Optional<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)

withConnectingTimeout

public abstract ClientConnectionSettings withConnectingTimeout(Duration newValue)

Java API

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

withIdleTimeout

public abstract ClientConnectionSettings withIdleTimeout(Duration newValue)

Java API

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

withStreamCancellationDelay

public abstract ClientConnectionSettings withStreamCancellationDelay(Duration newValue)

Java API

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

withUserAgentHeader

public ClientConnectionSettings withUserAgentHeader(Optional<UserAgent> newValue)

withLogUnencryptedNetworkBytes

public ClientConnectionSettings withLogUnencryptedNetworkBytes(Optional<Object> newValue)

withWebsocketRandomFactory

public ClientConnectionSettings withWebsocketRandomFactory(Supplier<Random> newValue)

withWebsocketSettings

public ClientConnectionSettings withWebsocketSettings(WebSocketSettings newValue)

withSocketOptions

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

withParserSettings

public ClientConnectionSettings withParserSettings(ParserSettings newValue)

withLocalAddress

public ClientConnectionSettings withLocalAddress(Optional<InetSocketAddress> newValue)

withTransport

public ClientConnectionSettings withTransport(ClientTransport newValue)