object ClientTransport
(Still unstable) entry point to create or access predefined client transports.
- Annotations
- @ApiMayChange()
- Source
- ClientTransport.scala
- Alphabetic
- By Inheritance
- ClientTransport
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def TCP: ClientTransport
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def fromScala(scalaTransport: scaladsl.ClientTransport): ClientTransport
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def httpsProxy(proxyCredentials: HttpCredentials, system: ActorSystem): ClientTransport
Returns a ClientTransport that runs all connection through the given HTTP(S) proxy using the HTTP CONNECT method.
Returns a ClientTransport that runs all connection through the given HTTP(S) proxy using the HTTP CONNECT method. This method also takes HttpCredentials in order to pass along to the proxy.
Pulls the host/port pair from the application.conf: pekko.client.proxy.https.{host, port}
- def httpsProxy(proxyAddress: InetSocketAddress, proxyCredentials: HttpCredentials): ClientTransport
Returns a ClientTransport that runs all connection through the given HTTP(S) proxy using the HTTP CONNECT method.
Returns a ClientTransport that runs all connection through the given HTTP(S) proxy using the HTTP CONNECT method. This call also takes HttpCredentials to base proxy credentials along with the request.
An HTTP(S) proxy is a proxy that will create one TCP connection to the HTTP(S) proxy for each target connection. The proxy transparently forwards the TCP connection to the target host.
For more information about HTTP CONNECT tunnelling see https://tools.ietf.org/html/rfc7231#section-4.3.6.
- def httpsProxy(implicit system: ActorSystem): ClientTransport
Returns a ClientTransport that runs all connection through the given HTTP(S) proxy using the HTTP CONNECT method.
Returns a ClientTransport that runs all connection through the given HTTP(S) proxy using the HTTP CONNECT method.
Pulls the host/port pair from the application.conf: pekko.client.proxy.https.{host, port}
- def httpsProxy(proxyAddress: InetSocketAddress): ClientTransport
Returns a ClientTransport that runs all connection through the given HTTP(S) proxy using the HTTP CONNECT method.
Returns a ClientTransport that runs all connection through the given HTTP(S) proxy using the HTTP CONNECT method.
An HTTP(S) proxy is a proxy that will create one TCP connection to the HTTP(S) proxy for each target connection. The proxy transparently forwards the TCP connection to the target host.
For more information about HTTP CONNECT tunnelling see https://tools.ietf.org/html/rfc7231#section-4.3.6.
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toScala(javaTransport: ClientTransport): scaladsl.ClientTransport
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def withCustomResolver(lookup: BiFunction[String, Int, CompletionStage[InetSocketAddress]]): ClientTransport
Returns a ClientTransport that allows to customize host name resolution.
Returns a ClientTransport that allows to customize host name resolution.
- lookup
A function that will be called with hostname and port and that should (potentially asynchronously resolve the given host/port to an InetSocketAddress