io.vertx.core.net.impl

Class TCPServerBase

java.lang.Object

io.vertx.core.net.impl.TCPServerBase

All Implemented Interfaces:

Closeable, Measured, MetricsProvider

Direct Known Subclasses:

HttpServerImpl, NetServerImpl

public abstract class TCPServerBase
extends Object
implements Closeable, MetricsProvider

Base class for TCP servers

Author:

Tim Fox, Julien Viet

Field Summary

Fields

Modifier and Type	Field and Description
protected Context	creatingContext
protected NetServerOptions	options
protected SSLHelper	sslHelper
protected VertxInternal	vertx

Constructor Summary

Constructors

Constructor and Description
TCPServerBase(VertxInternal vertx, NetServerOptions options)

Method Summary

Modifier and Type	Method and Description
int	actualPort()
abstract Future<Void>	close()
void	close(Promise<Void> completion) Close this resource, the completion promise must be notified when the operation has completed.
void	closeAll(Handler<AsyncResult<Void>> handler) Internal method that closes all servers when Vert.x is closing
protected TCPMetrics<?>	createMetrics(SocketAddress localAddress)
protected void	finalize()
TCPMetrics<?>	getMetrics() Returns the metrics implementation.
boolean	isListening()
boolean	isMetricsEnabled() Whether the metrics are enabled for this measured object
io.netty.util.concurrent.Future<io.netty.channel.Channel>	listen(SocketAddress localAddress, ContextInternal context, Handler<io.netty.channel.Channel> worker)

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

creatingContext

protected final Context creatingContext

vertx

protected final VertxInternal vertx

options

protected final NetServerOptions options

sslHelper

protected final SSLHelper sslHelper

Constructor Detail

TCPServerBase

public TCPServerBase(VertxInternal vertx,
                     NetServerOptions options)

Method Detail

actualPort

public int actualPort()

listen

public io.netty.util.concurrent.Future<io.netty.channel.Channel> listen(SocketAddress localAddress,
                                                                        ContextInternal context,
                                                                        Handler<io.netty.channel.Channel> worker)

isListening

public boolean isListening()

createMetrics

protected TCPMetrics<?> createMetrics(SocketAddress localAddress)

isMetricsEnabled

public boolean isMetricsEnabled()

Description copied from interface: Measured

Whether the metrics are enabled for this measured object

Specified by:

isMetricsEnabled in interface Measured

Returns:

true if metrics are enabled

getMetrics

public TCPMetrics<?> getMetrics()

Description copied from interface: MetricsProvider

Returns the metrics implementation.

Specified by:

getMetrics in interface MetricsProvider

Returns:

the metrics

close

public void close(Promise<Void> completion)

Description copied from interface: Closeable

Close this resource, the completion promise must be notified when the operation has completed.

Specified by:

close in interface Closeable

Parameters:

completion - the promise to signal when close has completed

closeAll

public void closeAll(Handler<AsyncResult<Void>> handler)

Internal method that closes all servers when Vert.x is closing

close

public abstract Future<Void> close()

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable