com.qwazr.server.GenericServer.of()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(8.7k)|赞(0)|评价(0)|浏览(68)

本文整理了Java中com.qwazr.server.GenericServer.of()方法的一些代码示例,展示了GenericServer.of()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。GenericServer.of()方法的具体详情如下:
包路径:com.qwazr.server.GenericServer
类名称:GenericServer
方法名:of

GenericServer.of介绍

暂无

代码示例

代码示例来源:origin: com.qwazr/qwazr-server

public static GenericServerBuilder of(ServerConfiguration config, ExecutorService executorService,
    ClassLoader classLoader) {
  return of(config, executorService, classLoader, null);
}

代码示例来源:origin: com.qwazr/qwazr-server

public static GenericServerBuilder of(ServerConfiguration config) {
  return of(config, null);
}

代码示例来源:origin: com.qwazr/qwazr-server

public static GenericServerBuilder of(ServerConfiguration config, ExecutorService executorService) {
  return of(config, executorService, null);
}

代码示例来源:origin: com.qwazr/qwazr-graph

private GraphServer(final ServerConfiguration configuration) throws IOException, URISyntaxException {
  final ExecutorService executorService = Executors.newCachedThreadPool();
  final GenericServerBuilder builder = GenericServer.of(configuration, executorService);
  final Set<String> services = new HashSet<>();
  services.add(ClusterServiceInterface.SERVICE_NAME);
  services.add(GraphServiceInterface.SERVICE_NAME);
  final ApplicationBuilder webServices = ApplicationBuilder.of("/*").classes(RestApplication.JSON_CLASSES).
      singletons(new WelcomeShutdownService());
  final ClusterManager clusterManager =
      new ClusterManager(executorService, configuration).registerProtocolListener(builder, services);
  webServices.singletons(clusterManager.getService());
  graphManager = new GraphManager(executorService,
      GraphManager.checkGraphesDirectory(configuration.dataDirectory.toPath())).registerContextAttribute(
      builder).registerWebService(webServices);
  builder.getWebServiceContext().jaxrs(webServices);
  server = builder.build();
}

代码示例来源:origin: com.qwazr/qwazr-cluster

private ClusterServer(final ServerConfiguration serverConfiguration) throws IOException {
  final ExecutorService executorService = Executors.newCachedThreadPool();
  final GenericServerBuilder builder = GenericServer.of(serverConfiguration, executorService);
  final ApplicationBuilder webServices = ApplicationBuilder.of("/*")
      .classes(RestApplication.JSON_CLASSES)
      .singletons(new WelcomeShutdownService());
  final Set<String> services = new HashSet<>();
  services.add(ClusterServiceInterface.SERVICE_NAME);
  clusterManager =
      new ClusterManager(executorService, serverConfiguration).registerProtocolListener(builder, services);
  webServices.singletons(clusterManager.getService());
  builder.getWebServiceContext().jaxrs(webServices);
  server = builder.build();
  serviceBuilder = new ClusterServiceBuilder(clusterManager);
}

代码示例来源:origin: com.qwazr/qwazr-extractor

private ExtractorServer(final ServerConfiguration configuration) throws IOException {
  final ExecutorService executorService = Executors.newCachedThreadPool();
  final GenericServerBuilder builder = GenericServer.of(configuration, executorService);
  final Set<String> services = new HashSet<>();
  services.add(ClusterServiceInterface.SERVICE_NAME);
  services.add(ExtractorServiceInterface.SERVICE_NAME);
  final ApplicationBuilder webServices = ApplicationBuilder.of("/*").classes(RestApplication.JSON_CLASSES).
      singletons(new WelcomeShutdownService());
  final ClusterManager clusterManager =
      new ClusterManager(executorService, configuration).registerProtocolListener(builder, services);
  webServices.singletons(clusterManager.getService());
  final ExtractorManager extractorManager = new ExtractorManager().registerServices();
  webServices.singletons(extractorManager.getService());
  builder.getWebServiceContext().jaxrs(webServices);
  server = builder.build();
}

代码示例来源:origin: com.qwazr/qwazr-search

private SearchServer(final ServerConfiguration configuration) throws IOException {
  final ExecutorService executorService = Executors.newCachedThreadPool();
  final GenericServerBuilder builder = GenericServer.of(configuration, executorService);
  final Set<String> services = new HashSet<>();
  services.add(ClusterServiceInterface.SERVICE_NAME);
  services.add(IndexServiceInterface.SERVICE_NAME);
  final ApplicationBuilder webServices = ApplicationBuilder.of("/*").classes(RestApplication.JSON_CLASSES).
      singletons(new WelcomeShutdownService());
  clusterManager = new ClusterManager(executorService, configuration).registerProtocolListener(builder, services);
  webServices.singletons(clusterManager.getService());
  indexManager =
      new IndexManager(IndexManager.checkIndexesDirectory(configuration.dataDirectory), executorService);
  builder.shutdownListener(server -> indexManager.close());
  webServices.singletons(indexManager.getService());
  builder.getWebServiceContext().jaxrs(webServices);
  serviceBuilder = new IndexServiceBuilder(clusterManager, indexManager);
  server = builder.build();
}

代码示例来源:origin: com.qwazr/qwazr-scripts

private ScriptsServer(final ServerConfiguration configuration) throws IOException {
  final ExecutorService executorService = Executors.newCachedThreadPool();
  final GenericServerBuilder builder = GenericServer.of(configuration, executorService);
  final Set<String> services = new HashSet<>();
  services.add(ClusterServiceInterface.SERVICE_NAME);
  services.add(ScriptServiceInterface.SERVICE_NAME);
  services.add(LibraryServiceInterface.SERVICE_NAME);
  final ApplicationBuilder webServices = ApplicationBuilder.of("/*")
      .classes(RestApplication.JSON_CLASSES)
      .singletons(new WelcomeShutdownService());
  final ClusterManager clusterManager =
      new ClusterManager(executorService, configuration).registerProtocolListener(builder, services);
  webServices.singletons(clusterManager.getService());
  final LibraryManager libraryManager =
      new LibraryManager(configuration.dataDirectory, configuration.getEtcFiles(), null);
  builder.shutdownListener(server -> libraryManager.close());
  final LibraryServiceInterface libraryService = libraryManager.getService();
  webServices.singletons(libraryService);
  final ScriptManager scriptManager =
      new ScriptManager(executorService, clusterManager, libraryService, configuration.dataDirectory);
  webServices.singletons(scriptManager.getService());
  scriptServiceBuilder = new ScriptServiceBuilder(executorService, clusterManager, scriptManager);
  builder.getWebServiceContext().jaxrs(webServices);
  server = builder.build();
}

代码示例来源:origin: com.qwazr/qwazr-store

public StoreServer(final ServerConfiguration configuration) throws IOException, URISyntaxException {
  final ExecutorService executorService = Executors.newCachedThreadPool();
  final GenericServerBuilder serverBuilder = GenericServer.of(configuration, executorService);
  final Set<String> services = new HashSet<>();
  services.add(ClusterServiceInterface.SERVICE_NAME);
  services.add(StoreServiceInterface.SERVICE_NAME);
  final ApplicationBuilder webServices = ApplicationBuilder.of("/*")
      .classes(RestApplication.JSON_CLASSES)
      .singletons(new WelcomeShutdownService());
  final ClusterManager clusterManager =
      new ClusterManager(executorService, configuration).registerProtocolListener(serverBuilder, services);
  webServices.singletons(clusterManager.getService());
  final ScriptManager scriptManager =
      new ScriptManager(executorService, clusterManager, null, configuration.dataDirectory);
  final StoreManager storeManager = new StoreManager(executorService, scriptManager,
      StoreManager.checkStoreDirectory(configuration.dataDirectory));
  webServices.singletons(storeManager.getService());
  serverBuilder.shutdownListener(server -> storeManager.close());
  storeServiceBuilder = new StoreServiceBuilder(clusterManager, storeManager, executorService);
  serverBuilder.getWebServiceContext().jaxrs(webServices);
  server = serverBuilder.build();
}

代码示例来源:origin: com.qwazr/qwazr-database

public TableServer(final ServerConfiguration serverConfiguration) throws IOException {
  final TableSingleton tableSingleton = new TableSingleton(serverConfiguration.dataDirectory, null);
  final ExecutorService executorService = tableSingleton.getExecutorService();
  final GenericServerBuilder builder = GenericServer.of(serverConfiguration, executorService);
  final ApplicationBuilder webServices = ApplicationBuilder.of("/*").classes(RestApplication.JSON_CLASSES).
      singletons(new WelcomeShutdownService());
  final Set<String> services = new HashSet<>();
  services.add(ClusterServiceInterface.SERVICE_NAME);
  services.add(TableServiceInterface.SERVICE_NAME);
  final ClusterManager clusterManager =
      new ClusterManager(executorService, serverConfiguration).registerProtocolListener(builder, services);
  webServices.singletons(clusterManager.getService());
  final TableManager tableManager = tableSingleton.getTableManager();
  webServices.singletons(tableManager.getService());
  serviceBuilder = new TableServiceBuilder(clusterManager, tableManager);
  builder.getWebServiceContext().jaxrs(webServices);
  builder.shutdownListener(server -> tableSingleton.close());
  server = builder.build();
}

代码示例来源:origin: com.qwazr/qwazr-webapps

final GenericServerBuilder builder = GenericServer.of(configuration, executorService);

相关文章

微信公众号

最新文章

更多