本文整理了Java中com.qwazr.server.GenericServer.of()
方法的一些代码示例,展示了GenericServer.of()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。GenericServer.of()
方法的具体详情如下:
包路径:com.qwazr.server.GenericServer
类名称: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);
内容来源于网络,如有侵权,请联系作者删除!