class NetClient extends Measured
A TCP client.
Multiple connections to different servers can be made using the same instance.
This client supports a configurable number of connection attempts and a configurable delay between attempts.
- Alphabetic
- By Inheritance
- NetClient
- Measured
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new NetClient(_asJava: AnyRef)
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
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- def asJava: AnyRef
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
close(): Unit
Close the client.
Close the client.
Any sockets which have not been closed manually will be closed here. The close is asynchronous and may not complete until some time after the method has returned.
-
def
connect(remoteAddress: SocketAddress, serverName: String, connectHandler: Handler[AsyncResult[NetSocket]]): NetClient
Open a connection to a server at the specific
remoteAddress
.Open a connection to a server at the specific
remoteAddress
.The connect is done asynchronously and on success, a io.vertx.scala.core.net.NetSocket instance is supplied via the
connectHandler
instance * @param remoteAddress the remote address- serverName
the SNI server name
- returns
a reference to this, so the API can be used fluently
-
def
connect(remoteAddress: SocketAddress, connectHandler: Handler[AsyncResult[NetSocket]]): NetClient
Open a connection to a server at the specific
remoteAddress
.Open a connection to a server at the specific
remoteAddress
.The connect is done asynchronously and on success, a io.vertx.scala.core.net.NetSocket instance is supplied via the
connectHandler
instance * @param remoteAddress the remote address- returns
a reference to this, so the API can be used fluently
-
def
connect(port: Int, host: String, serverName: String, connectHandler: Handler[AsyncResult[NetSocket]]): NetClient
Open a connection to a server at the specific
port
andhost
.Open a connection to a server at the specific
port
andhost
.host
can be a valid host name or IP address. The connect is done asynchronously and on success, a io.vertx.scala.core.net.NetSocket instance is supplied via theconnectHandler
instance * @param port the port- host
the host
- serverName
the SNI server name
- returns
a reference to this, so the API can be used fluently
-
def
connect(port: Int, host: String, connectHandler: Handler[AsyncResult[NetSocket]]): NetClient
Open a connection to a server at the specific
port
andhost
.Open a connection to a server at the specific
port
andhost
.host
can be a valid host name or IP address. The connect is done asynchronously and on success, a io.vertx.scala.core.net.NetSocket instance is supplied via theconnectHandler
instance * @param port the port- host
the host
- returns
a reference to this, so the API can be used fluently
-
def
connectFuture(remoteAddress: SocketAddress, serverName: String): scala.concurrent.Future[NetSocket]
Like connect but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
connectFuture(remoteAddress: SocketAddress): scala.concurrent.Future[NetSocket]
Like connect but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
connectFuture(port: Int, host: String, serverName: String): scala.concurrent.Future[NetSocket]
Like connect but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
connectFuture(port: Int, host: String): scala.concurrent.Future[NetSocket]
Like connect but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isMetricsEnabled(): Boolean
Whether the metrics are enabled for this measured object * @return
true
if metrics are enabled -
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
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )