Class HttpClientTransportOverHTTP2

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.client.AbstractHttpClientTransport

org.eclipse.jetty.http2.client.transport.HttpClientTransportOverHTTP2

All Implemented Interfaces:

HttpClient.Aware, HttpClientTransport, ClientConnectionFactory, Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle, Invocable

@ManagedObject("The HTTP/2 client transport")
public class HttpClientTransportOverHTTP2
extends AbstractHttpClientTransport

Nested Class Summary

Nested classes/interfaces inherited from class AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener, AbstractLifeCycle.StopException

Nested classes/interfaces inherited from interface ClientConnectionFactory

ClientConnectionFactory.Decorator, ClientConnectionFactory.Info, ClientConnectionFactory.Wrapper

Nested classes/interfaces inherited from interface Container

Container.InheritedListener, Container.Listener

Nested classes/interfaces inherited from interface Dumpable

Dumpable.DumpableContainer, Dumpable.DumpAppendable

Nested classes/interfaces inherited from interface Invocable

Invocable.Callable, Invocable.InvocationType, Invocable.ReadyTask, Invocable.Task

Nested classes/interfaces inherited from interface LifeCycle

LifeCycle.Listener

Field Summary

Fields inherited from class AbstractLifeCycle

FAILED, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface ClientConnectionFactory

CONTEXT_KEY

Fields inherited from interface Dumpable

LEGEND

Fields inherited from interface Invocable

__nonBlocking, NOOP

Constructor Summary

Constructors

Constructor	Description
HttpClientTransportOverHTTP2(HTTP2Client http2Client)

Method Summary

Modifier and Type	Method	Description
void	connect(SocketAddress address, Map<String,Object> context)	Establishes a physical connection to the given address.
protected void	connect(Transport transport, SslContextFactory.Client sslContextFactory, SocketAddress address, Session.Listener listener, Promise<Session> promise, Map<String,Object> context)
protected void	doStart()	Starts the managed lifecycle beans in the order they were added.
HTTP2Client	getHTTP2Client()
int	getSelectors()
protected Connection	newConnection(Destination destination, Session session, HTTP2Connection connection)
Connection	newConnection(EndPoint endPoint, Map<String,Object> context)
Destination	newDestination(Origin origin)	Creates a new, transport-specific, HttpDestination object.
Origin	newOrigin(Request request)	Creates a new Origin with the given request.
protected void	onClose(Connection connection, GoAwayFrame frame)

Methods inherited from class AbstractHttpClientTransport

connectFailed, getConnectionPoolFactory, getHttpClient, getInvocationType, setConnectionPoolFactory, setHttpClient, setInvocationType

Methods inherited from class ContainerLifeCycle

addBean, addBean, addEventListener, addManaged, contains, destroy, doStop, dump, dump, dump, dumpObjects, dumpStdErr, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, installBean, installBean, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, start, stop, unmanage, updateBean, updateBean, updateBeans, updateBeans

Methods inherited from class AbstractLifeCycle

getEventListeners, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, setEventListeners, start, stop, toString

Methods inherited from class Object

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

Methods inherited from interface ClientConnectionFactory

customize

Methods inherited from interface Container

getCachedBeans, getEventListeners

Methods inherited from interface Dumpable

dumpSelf

Methods inherited from interface Dumpable.DumpableContainer

isDumpable

Constructor Details

HttpClientTransportOverHTTP2

public HttpClientTransportOverHTTP2(HTTP2Client http2Client)

Method Details

getHTTP2Client

public HTTP2Client getHTTP2Client()

getSelectors

@ManagedAttribute(value="The number of selectors",
                  readonly=true)
public int getSelectors()

doStart

protected void doStart()
                throws Exception

Description copied from class: ContainerLifeCycle

Starts the managed lifecycle beans in the order they were added.

Overrides:

doStart in class ContainerLifeCycle

Throws:

Exception - If there was a problem starting. Will cause a transition to FAILED state

newOrigin

public Origin newOrigin(Request request)

Description copied from interface: HttpClientTransport

Creates a new Origin with the given request.

Parameters:

request - the request that triggers the creation of the Origin

Returns:

an Origin that identifies a destination

newDestination

public Destination newDestination(Origin origin)

Description copied from interface: HttpClientTransport

Creates a new, transport-specific, HttpDestination object.

HttpDestination controls the destination-connection cardinality: protocols like HTTP have 1-N cardinality, while multiplexed protocols like HTTP/2 have a 1-1 cardinality.

Parameters:

origin - the destination origin

Returns:

a new, transport-specific, HttpDestination object

connect

public void connect(SocketAddress address,
 Map<String,Object> context)

Description copied from interface: HttpClientTransport

Establishes a physical connection to the given address.

Parameters:

address - the address to connect to

context - the context information to establish the connection

connect

protected void connect(Transport transport,
 SslContextFactory.Client sslContextFactory,
 SocketAddress address,
 Session.Listener listener,
 Promise<Session> promise,
 Map<String,Object> context)

newConnection

public Connection newConnection(EndPoint endPoint,
 Map<String,Object> context)
                         throws IOException

Parameters:

endPoint - the EndPoint to link the newly created connection to

context - the context data to create the connection

Returns:

a new Connection

Throws:

IOException - if the connection cannot be created

newConnection

protected Connection newConnection(Destination destination,
 Session session,
 HTTP2Connection connection)

onClose

protected void onClose(Connection connection,
 GoAwayFrame frame)