trait OutgoingConnectionBuilder extends AnyRef
Builder for setting up a flow that will create one single connection per materialization to the specified host. When customization is done, the flow is created using #http(), #https(), #http2() or #http2WithPriorKnowledge().
Not for user extension
- Annotations
- @DoNotInherit()
- Source
- OutgoingConnectionBuilder.scala
- Alphabetic
- By Inheritance
- OutgoingConnectionBuilder
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def http(): Flow[HttpRequest, HttpResponse, Future[OutgoingConnection]]
Create a flow that when materialized creates a single HTTP/1.1 plaintext connection with a default port 80 to the server.
- abstract def http2(): Flow[HttpRequest, HttpResponse, Future[OutgoingConnection]]
Create a flow that when materialized creates a single HTTP/2 TLS connection with a default port 443
Create a flow that when materialized creates a single HTTP/2 TLS connection with a default port 443
Note that the responses are not guaranteed to arrive in the same order as the requests go out (In the case of a HTTP/2 connection) so therefore requests needs to have a akka.http.scaladsl.model.RequestResponseAssociation which Akka HTTP will carry over to the corresponding response for a request.
- abstract def http2WithPriorKnowledge(): Flow[HttpRequest, HttpResponse, Future[OutgoingConnection]]
Create a flow that when materialized creates a single HTTP/2 with 'prior knowledge' plaintext connection with a default port 80
Create a flow that when materialized creates a single HTTP/2 with 'prior knowledge' plaintext connection with a default port 80
Note that the responses are not guaranteed to arrive in the same order as the requests go out (In the case of a HTTP/2 connection) so therefore requests needs to have a akka.http.scaladsl.model.RequestResponseAssociation which Akka HTTP will carry over to the corresponding response for a request.
- abstract def https(): Flow[HttpRequest, HttpResponse, Future[OutgoingConnection]]
Create a flow that when materialized creates a single HTTP/1.1 TLS connection with a default port 443
- abstract def logTo(logger: LoggingAdapter): OutgoingConnectionBuilder
Use a custom logger
- abstract def managedPersistentHttp2(): Flow[HttpRequest, HttpResponse, NotUsed]
Create a flow that when materialized creates a managed HTTP/2 TLS connection with a default port 443.
Create a flow that when materialized creates a managed HTTP/2 TLS connection with a default port 443.
The connection will be re-established as needed.
Note that the responses are not guaranteed to arrive in the same order as the requests go out so therefore requests needs to have a akka.http.scaladsl.model.RequestResponseAssociation which Akka HTTP will carry over to the corresponding response for a request.
- Annotations
- @ApiMayChange()
- abstract def managedPersistentHttp2WithPriorKnowledge(): Flow[HttpRequest, HttpResponse, NotUsed]
Create a flow that when materialized creates a single HTTP/2 with 'prior knowledge' plaintext connection with a default port 80
Create a flow that when materialized creates a single HTTP/2 with 'prior knowledge' plaintext connection with a default port 80
The connection will be re-established as needed.
Note that the responses are not guaranteed to arrive in the same order as the requests go out (In the case of a HTTP/2 connection) so therefore requests needs to have a akka.http.scaladsl.model.RequestResponseAssociation which Akka HTTP will carry over to the corresponding response for a request.
- Annotations
- @ApiMayChange()
- abstract def toHost(host: String): OutgoingConnectionBuilder
Change which host flows built with this builder connects to
- abstract def toPort(port: Int): OutgoingConnectionBuilder
Change with port flows built with this builder connects to, if not set the protocol default is used.
- abstract def withClientConnectionSettings(settings: ClientConnectionSettings): OutgoingConnectionBuilder
Use custom ClientConnectionSettings for the connection.
- abstract def withCustomHttpsConnectionContext(httpsConnectionContext: HttpsConnectionContext): OutgoingConnectionBuilder
Use a custom HttpsConnectionContext for the connection.
Use a custom HttpsConnectionContext for the connection. Only applicable for
https()
andhttp2()
, overridesdefaultHttpsContext