Class JettyHttpClientTransport

java.lang.Object

org.cometd.common.AbstractTransport

org.cometd.client.transport.ClientTransport

org.cometd.client.transport.HttpClientTransport

org.cometd.client.http.common.AbstractHttpClientTransport

org.cometd.client.http.jetty.JettyHttpClientTransport

All Implemented Interfaces:

Transport

public class JettyHttpClientTransport
extends AbstractHttpClientTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JettyHttpClientTransport.Factory

Nested classes/interfaces inherited from class org.cometd.client.transport.ClientTransport

ClientTransport.FailureHandler, ClientTransport.FailureInfo

Field Summary

Fields inherited from class org.cometd.client.http.common.AbstractHttpClientTransport

NAME, PREFIX

Fields inherited from class org.cometd.client.transport.ClientTransport

JSON_CONTEXT_OPTION, MAX_MESSAGE_SIZE_OPTION, MAX_NETWORK_DELAY_OPTION, MAX_SEND_BAYEUX_MESSAGE_SIZE_OPTION, SCHEDULER_OPTION, URL_OPTION

Constructor Summary

Constructors

Constructor	Description
JettyHttpClientTransport(String url, Map<String,Object> options, ScheduledExecutorService scheduler, org.eclipse.jetty.client.HttpClient httpClient)
JettyHttpClientTransport(String url, Map<String,Object> options, org.eclipse.jetty.client.HttpClient httpClient)
JettyHttpClientTransport(Map<String,Object> options, org.eclipse.jetty.client.HttpClient httpClient)

Method Summary

Modifier and Type	Method	Description
void	abort(Throwable failure)	Aborts this transport, usually by cancelling all pending Bayeux messages that require a response, such as /meta/connects, without waiting for a response.
protected void	customize(org.eclipse.jetty.client.Request request)
protected void	customize(org.eclipse.jetty.client.Request request, Promise<org.eclipse.jetty.client.Request> promise)
protected org.eclipse.jetty.client.HttpClient	getHttpClient()
void	init()
void	send(TransportListener listener, List<Message.Mutable> messages)

Methods inherited from class org.cometd.client.http.common.AbstractHttpClientTransport

accept, calculateMaxNetworkDelay, getAdvice, getMaxMessageSize, isAborted, isAppendMessageType, newRequestURI, processResponseContent, processResponseMessages, processWrongResponseCode, setAdvice, terminate

Methods inherited from class org.cometd.client.transport.HttpClientTransport

getCookies, getHttpCookieStore, setHttpCookieStore, storeCookies

Methods inherited from class org.cometd.client.transport.ClientTransport

generateJSON, getJSONContextClient, getMaxNetworkDelay, getScheduler, getURL, initScheduler, parseMessages, setMaxNetworkDelay, setURL, shutdownScheduler

Methods inherited from class org.cometd.common.AbstractTransport

getName, getOption, getOption, getOption, getOption, getOption, getOptionNames, getOptionPrefix, setOption, setOptionPrefix

Methods inherited from class java.lang.Object

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

Constructor Details

JettyHttpClientTransport

public JettyHttpClientTransport(Map<String,Object> options,
 org.eclipse.jetty.client.HttpClient httpClient)

JettyHttpClientTransport

public JettyHttpClientTransport(String url,
 Map<String,Object> options,
 org.eclipse.jetty.client.HttpClient httpClient)

JettyHttpClientTransport

public JettyHttpClientTransport(String url,
 Map<String,Object> options,
 ScheduledExecutorService scheduler,
 org.eclipse.jetty.client.HttpClient httpClient)

Method Details

getHttpClient

protected org.eclipse.jetty.client.HttpClient getHttpClient()

init

public void init()

Overrides:

init in class AbstractHttpClientTransport

abort

public void abort(Throwable failure)

Description copied from class: ClientTransport

Aborts this transport, usually by cancelling all pending Bayeux messages that require a response, such as /meta/connects, without waiting for a response.

Overrides:

abort in class AbstractHttpClientTransport

Parameters:

failure - the cause of the abort

See Also:

• BayeuxClient.abort()

send

public void send(TransportListener listener,
 List<Message.Mutable> messages)

Specified by:

send in class ClientTransport

customize

protected void customize(org.eclipse.jetty.client.Request request)

customize

protected void customize(org.eclipse.jetty.client.Request request,
 Promise<org.eclipse.jetty.client.Request> promise)