Top Description Fields Constructors Methods
io.vertx.core.net.impl.pool

public abstract Class Endpoint<C>

extends Object
Class Inheritance
Known Direct Subclasses
io.vertx.core.http.impl.ClientHttpEndpointBase
Imports
io.vertx.core.AsyncResult, .Handler, io.vertx.core.impl.ContextInternal

An endpoint, i.e a set of connection to the same address.
Author
Julien Viet

Field Summary

Modifier and TypeField and Description
private boolean
private final Runnable
private boolean
private long
private long

Constructor Summary

AccessConstructor and Description
public
Endpoint(Runnable dispose)

Method Summary

Modifier and TypeMethod and Description
private boolean
protected void
close()

Close the endpoint, this will close all connections, this method is called by the ConnectionManager when it is closed.

protected boolean
protected void
dispose()

Hook to cleanup when all metrics have been processed, e.g unregistering metrics, this method is called when the endpoint will not accept anymore requests.

private void
public boolean
getConnection(ContextInternal ctx, long timeout, Handler<AsyncResult<C>> handler)

protected boolean
public abstract void
requestConnection(ContextInternal ctx, long timeout, Handler<AsyncResult<C>> handler)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

closedback to summary
private boolean closed
disposeback to summary
private final Runnable dispose
disposedback to summary
private boolean disposed
pendingRequestCountback to summary
private long pendingRequestCount
refCountback to summary
private long refCount

Constructor Detail

Endpointback to summary
public Endpoint(Runnable dispose)

Method Detail

checkDisposeback to summary
private boolean checkDispose()
closeback to summary
protected void close()

Close the endpoint, this will close all connections, this method is called by the ConnectionManager when it is closed.

decRefCountback to summary
protected boolean decRefCount()
disposeback to summary
protected void dispose()

Hook to cleanup when all metrics have been processed, e.g unregistering metrics, this method is called when the endpoint will not accept anymore requests.

disposeInternalback to summary
private void disposeInternal()
getConnectionback to summary
public boolean getConnection(ContextInternal ctx, long timeout, Handler<AsyncResult<C>> handler)
incRefCountback to summary
protected boolean incRefCount()
requestConnectionback to summary
public abstract void requestConnection(ContextInternal ctx, long timeout, Handler<AsyncResult<C>> handler)