本文整理汇总了Java中org.neo4j.kernel.lifecycle.Lifecycle类的典型用法代码示例。如果您正苦于以下问题：Java Lifecycle类的具体用法？Java Lifecycle怎么用？Java Lifecycle使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Lifecycle类属于org.neo4j.kernel.lifecycle包，在下文中一共展示了Lifecycle类的10个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: newInstance
import org.neo4j.kernel.lifecycle.Lifecycle; //导入依赖的package包/类
@Override
public Lifecycle newInstance(KernelContext kernelContext, final Dependencies dependencies) throws Throwable {
return new LifecycleAdapter() {
private Server server;
@Override
public void start() throws Throwable {
server = ServerBuilder.forPort(9999).addService(new Neo4jGRPCService(dependencies.getGraphDatabaseService())).build();
server.start();
System.out.println("Started gRPC Server.");
}
@Override
public void shutdown() throws Throwable {
server.shutdown();
}
};
}
开发者ID:maxdemarzi，项目名称:neo_grpc，代码行数:20，代码来源:RegistergRPCExtensionFactory.java
示例2: newInstance
import org.neo4j.kernel.lifecycle.Lifecycle; //导入依赖的package包/类
@Override
public Lifecycle newInstance(KernelContext context, Dependencies dependencies) throws Throwable {
GraphDatabaseService graphDatabaseService = dependencies.getGraphDatabaseService();
Config config = dependencies.getConfig();
Setting<HostnamePort> hostnamePort = setting("websocket_host", HOSTNAME_PORT, "0.0.0.0:8765");
Setting<List<String>> packageNames = setting("websocket_packages", STRING_LIST, "");
Setting<String> managementPath = setting("websocket_management_path", STRING, "/ws/management");
Setting<String> commandPath = setting("websocket_data_path", STRING, "/ws/data");
ClusterMemberEvents clusterMemberEvents = null;
if (graphDatabaseService instanceof HighlyAvailableGraphDatabase) {
logger.info("[newInstance] cluster installation");
clusterMemberEvents = dependencies.getClusterMemberEvents();
}
return new WebsocketsKernelExtension(
graphDatabaseService, clusterMemberEvents, config.get(packageNames), config.get(hostnamePort),
config.get(managementPath), config.get(commandPath));
}
开发者ID:owetterau，项目名称:neo4j-websockets，代码行数:22，代码来源:WebsocketsKernelExtensionFactory.java
示例3: createAlwaysInitiallyPopulatingLuceneIndexFactory
import org.neo4j.kernel.lifecycle.Lifecycle; //导入依赖的package包/类
private KernelExtensionFactory<?> createAlwaysInitiallyPopulatingLuceneIndexFactory()
{
return new KernelExtensionFactory<LuceneSchemaIndexProviderFactory.Dependencies>(
LuceneSchemaIndexProviderFactory.PROVIDER_DESCRIPTOR.getKey() )
{
@Override
public Lifecycle newInstance( KernelContext context, LuceneSchemaIndexProviderFactory.Dependencies dependencies )
throws Throwable
{
return new LuceneSchemaIndexProvider( fs.get(), ignoreCloseDirectoryFactory, context.storeDir() )
{
@Override
public InternalIndexState getInitialState( long indexId )
{
return InternalIndexState.POPULATING;
}
};
}
};
}
开发者ID:neo4j-contrib，项目名称:neo4j-lucene5-index，代码行数:21，代码来源:LuceneIndexRecoveryIT.java
示例4: createLuceneIndexFactory
import org.neo4j.kernel.lifecycle.Lifecycle; //导入依赖的package包/类
private KernelExtensionFactory<?> createLuceneIndexFactory()
{
return new KernelExtensionFactory<LuceneSchemaIndexProviderFactory.Dependencies>(
LuceneSchemaIndexProviderFactory.PROVIDER_DESCRIPTOR.getKey() )
{
@Override
public Lifecycle newInstance( KernelContext context, LuceneSchemaIndexProviderFactory.Dependencies dependencies )
throws Throwable
{
return new LuceneSchemaIndexProvider( fs.get(), ignoreCloseDirectoryFactory, context.storeDir() )
{
@Override
public int compareTo( SchemaIndexProvider o )
{
return 1;
}
};
}
};
}
开发者ID:neo4j-contrib，项目名称:neo4j-lucene5-index，代码行数:21，代码来源:LuceneIndexRecoveryIT.java
示例5: newInstance
import org.neo4j.kernel.lifecycle.Lifecycle; //导入依赖的package包/类
@Override
public Lifecycle newInstance(KernelContext kernelContext, final Dependencies dependencies) throws Throwable {
return new LifecycleAdapter() {
private MyTransactionEventHandler handler;
private ExecutorService executor;
@Override
public void start() throws Throwable {
executor = Executors.newFixedThreadPool(2);
handler = new MyTransactionEventHandler(dependencies.getGraphDatabaseService(), executor);
dependencies.getGraphDatabaseService().registerTransactionEventHandler(handler);
}
@Override
public void shutdown() throws Throwable {
executor.shutdown();
dependencies.getGraphDatabaseService().unregisterTransactionEventHandler(handler);
}
};
}
开发者ID:maxdemarzi，项目名称:neo_listens，代码行数:22，代码来源:RegisterTransactionEventHandlerExtensionFactory.java
示例6: newInstance
import org.neo4j.kernel.lifecycle.Lifecycle; //导入依赖的package包/类
@Override
public Lifecycle newInstance(KernelContext context, Dependencies dependencies) throws Throwable {
return new LifecycleAdapter() {
@Override
public void init() throws Throwable {
final String username = dependencies.getConfig().get(setting( "extension.csv.http.username", STRING, (String)null ));
final String password = dependencies.getConfig().get(setting( "extension.csv.http.password", STRING, (String)null ));
Authenticator.setDefault(new Authenticator() {
@Override
protected PasswordAuthentication getPasswordAuthentication() {
if (getRequestorType().equals(RequestorType.SERVER) &&
(getRequestingProtocol().equals("http") || getRequestingProtocol().equals("https")) &&
getRequestingHost().equals("localhost")) {
return new PasswordAuthentication(username, password.toCharArray());
} else {
return null;
}
}
});
}
};
}
开发者ID:sarmbruster，项目名称:neo4j-csv-firehose，代码行数:25，代码来源:AuthenticatorKernelExtensionFactory.java
示例7: newInstance
import org.neo4j.kernel.lifecycle.Lifecycle; //导入依赖的package包/类
@Override
public Lifecycle newInstance(KernelContext context, Dependencies dependencies) throws Throwable {
return new LifecycleAdapter() {
@Override
public void init() throws Throwable {
GraphDatabaseFacade facade = dependencies.getGraphDatabaseFacade();
PlatformModule platformModule = facade.platformModule;
Field field = platformModule.getClass().getField("urlAccessRule");
field.setAccessible(true);
field.set(platformModule, URLAccessRules.alwaysPermitted());
}
};
}
开发者ID:sarmbruster，项目名称:neo4j-csv-firehose，代码行数:14，代码来源:FuckUrlAccessValidationExtensionFactory.java
示例8: newKernelExtension
import org.neo4j.kernel.lifecycle.Lifecycle; //导入依赖的package包/类
@Override
public Lifecycle newKernelExtension(Dependencies dependencies) throws Throwable {
Config config = dependencies.getConfig();
Boolean enabled = config.get(ZmqSettings.zmq_enabled);
if (enabled) {
return new ZmqKernelExtension(dependencies);
} else {
return new FakeLifecycle();
}
}
开发者ID:TinderBackend，项目名称:neo4j-zmq-extension，代码行数:11，代码来源:ZmqKernelExtensionFactory.java
示例9: newInstance
import org.neo4j.kernel.lifecycle.Lifecycle; //导入依赖的package包/类
@Override
public Lifecycle newInstance( KernelContext context, Dependencies dependencies ) throws Throwable
{
return new LuceneKernelExtension( context.storeDir(), dependencies.getConfig(), dependencies.getIndexStore(),
context.fileSystem(), dependencies.getIndexProviders() );
}
开发者ID:neo4j-contrib，项目名称:neo4j-lucene5-index，代码行数:7，代码来源:LuceneKernelExtensionFactory.java
示例10: newKernelExtension
import org.neo4j.kernel.lifecycle.Lifecycle; //导入依赖的package包/类
@Override
public Lifecycle newKernelExtension( Dependencies dependencies ) throws Throwable {
return new TimestampKernelExtension(dependencies.getDatabase(), this.setupAutoIndexing, this.addCreated, this.customPropertyHandlers);
}
开发者ID:ttiurani，项目名称:neo4j-timestamp，代码行数:5，代码来源:TimestampKernelExtensionFactory.java
注：本文中的org.neo4j.kernel.lifecycle.Lifecycle类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论