Package com.linkedin.r2.transport.http.server

Examples of com.linkedin.r2.transport.http.server.HttpServerFactory

180
181
182
183
184
185
186
187
188
189
190
    TransportDispatcher dispatcher = new DelegatingTransportDispatcher(new RestLiServer(config,
                                                                                        resourceFactory,
                                                                                        engine));

    final FilterChain fc = FilterChains.empty().addLast(new SimpleLoggingFilter());
    final HttpServer server = new HttpServerFactory(fc).createServer(port,
                                                               HttpServerFactory.DEFAULT_CONTEXT_PATH,
                                                               NUM_THREADS,
                                                               dispatcher,
                                                               enableAsync,
                                                               enableAsync ? ASYNC_TIMEOUT : -1);
View Full Code Here
79
80
81
82
83
84
85
    // using InjectMockResourceFactory to keep examples spring-free
    final ResourceFactory factory = new InjectMockResourceFactory(beanProvider);

    final TransportDispatcher dispatcher = new DelegatingTransportDispatcher(new RestLiServer(config, factory));
    return new HttpServerFactory(FilterChains.empty()).createServer(SERVER_PORT, dispatcher);
  }
View Full Code Here
52
53
54
55
56
57
58
59
    return createHttpServer(HTTP_PORT, filters);
  }

  public static Server createHttpServer(int port, FilterChain filters)
  {
    return new HttpServerFactory(filters)
            .createServer(port, createDispatcher());
  }
View Full Code Here
28
29
30
31
32
33
34
public class HttpPerfServerFactory extends AbstractPerfServerFactory
{
  @Override
  protected Server createServer(int port, TransportDispatcher dispatcher)
  {
    return new HttpServerFactory().createServer(port, dispatcher);
  }
View Full Code Here
35
36
37
38
39
40
41
42
43
    final URI relativeUri = MiscUtil.getUri(DEFAULT_RELATIVE_URI);
    final TransportDispatcher dispatcher = new TransportDispatcherBuilder()
    .addRestHandler(relativeUri, new RestEchoServer(new EchoServiceImpl()))
    .build();

    final Server server = new HttpServerFactory().createServer(port, dispatcher);
    //final Server server = new HttpServerFactory().createServer(port, createDispatcher(relativeUri));
    server.start();
  }
View Full Code Here
381
382
383
384
385
386
387
    return null;
  }

  private Server getHttpServer(TransportDispatcher dispatcher)
  {
    return new HttpServerFactory().createServer(_port, dispatcher);
  }
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
    TransportDispatcher dispatcher = new DelegatingTransportDispatcher(new RestLiServer(config, factory, engine));

    final FilterChain fc = FilterChains.empty().addLast(new ServerCompressionFilter(supportedCompression))
        .addLast(new SimpleLoggingFilter());
    return new HttpServerFactory(fc).createServer(port,
                                                  HttpServerFactory.DEFAULT_CONTEXT_PATH,
                                                  HttpServerFactory.DEFAULT_THREAD_POOL_SIZE,
                                                  dispatcher,
                                                  useAsyncServletApi,
                                                  asyncTimeOut);
View Full Code Here
61
62
63
64
65
66
67
68
    final TransportDispatcher dispatcher = new TransportDispatcherBuilder()
            .addRestHandler(URI.create("/error"), new ErrorHandler())
            .addRestHandler(URI.create("/foobar"), new FoobarHandler())
            .build();

    _server = new HttpServerFactory().createServer(PORT, dispatcher);
    _server.start();
  }
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
    final RestLiServer restServer = new RestLiServer(config, new PrototypeResourceFactory(), engine);
    final TransportDispatcher dispatcher = new DelegatingTransportDispatcher(restServer);
    System.err.println("Jetty threadPoolSize: " + threadPoolSize);
    _server =
        new HttpServerFactory(FilterChains.empty()).createServer(_port,
                                                                 _contextPath,
                                                                 _threadPoolSize,
                                                                 dispatcher,
                                                                 useAsyncserverApi,
                                                                 asyncTimeout);
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
  public RestliHttpRequestHandler(RestLiConfig config,
                                  SpringInjectResourceFactory injectResourceFactory,
                                  FilterChain filterChain)
  {
    _r2Servlet = new RAPServlet(
        new FilterChainDispatcher(
            new DelegatingTransportDispatcher(
                new RestLiServer(config, injectResourceFactory)),
            filterChain
        )
View Full Code Here
TOP

Related Classes of com.linkedin.r2.transport.http.server.HttpServerFactory

  • com.example.d2.client.BigDataClientExample
  • com.example.d2.client.CacheClientExample
  • com.example.d2.client.EmailClientExample
  • com.example.d2.client.ExampleD2Client
  • com.example.d2.client.ProfileClientExample
  • com.example.fortune.inject.FortunesGuiceServletConfig
  • com.example.fortune.RestLiFortunesClient
  • com.linkedin.d2.balancer.clients.DynamicClientTest
  • com.linkedin.d2.balancer.clients.TrackerClientTest
  • com.linkedin.d2.balancer.simple.SimpleLoadBalancerStrawMan
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.