Class JettyHttpClientTransport

All Implemented Interfaces:
Transport

public class JettyHttpClientTransport extends AbstractHttpClientTransport
  • 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.api.Request request)
    • customize

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