public class Http
extends java.lang.Object
implements akka.actor.Extension
Constructor and Description |
---|
Http(akka.actor.ExtendedActorSystem system) |
Modifier and Type | Method and Description |
---|---|
static T |
apply(akka.actor.ActorSystem system) |
akka.stream.javadsl.Source<IncomingConnection,java.util.concurrent.CompletionStage<ServerBinding>> |
bind(ConnectHttp connect)
Creates a
Source of IncomingConnection instances which represents a prospective HTTP server binding
on the given endpoint . |
akka.stream.javadsl.Source<IncomingConnection,java.util.concurrent.CompletionStage<ServerBinding>> |
bind(ConnectHttp connect,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
akka.stream.javadsl.Source<IncomingConnection,java.util.concurrent.CompletionStage<ServerBinding>> |
bind(ConnectHttp connect,
ServerSettings settings)
Creates a
Source of IncomingConnection instances which represents a prospective HTTP server binding
on the given endpoint . |
akka.stream.javadsl.Source<IncomingConnection,java.util.concurrent.CompletionStage<ServerBinding>> |
bind(ConnectHttp connect,
ServerSettings settings,
akka.event.LoggingAdapter log)
Creates a
Source of IncomingConnection instances which represents a prospective HTTP server binding
on the given endpoint . |
akka.stream.javadsl.Source<IncomingConnection,java.util.concurrent.CompletionStage<ServerBinding>> |
bind(ConnectHttp connect,
ServerSettings settings,
akka.event.LoggingAdapter log,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
akka.stream.javadsl.Source<IncomingConnection,java.util.concurrent.CompletionStage<ServerBinding>> |
bind(ConnectHttp connect,
ServerSettings settings,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
java.util.concurrent.CompletionStage<ServerBinding> |
bindAndHandle(akka.stream.javadsl.Flow<HttpRequest,HttpResponse,?> handler,
ConnectHttp connect,
akka.stream.Materializer materializer)
Convenience method which starts a new HTTP server at the given endpoint and uses the given
handler
Flow for processing all incoming connections. |
java.util.concurrent.CompletionStage<ServerBinding> |
bindAndHandle(akka.stream.javadsl.Flow<HttpRequest,HttpResponse,?> handler,
ConnectHttp connect,
ServerSettings settings,
akka.event.LoggingAdapter log,
akka.stream.Materializer materializer)
Convenience method which starts a new HTTP server at the given endpoint and uses the given
handler
Flow for processing all incoming connections. |
java.util.concurrent.CompletionStage<ServerBinding> |
bindAndHandleAsync(akka.japi.Function<HttpRequest,java.util.concurrent.CompletionStage<HttpResponse>> handler,
ConnectHttp connect,
akka.stream.Materializer materializer)
Convenience method which starts a new HTTP server at the given endpoint and uses the given
handler
Flow for processing all incoming connections. |
java.util.concurrent.CompletionStage<ServerBinding> |
bindAndHandleAsync(akka.japi.Function<HttpRequest,java.util.concurrent.CompletionStage<HttpResponse>> handler,
ConnectHttp connect,
ServerSettings settings,
int parallelism,
akka.event.LoggingAdapter log,
akka.stream.Materializer materializer)
Convenience method which starts a new HTTP server at the given endpoint and uses the given
handler
Flow for processing all incoming connections. |
java.util.concurrent.CompletionStage<ServerBinding> |
bindAndHandleSync(akka.japi.Function<HttpRequest,HttpResponse> handler,
ConnectHttp connect,
akka.stream.Materializer materializer)
Convenience method which starts a new HTTP server at the given endpoint and uses the given
handler
Flow for processing all incoming connections. |
java.util.concurrent.CompletionStage<ServerBinding> |
bindAndHandleSync(akka.japi.Function<HttpRequest,HttpResponse> handler,
ConnectHttp connect,
ServerSettings settings,
akka.event.LoggingAdapter log,
akka.stream.Materializer materializer)
Convenience method which starts a new HTTP server at the given endpoint and uses the given
handler
Flow for processing all incoming connections. |
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> |
cachedHostConnectionPool(ConnectHttp to)
Returns a
Flow which dispatches incoming HTTP requests to the per-ActorSystem pool of outgoing
HTTP connections to the given target host endpoint. |
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> |
cachedHostConnectionPool(ConnectHttp to,
ConnectionPoolSettings settings,
akka.event.LoggingAdapter log,
akka.stream.Materializer materializer)
Deprecated.
in favor of
cachedHostConnectionPoolHttps that doesn't require an Materializer argument. |
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> |
cachedHostConnectionPool(ConnectHttp to,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> |
cachedHostConnectionPool(java.lang.String host)
Returns a
Flow which dispatches incoming HTTP requests to the per-ActorSystem pool of outgoing
HTTP connections to the given target host endpoint. |
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> |
cachedHostConnectionPool(java.lang.String host,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> |
cachedHostConnectionPoolHttps(ConnectHttp to)
Same as
cachedHostConnectionPool but with HTTPS encryption. |
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> |
cachedHostConnectionPoolHttps(ConnectHttp to,
ConnectionPoolSettings settings,
akka.event.LoggingAdapter log)
Same as
cachedHostConnectionPool but with HTTPS encryption. |
akka.stream.javadsl.BidiFlow<HttpRequest,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpResponse,akka.NotUsed> |
clientLayer(Host hostHeader)
Constructs a client layer stage using the configured default
ClientConnectionSettings . |
akka.stream.javadsl.BidiFlow<HttpRequest,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpResponse,akka.NotUsed> |
clientLayer(Host hostHeader,
ClientConnectionSettings settings)
Constructs a client layer stage using the given
ClientConnectionSettings . |
akka.stream.javadsl.BidiFlow<HttpRequest,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpResponse,akka.NotUsed> |
clientLayer(Host hostHeader,
ClientConnectionSettings settings,
akka.event.LoggingAdapter log)
Constructs a client layer stage using the given
ClientConnectionSettings . |
HttpsConnectionContext |
createClientHttpsContext(com.typesafe.sslconfig.akka.AkkaSSLConfig sslConfig) |
HttpsConnectionContext |
createDefaultClientHttpsContext() |
static Http |
createExtension(akka.actor.ExtendedActorSystem system) |
HttpsConnectionContext |
createServerHttpsContext(com.typesafe.sslconfig.akka.AkkaSSLConfig sslConfig) |
HttpsConnectionContext |
defaultClientHttpsContext()
Gets the current default client-side
ConnectionContext . |
ConnectionContext |
defaultServerHttpContext()
Gets the current default server-side
ConnectionContext – defaults to plain HTTP. |
static boolean |
equals(java.lang.Object other) |
static Http |
get(akka.actor.ActorSystem system) |
static int |
hashCode() |
static Http$ |
lookup() |
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> |
newHostConnectionPool(ConnectHttp to,
ConnectionPoolSettings settings,
akka.event.LoggingAdapter log,
akka.stream.Materializer materializer)
Same as
newHostConnectionPool but with HTTPS encryption. |
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> |
newHostConnectionPool(ConnectHttp to,
akka.stream.Materializer materializer)
Starts a new connection pool to the given host and configuration and returns a
Flow which dispatches
the requests from all its materializations across this pool. |
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> |
newHostConnectionPool(java.lang.String host,
akka.stream.Materializer materializer)
Starts a new connection pool to the given host and configuration and returns a
Flow which dispatches
the requests from all its materializations across this pool. |
akka.stream.javadsl.Flow<HttpRequest,HttpResponse,java.util.concurrent.CompletionStage<OutgoingConnection>> |
outgoingConnection(ConnectHttp to)
Creates a
Flow representing a prospective HTTP client connection to the given endpoint. |
akka.stream.javadsl.Flow<HttpRequest,HttpResponse,java.util.concurrent.CompletionStage<OutgoingConnection>> |
outgoingConnection(ConnectHttp to,
java.util.Optional<java.net.InetSocketAddress> localAddress,
ClientConnectionSettings settings,
akka.event.LoggingAdapter log)
Creates a
Flow representing a prospective HTTP client connection to the given endpoint. |
akka.stream.javadsl.Flow<HttpRequest,HttpResponse,java.util.concurrent.CompletionStage<OutgoingConnection>> |
outgoingConnection(java.lang.String host)
Creates a
Flow representing a prospective HTTP client connection to the given endpoint. |
akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> |
serverLayer()
Constructs a server layer stage using the configured default
ServerSettings . |
akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> |
serverLayer(akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> |
serverLayer(ServerSettings settings)
Constructs a server layer stage using the given
ServerSettings . |
akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> |
serverLayer(ServerSettings settings,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> |
serverLayer(ServerSettings settings,
java.util.Optional<java.net.InetSocketAddress> remoteAddress)
Constructs a server layer stage using the given
ServerSettings . |
akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> |
serverLayer(ServerSettings settings,
java.util.Optional<java.net.InetSocketAddress> remoteAddress,
akka.event.LoggingAdapter log)
Constructs a server layer stage using the given
ServerSettings . |
akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> |
serverLayer(ServerSettings settings,
java.util.Optional<java.net.InetSocketAddress> remoteAddress,
akka.event.LoggingAdapter log,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> |
serverLayer(ServerSettings settings,
java.util.Optional<java.net.InetSocketAddress> remoteAddress,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
void |
setDefaultClientHttpsContext(HttpsConnectionContext context)
Sets the default client-side
ConnectionContext . |
void |
setDefaultServerHttpContext(ConnectionContext context)
Sets the default server-side
ConnectionContext . |
java.util.concurrent.CompletionStage<scala.runtime.BoxedUnit> |
shutdownAllConnectionPools()
Triggers an orderly shutdown of all host connections pools currently maintained by the
ActorSystem . |
java.util.concurrent.CompletionStage<HttpResponse> |
singleRequest(HttpRequest request)
Fires a single
HttpRequest across the (cached) host connection pool for the request's
effective URI to produce a response future. |
java.util.concurrent.CompletionStage<HttpResponse> |
singleRequest(HttpRequest request,
HttpsConnectionContext connectionContext)
Fires a single
HttpRequest across the (cached) host connection pool for the request's
effective URI to produce a response future. |
java.util.concurrent.CompletionStage<HttpResponse> |
singleRequest(HttpRequest request,
HttpsConnectionContext connectionContext,
ConnectionPoolSettings settings,
akka.event.LoggingAdapter log)
Fires a single
HttpRequest across the (cached) host connection pool for the request's
effective URI to produce a response future. |
java.util.concurrent.CompletionStage<HttpResponse> |
singleRequest(HttpRequest request,
HttpsConnectionContext connectionContext,
ConnectionPoolSettings settings,
akka.event.LoggingAdapter log,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
java.util.concurrent.CompletionStage<HttpResponse> |
singleRequest(HttpRequest request,
HttpsConnectionContext connectionContext,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
java.util.concurrent.CompletionStage<HttpResponse> |
singleRequest(HttpRequest request,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
<T> akka.japi.Pair<java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>,T> |
singleWebSocketRequest(WebSocketRequest request,
akka.stream.javadsl.Flow<Message,Message,T> clientFlow,
ConnectionContext connectionContext,
akka.stream.Materializer materializer)
Runs a single WebSocket conversation given a Uri and a flow that represents the client side of the
WebSocket conversation.
|
<T> akka.japi.Pair<java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>,T> |
singleWebSocketRequest(WebSocketRequest request,
akka.stream.javadsl.Flow<Message,Message,T> clientFlow,
ConnectionContext connectionContext,
java.util.Optional<java.net.InetSocketAddress> localAddress,
ClientConnectionSettings settings,
akka.event.LoggingAdapter log,
akka.stream.Materializer materializer)
Runs a single WebSocket conversation given a Uri and a flow that represents the client side of the
WebSocket conversation.
|
<T> akka.japi.Pair<java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>,T> |
singleWebSocketRequest(WebSocketRequest request,
akka.stream.javadsl.Flow<Message,Message,T> clientFlow,
akka.stream.Materializer materializer)
Runs a single WebSocket conversation given a Uri and a flow that represents the client side of the
WebSocket conversation.
|
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,akka.NotUsed> |
superPool()
Creates a new "super connection pool flow", which routes incoming requests to a (cached) host connection pool
depending on their respective effective URIs.
|
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,akka.NotUsed> |
superPool(ConnectionPoolSettings settings,
HttpsConnectionContext connectionContext,
akka.event.LoggingAdapter log)
Creates a new "super connection pool flow", which routes incoming requests to a (cached) host connection pool
depending on their respective effective URIs.
|
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,akka.NotUsed> |
superPool(ConnectionPoolSettings settings,
HttpsConnectionContext connectionContext,
akka.event.LoggingAdapter log,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,akka.NotUsed> |
superPool(ConnectionPoolSettings settings,
akka.event.LoggingAdapter log)
Creates a new "super connection pool flow", which routes incoming requests to a (cached) host connection pool
depending on their respective effective URIs.
|
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,akka.NotUsed> |
superPool(ConnectionPoolSettings settings,
akka.event.LoggingAdapter log,
akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
<T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,akka.NotUsed> |
superPool(akka.stream.Materializer materializer)
Deprecated.
in favor of method that doesn't require materializer. You can just remove the materializer argument.
|
akka.stream.javadsl.Flow<Message,Message,java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>> |
webSocketClientFlow(WebSocketRequest request)
Constructs a flow that once materialized establishes a WebSocket connection to the given Uri.
|
akka.stream.javadsl.Flow<Message,Message,java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>> |
webSocketClientFlow(WebSocketRequest request,
ConnectionContext connectionContext,
java.util.Optional<java.net.InetSocketAddress> localAddress,
ClientConnectionSettings settings,
akka.event.LoggingAdapter log)
Constructs a flow that once materialized establishes a WebSocket connection to the given Uri.
|
akka.stream.javadsl.BidiFlow<Message,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,Message,java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>> |
webSocketClientLayer(WebSocketRequest request)
Constructs a WebSocket
BidiFlow . |
akka.stream.javadsl.BidiFlow<Message,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,Message,java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>> |
webSocketClientLayer(WebSocketRequest request,
ClientConnectionSettings settings)
Constructs a WebSocket
BidiFlow using the configured default ClientConnectionSettings ,
configured using the akka.http.client config section. |
akka.stream.javadsl.BidiFlow<Message,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,Message,java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>> |
webSocketClientLayer(WebSocketRequest request,
ClientConnectionSettings settings,
akka.event.LoggingAdapter log)
Constructs a WebSocket
BidiFlow using the configured default ClientConnectionSettings ,
configured using the akka.http.client config section. |
public static Http get(akka.actor.ActorSystem system)
public static Http$ lookup()
public static Http createExtension(akka.actor.ExtendedActorSystem system)
public static T apply(akka.actor.ActorSystem system)
public static final int hashCode()
public static final boolean equals(java.lang.Object other)
public akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> serverLayer()
ServerSettings
. The returned BidiFlow
isn't
reusable and can only be materialized once.public akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> serverLayer(ServerSettings settings)
ServerSettings
. The returned BidiFlow
isn't reusable and
can only be materialized once.settings
- (undocumented)public akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> serverLayer(ServerSettings settings, java.util.Optional<java.net.InetSocketAddress> remoteAddress)
ServerSettings
. The returned BidiFlow
isn't reusable and
can only be materialized once. The remoteAddress
, if provided, will be added as a header to each HttpRequest
this layer produces if the akka.http.server.remote-address-header
configuration option is enabled.settings
- (undocumented)remoteAddress
- (undocumented)public akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> serverLayer(ServerSettings settings, java.util.Optional<java.net.InetSocketAddress> remoteAddress, akka.event.LoggingAdapter log)
ServerSettings
. The returned BidiFlow
isn't reusable and
can only be materialized once. The remoteAddress, if provided, will be added as a header to each HttpRequest
this layer produces if the akka.http.server.remote-address-header
configuration option is enabled.settings
- (undocumented)remoteAddress
- (undocumented)log
- (undocumented)public akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> serverLayer(akka.stream.Materializer materializer)
materializer
- (undocumented)public akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> serverLayer(ServerSettings settings, akka.stream.Materializer materializer)
settings
- (undocumented)materializer
- (undocumented)public akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> serverLayer(ServerSettings settings, java.util.Optional<java.net.InetSocketAddress> remoteAddress, akka.stream.Materializer materializer)
settings
- (undocumented)remoteAddress
- (undocumented)materializer
- (undocumented)public akka.stream.javadsl.BidiFlow<HttpResponse,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpRequest,akka.NotUsed> serverLayer(ServerSettings settings, java.util.Optional<java.net.InetSocketAddress> remoteAddress, akka.event.LoggingAdapter log, akka.stream.Materializer materializer)
settings
- (undocumented)remoteAddress
- (undocumented)log
- (undocumented)materializer
- (undocumented)public akka.stream.javadsl.Source<IncomingConnection,java.util.concurrent.CompletionStage<ServerBinding>> bind(ConnectHttp connect)
Source
of IncomingConnection
instances which represents a prospective HTTP server binding
on the given endpoint
.
If the given port is 0 the resulting source can be materialized several times. Each materialization will
then be assigned a new local port by the operating system, which can then be retrieved by the materialized
ServerBinding
.
If the given port is non-zero subsequent materialization attempts of the produced source will immediately
fail, unless the first materialization has already been unbound. Unbinding can be triggered via the materialized
ServerBinding
.
The server will be bound using HTTPS if the ConnectHttp
object is configured with an HttpsConnectionContext
,
or the defaultServerHttpContext
has been configured to be an HttpsConnectionContext
.
connect
- (undocumented)public akka.stream.javadsl.Source<IncomingConnection,java.util.concurrent.CompletionStage<ServerBinding>> bind(ConnectHttp connect, ServerSettings settings)
Source
of IncomingConnection
instances which represents a prospective HTTP server binding
on the given endpoint
.
If the given port is 0 the resulting source can be materialized several times. Each materialization will
then be assigned a new local port by the operating system, which can then be retrieved by the materialized
ServerBinding
.
If the given port is non-zero subsequent materialization attempts of the produced source will immediately
fail, unless the first materialization has already been unbound. Unbinding can be triggered via the materialized
ServerBinding
.
The server will be bound using HTTPS if the ConnectHttp
object is configured with an HttpsConnectionContext
,
or the defaultServerHttpContext
has been configured to be an HttpsConnectionContext
.
connect
- (undocumented)settings
- (undocumented)public akka.stream.javadsl.Source<IncomingConnection,java.util.concurrent.CompletionStage<ServerBinding>> bind(ConnectHttp connect, ServerSettings settings, akka.event.LoggingAdapter log)
Source
of IncomingConnection
instances which represents a prospective HTTP server binding
on the given endpoint
.
If the given port is 0 the resulting source can be materialized several times. Each materialization will
then be assigned a new local port by the operating system, which can then be retrieved by the materialized
ServerBinding
.
If the given port is non-zero subsequent materialization attempts of the produced source will immediately
fail, unless the first materialization has already been unbound. Unbinding can be triggered via the materialized
ServerBinding
.
The server will be bound using HTTPS if the ConnectHttp
object is configured with an HttpsConnectionContext
,
or the defaultServerHttpContext
has been configured to be an HttpsConnectionContext
.
connect
- (undocumented)settings
- (undocumented)log
- (undocumented)public akka.stream.javadsl.Source<IncomingConnection,java.util.concurrent.CompletionStage<ServerBinding>> bind(ConnectHttp connect, akka.stream.Materializer materializer)
connect
- (undocumented)materializer
- (undocumented)public akka.stream.javadsl.Source<IncomingConnection,java.util.concurrent.CompletionStage<ServerBinding>> bind(ConnectHttp connect, ServerSettings settings, akka.stream.Materializer materializer)
connect
- (undocumented)settings
- (undocumented)materializer
- (undocumented)public akka.stream.javadsl.Source<IncomingConnection,java.util.concurrent.CompletionStage<ServerBinding>> bind(ConnectHttp connect, ServerSettings settings, akka.event.LoggingAdapter log, akka.stream.Materializer materializer)
connect
- (undocumented)settings
- (undocumented)log
- (undocumented)materializer
- (undocumented)public java.util.concurrent.CompletionStage<ServerBinding> bindAndHandle(akka.stream.javadsl.Flow<HttpRequest,HttpResponse,?> handler, ConnectHttp connect, akka.stream.Materializer materializer)
handler
Flow
for processing all incoming connections.
The number of concurrently accepted connections can be configured by overriding
the akka.http.server.max-connections
setting. Please see the documentation in the reference.conf for more
information about what kind of guarantees to expect.
The server will be bound using HTTPS if the ConnectHttp
object is configured with an HttpsConnectionContext
,
or the defaultServerHttpContext
has been configured to be an HttpsConnectionContext
.
handler
- (undocumented)connect
- (undocumented)materializer
- (undocumented)public java.util.concurrent.CompletionStage<ServerBinding> bindAndHandle(akka.stream.javadsl.Flow<HttpRequest,HttpResponse,?> handler, ConnectHttp connect, ServerSettings settings, akka.event.LoggingAdapter log, akka.stream.Materializer materializer)
handler
Flow
for processing all incoming connections.
The number of concurrently accepted connections can be configured by overriding
the akka.http.server.max-connections
setting. Please see the documentation in the reference.conf for more
information about what kind of guarantees to expect.
The server will be bound using HTTPS if the ConnectHttp
object is configured with an HttpsConnectionContext
,
or the defaultServerHttpContext
has been configured to be an HttpsConnectionContext
.
handler
- (undocumented)connect
- (undocumented)settings
- (undocumented)log
- (undocumented)materializer
- (undocumented)public java.util.concurrent.CompletionStage<ServerBinding> bindAndHandleSync(akka.japi.Function<HttpRequest,HttpResponse> handler, ConnectHttp connect, akka.stream.Materializer materializer)
handler
Flow
for processing all incoming connections.
The number of concurrently accepted connections can be configured by overriding
the akka.http.server.max-connections
setting. Please see the documentation in the reference.conf for more
information about what kind of guarantees to expect.
The server will be bound using HTTPS if the ConnectHttp
object is configured with an HttpsConnectionContext
,
or the defaultServerHttpContext
has been configured to be an HttpsConnectionContext
.
handler
- (undocumented)connect
- (undocumented)materializer
- (undocumented)public java.util.concurrent.CompletionStage<ServerBinding> bindAndHandleSync(akka.japi.Function<HttpRequest,HttpResponse> handler, ConnectHttp connect, ServerSettings settings, akka.event.LoggingAdapter log, akka.stream.Materializer materializer)
handler
Flow
for processing all incoming connections.
The number of concurrently accepted connections can be configured by overriding
the akka.http.server.max-connections
setting. Please see the documentation in the reference.conf for more
information about what kind of guarantees to expect.
The server will be bound using HTTPS if the ConnectHttp
object is configured with an HttpsConnectionContext
,
or the defaultServerHttpContext
has been configured to be an HttpsConnectionContext
.
handler
- (undocumented)connect
- (undocumented)settings
- (undocumented)log
- (undocumented)materializer
- (undocumented)public java.util.concurrent.CompletionStage<ServerBinding> bindAndHandleAsync(akka.japi.Function<HttpRequest,java.util.concurrent.CompletionStage<HttpResponse>> handler, ConnectHttp connect, akka.stream.Materializer materializer)
handler
Flow
for processing all incoming connections.
The number of concurrently accepted connections can be configured by overriding
the akka.http.server.max-connections
setting. Please see the documentation in the reference.conf for more
information about what kind of guarantees to expect.
The server will be bound using HTTPS if the ConnectHttp
object is configured with an HttpsConnectionContext
,
or the defaultServerHttpContext
has been configured to be an HttpsConnectionContext
.
handler
- (undocumented)connect
- (undocumented)materializer
- (undocumented)public java.util.concurrent.CompletionStage<ServerBinding> bindAndHandleAsync(akka.japi.Function<HttpRequest,java.util.concurrent.CompletionStage<HttpResponse>> handler, ConnectHttp connect, ServerSettings settings, int parallelism, akka.event.LoggingAdapter log, akka.stream.Materializer materializer)
handler
Flow
for processing all incoming connections.
The number of concurrently accepted connections can be configured by overriding
the akka.http.server.max-connections
setting. Please see the documentation in the reference.conf for more
information about what kind of guarantees to expect.
The server will be bound using HTTPS if the ConnectHttp
object is configured with an HttpsConnectionContext
,
or the defaultServerHttpContext
has been configured to be an HttpsConnectionContext
.
handler
- (undocumented)connect
- (undocumented)settings
- (undocumented)parallelism
- (undocumented)log
- (undocumented)materializer
- (undocumented)public akka.stream.javadsl.BidiFlow<HttpRequest,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpResponse,akka.NotUsed> clientLayer(Host hostHeader)
ClientConnectionSettings
.hostHeader
- (undocumented)public akka.stream.javadsl.BidiFlow<HttpRequest,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpResponse,akka.NotUsed> clientLayer(Host hostHeader, ClientConnectionSettings settings)
ClientConnectionSettings
.hostHeader
- (undocumented)settings
- (undocumented)public akka.stream.javadsl.BidiFlow<HttpRequest,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,HttpResponse,akka.NotUsed> clientLayer(Host hostHeader, ClientConnectionSettings settings, akka.event.LoggingAdapter log)
ClientConnectionSettings
.hostHeader
- (undocumented)settings
- (undocumented)log
- (undocumented)public akka.stream.javadsl.Flow<HttpRequest,HttpResponse,java.util.concurrent.CompletionStage<OutgoingConnection>> outgoingConnection(java.lang.String host)
Flow
representing a prospective HTTP client connection to the given endpoint.
Every materialization of the produced flow will attempt to establish a new outgoing connection.
If the hostname is given with an https://
prefix, the default HttpsConnectionContext
will be used.
host
- (undocumented)public akka.stream.javadsl.Flow<HttpRequest,HttpResponse,java.util.concurrent.CompletionStage<OutgoingConnection>> outgoingConnection(ConnectHttp to)
Flow
representing a prospective HTTP client connection to the given endpoint.
Every materialization of the produced flow will attempt to establish a new outgoing connection.
Use the ConnectHttp
DSL to configure target host and whether HTTPS should be used.
to
- (undocumented)public akka.stream.javadsl.Flow<HttpRequest,HttpResponse,java.util.concurrent.CompletionStage<OutgoingConnection>> outgoingConnection(ConnectHttp to, java.util.Optional<java.net.InetSocketAddress> localAddress, ClientConnectionSettings settings, akka.event.LoggingAdapter log)
Flow
representing a prospective HTTP client connection to the given endpoint.
Every materialization of the produced flow will attempt to establish a new outgoing connection.to
- (undocumented)localAddress
- (undocumented)settings
- (undocumented)log
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> newHostConnectionPool(java.lang.String host, akka.stream.Materializer materializer)
Flow
which dispatches
the requests from all its materializations across this pool.
While the started host connection pool internally shuts itself down automatically after the configured idle
timeout it will spin itself up again if more requests arrive from an existing or a new client flow
materialization. The returned flow therefore remains usable for the full lifetime of the application.
Since the underlying transport usually comprises more than a single connection the produced flow might generate
responses in an order that doesn't directly match the consumed requests.
For example, if two requests A and B enter the flow in that order the response for B might be produced before the
response for A.
In order to allow for easy response-to-request association the flow takes in a custom, opaque context
object of type T
from the application which is emitted together with the corresponding response.
host
- (undocumented)materializer
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> newHostConnectionPool(ConnectHttp to, akka.stream.Materializer materializer)
Flow
which dispatches
the requests from all its materializations across this pool.
While the started host connection pool internally shuts itself down automatically after the configured idle
timeout it will spin itself up again if more requests arrive from an existing or a new client flow
materialization. The returned flow therefore remains usable for the full lifetime of the application.
Since the underlying transport usually comprises more than a single connection the produced flow might generate
responses in an order that doesn't directly match the consumed requests.
For example, if two requests A and B enter the flow in that order the response for B might be produced before the
response for A.
In order to allow for easy response-to-request association the flow takes in a custom, opaque context
object of type T
from the application which is emitted together with the corresponding response.
to
- (undocumented)materializer
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> newHostConnectionPool(ConnectHttp to, ConnectionPoolSettings settings, akka.event.LoggingAdapter log, akka.stream.Materializer materializer)
newHostConnectionPool
but with HTTPS encryption.
The given ConnectionContext
will be used for encryption on the connection.
to
- (undocumented)settings
- (undocumented)log
- (undocumented)materializer
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> cachedHostConnectionPool(java.lang.String host)
Flow
which dispatches incoming HTTP requests to the per-ActorSystem pool of outgoing
HTTP connections to the given target host endpoint. For every ActorSystem, target host and pool
configuration a separate connection pool is maintained.
The HTTP layer transparently manages idle shutdown and restarting of connections pools as configured.
The returned Flow
instances therefore remain valid throughout the lifetime of the application.
The internal caching logic guarantees that there will never be more than a single pool running for the given target host endpoint and configuration (in this ActorSystem).
Since the underlying transport usually comprises more than a single connection the produced flow might generate
responses in an order that doesn't directly match the consumed requests.
For example, if two requests A and B enter the flow in that order the response for B might be produced before the
response for A.
In order to allow for easy response-to-request association the flow takes in a custom, opaque context
object of type T
from the application which is emitted together with the corresponding response.
host
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> cachedHostConnectionPool(ConnectHttp to)
Flow
which dispatches incoming HTTP requests to the per-ActorSystem pool of outgoing
HTTP connections to the given target host endpoint. For every ActorSystem, target host and pool
configuration a separate connection pool is maintained.
The HTTP layer transparently manages idle shutdown and restarting of connections pools as configured.
The returned Flow
instances therefore remain valid throughout the lifetime of the application.
The internal caching logic guarantees that there will never be more than a single pool running for the given target host endpoint and configuration (in this ActorSystem).
Since the underlying transport usually comprises more than a single connection the produced flow might generate
responses in an order that doesn't directly match the consumed requests.
For example, if two requests A and B enter the flow in that order the response for B might be produced before the
response for A.
In order to allow for easy response-to-request association the flow takes in a custom, opaque context
object of type T
from the application which is emitted together with the corresponding response.
to
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> cachedHostConnectionPoolHttps(ConnectHttp to, ConnectionPoolSettings settings, akka.event.LoggingAdapter log)
cachedHostConnectionPool
but with HTTPS encryption.
When an HttpConnectionContext
is defined in the given ConnectHttp
it will be used, otherwise the default client-side context will be used.
to
- (undocumented)settings
- (undocumented)log
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> cachedHostConnectionPoolHttps(ConnectHttp to)
cachedHostConnectionPool
but with HTTPS encryption.
When an HttpConnectionContext
is defined in the given ConnectHttp
it will be used, otherwise the default client-side context will be used.
to
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> cachedHostConnectionPool(java.lang.String host, akka.stream.Materializer materializer)
host
- (undocumented)materializer
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> cachedHostConnectionPool(ConnectHttp to, akka.stream.Materializer materializer)
to
- (undocumented)materializer
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,HostConnectionPool> cachedHostConnectionPool(ConnectHttp to, ConnectionPoolSettings settings, akka.event.LoggingAdapter log, akka.stream.Materializer materializer)
cachedHostConnectionPoolHttps
that doesn't require an Materializer argument.to
- (undocumented)settings
- (undocumented)log
- (undocumented)materializer
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,akka.NotUsed> superPool()
Host
header.
Since the underlying transport usually comprises more than a single connection the produced flow might generate
responses in an order that doesn't directly match the consumed requests.
For example, if two requests A
and B
enter the flow in that order the response for B
might be produced before the
response for A
.
In order to allow for easy response-to-request association the flow takes in a custom, opaque context
object of type T
from the application which is emitted together with the corresponding response.
public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,akka.NotUsed> superPool(ConnectionPoolSettings settings, HttpsConnectionContext connectionContext, akka.event.LoggingAdapter log)
Host
header.
The given HttpsConnectionContext
is used to configure TLS for the connection.
Since the underlying transport usually comprises more than a single connection the produced flow might generate
responses in an order that doesn't directly match the consumed requests.
For example, if two requests A
and B
enter the flow
in that order the response for B
might be produced before the
response for A
.
In order to allow for easy response-to-request association the flow takes in a custom, opaque context
object of type T
from the application which is emitted together with the corresponding response.
settings
- (undocumented)connectionContext
- (undocumented)log
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,akka.NotUsed> superPool(ConnectionPoolSettings settings, akka.event.LoggingAdapter log)
Host
header.
The defaultClientHttpsContext
is used to configure TLS for the connection.
Since the underlying transport usually comprises more than a single connection the produced flow might generate
responses in an order that doesn't directly match the consumed requests.
For example, if two requests A
and B
enter the flow
in that order the response for B
might be produced before the
response for A
.
In order to allow for easy response-to-request association the flow takes in a custom, opaque context
object of type T
from the application which is emitted together with the corresponding response.
settings
- (undocumented)log
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,akka.NotUsed> superPool(akka.stream.Materializer materializer)
materializer
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,akka.NotUsed> superPool(ConnectionPoolSettings settings, akka.event.LoggingAdapter log, akka.stream.Materializer materializer)
settings
- (undocumented)log
- (undocumented)materializer
- (undocumented)public <T> akka.stream.javadsl.Flow<akka.japi.Pair<HttpRequest,T>,akka.japi.Pair<scala.util.Try<HttpResponse>,T>,akka.NotUsed> superPool(ConnectionPoolSettings settings, HttpsConnectionContext connectionContext, akka.event.LoggingAdapter log, akka.stream.Materializer materializer)
settings
- (undocumented)connectionContext
- (undocumented)log
- (undocumented)materializer
- (undocumented)public java.util.concurrent.CompletionStage<HttpResponse> singleRequest(HttpRequest request, akka.stream.Materializer materializer)
request
- (undocumented)materializer
- (undocumented)public java.util.concurrent.CompletionStage<HttpResponse> singleRequest(HttpRequest request, HttpsConnectionContext connectionContext, akka.stream.Materializer materializer)
request
- (undocumented)connectionContext
- (undocumented)materializer
- (undocumented)public java.util.concurrent.CompletionStage<HttpResponse> singleRequest(HttpRequest request, HttpsConnectionContext connectionContext, ConnectionPoolSettings settings, akka.event.LoggingAdapter log, akka.stream.Materializer materializer)
request
- (undocumented)connectionContext
- (undocumented)settings
- (undocumented)log
- (undocumented)materializer
- (undocumented)public java.util.concurrent.CompletionStage<HttpResponse> singleRequest(HttpRequest request)
HttpRequest
across the (cached) host connection pool for the request's
effective URI to produce a response future.
The defaultClientHttpsContext
is used to configure TLS for the connection.
Note that the request must have either an absolute URI or a valid Host
header, otherwise
the future will be completed with an error.
request
- (undocumented)public java.util.concurrent.CompletionStage<HttpResponse> singleRequest(HttpRequest request, HttpsConnectionContext connectionContext)
HttpRequest
across the (cached) host connection pool for the request's
effective URI to produce a response future.
The defaultClientHttpsContext
is used to configure TLS for the connection.
Note that the request must have either an absolute URI or a valid Host
header, otherwise
the future will be completed with an error.
request
- (undocumented)connectionContext
- (undocumented)public java.util.concurrent.CompletionStage<HttpResponse> singleRequest(HttpRequest request, HttpsConnectionContext connectionContext, ConnectionPoolSettings settings, akka.event.LoggingAdapter log)
HttpRequest
across the (cached) host connection pool for the request's
effective URI to produce a response future.
The given HttpsConnectionContext
will be used for encryption if the request is sent to an https endpoint.
Note that the request must have either an absolute URI or a valid Host
header, otherwise
the future will be completed with an error.
request
- (undocumented)connectionContext
- (undocumented)settings
- (undocumented)log
- (undocumented)public akka.stream.javadsl.BidiFlow<Message,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,Message,java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>> webSocketClientLayer(WebSocketRequest request)
BidiFlow
.
The layer is not reusable and must only be materialized once.
request
- (undocumented)public akka.stream.javadsl.BidiFlow<Message,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,Message,java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>> webSocketClientLayer(WebSocketRequest request, ClientConnectionSettings settings)
BidiFlow
using the configured default ClientConnectionSettings
,
configured using the akka.http.client
config section.
The layer is not reusable and must only be materialized once.
request
- (undocumented)settings
- (undocumented)public akka.stream.javadsl.BidiFlow<Message,akka.stream.TLSProtocol.SslTlsOutbound,akka.stream.TLSProtocol.SslTlsInbound,Message,java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>> webSocketClientLayer(WebSocketRequest request, ClientConnectionSettings settings, akka.event.LoggingAdapter log)
BidiFlow
using the configured default ClientConnectionSettings
,
configured using the akka.http.client
config section.
The layer is not reusable and must only be materialized once.
request
- (undocumented)settings
- (undocumented)log
- (undocumented)public akka.stream.javadsl.Flow<Message,Message,java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>> webSocketClientFlow(WebSocketRequest request)
The layer is not reusable and must only be materialized once.
request
- (undocumented)public akka.stream.javadsl.Flow<Message,Message,java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>> webSocketClientFlow(WebSocketRequest request, ConnectionContext connectionContext, java.util.Optional<java.net.InetSocketAddress> localAddress, ClientConnectionSettings settings, akka.event.LoggingAdapter log)
The layer is not reusable and must only be materialized once.
request
- (undocumented)connectionContext
- (undocumented)localAddress
- (undocumented)settings
- (undocumented)log
- (undocumented)public <T> akka.japi.Pair<java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>,T> singleWebSocketRequest(WebSocketRequest request, akka.stream.javadsl.Flow<Message,Message,T> clientFlow, akka.stream.Materializer materializer)
The defaultClientHttpsContext
is used to configure TLS for the connection.
request
- (undocumented)clientFlow
- (undocumented)materializer
- (undocumented)public <T> akka.japi.Pair<java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>,T> singleWebSocketRequest(WebSocketRequest request, akka.stream.javadsl.Flow<Message,Message,T> clientFlow, ConnectionContext connectionContext, akka.stream.Materializer materializer)
The defaultClientHttpsContext
is used to configure TLS for the connection.
request
- (undocumented)clientFlow
- (undocumented)connectionContext
- (undocumented)materializer
- (undocumented)public <T> akka.japi.Pair<java.util.concurrent.CompletionStage<WebSocketUpgradeResponse>,T> singleWebSocketRequest(WebSocketRequest request, akka.stream.javadsl.Flow<Message,Message,T> clientFlow, ConnectionContext connectionContext, java.util.Optional<java.net.InetSocketAddress> localAddress, ClientConnectionSettings settings, akka.event.LoggingAdapter log, akka.stream.Materializer materializer)
request
- (undocumented)clientFlow
- (undocumented)connectionContext
- (undocumented)localAddress
- (undocumented)settings
- (undocumented)log
- (undocumented)materializer
- (undocumented)public java.util.concurrent.CompletionStage<scala.runtime.BoxedUnit> shutdownAllConnectionPools()
ActorSystem
.
The returned future is completed when all pools that were live at the time of this method call
have completed their shutdown process.
If existing pool client flows are re-used or new ones materialized concurrently with or after this method call the respective connection pools will be restarted and not contribute to the returned future.
public ConnectionContext defaultServerHttpContext()
ConnectionContext
– defaults to plain HTTP.
Can be modified using setDefaultServerHttpContext
, and will then apply for servers bound after that call has completed.public void setDefaultServerHttpContext(ConnectionContext context)
ConnectionContext
.
If it is an instance of HttpsConnectionContext
then the server will be bound using HTTPS.context
- (undocumented)public HttpsConnectionContext defaultClientHttpsContext()
ConnectionContext
.public void setDefaultClientHttpsContext(HttpsConnectionContext context)
ConnectionContext
.context
- (undocumented)public HttpsConnectionContext createServerHttpsContext(com.typesafe.sslconfig.akka.AkkaSSLConfig sslConfig)
public HttpsConnectionContext createClientHttpsContext(com.typesafe.sslconfig.akka.AkkaSSLConfig sslConfig)
public HttpsConnectionContext createDefaultClientHttpsContext()