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

RepositoryConfiguration.getClustering介绍

暂无

代码示例

代码示例来源：origin: ModeShape/modeshape

@Override
public Channel getChannel(String name) throws Exception {
  LOG.debugv("getting JGroups channel named '{0}'", name);
  final ChannelFactory channelFactory = channelFactoryInjector.getOptionalValue();
  if (channelFactory != null) {
    LOG.debugv("JGroups configured to use server subsystem stack");
    // there is a cluster-stack attribute configured, so use that
    return channelFactory.createChannel(name);
  }
  // there is no cluster stack, so use a configured XML file 
  String clusterConfig = repositoryConfiguration.getClustering().getConfiguration();
  assert clusterConfig != null;
  LOG.debugv("reading JGroups config '{0}'", clusterConfig);
  InputStream configStream = new FileInputStream(clusterConfig);
  XmlConfigurator configurator = XmlConfigurator.getInstance(configStream);
  return new JChannel(configurator);
}

代码示例来源：origin: ModeShape/modeshape

@Test
public void shouldNotEnableClusteringIfMissingDocument() throws Exception {
  RepositoryConfiguration config = RepositoryConfiguration.read("{ 'name' = 'nm', 'storage' : {}}");
  RepositoryConfiguration.Clustering clusteringConfiguration = config.getClustering();
  assertFalse(clusteringConfiguration.isEnabled());
}

代码示例来源：origin: ModeShape/modeshape

@Test
public void shouldAllowClusteringToBeConfigured() throws Exception {
  String clusterName = "testCluster";
  String channelConfig = "someConfig";
  RepositoryConfiguration config = RepositoryConfiguration.read("{ \"clustering\" : {\"clusterName\":\"" + clusterName
                                 + "\", \"configuration\": \"" + channelConfig
                                 + "\"} }");
  RepositoryConfiguration.Clustering clusteringConfiguration = config.getClustering();
  assertTrue(clusteringConfiguration.isEnabled());
  assertEquals(clusterName, clusteringConfiguration.getClusterName());
  assertEquals(channelConfig, clusteringConfiguration.getConfiguration());
}

代码示例来源：origin: ModeShape/modeshape

@Test
public void shouldUseDefaultClusteringValues() throws Exception {
  RepositoryConfiguration config = RepositoryConfiguration.read("{ \"clustering\" : {} }");
  RepositoryConfiguration.Clustering clusteringConfiguration = config.getClustering();
  assertTrue(clusteringConfiguration.isEnabled());
  assertEquals(Default.CLUSTER_NAME, clusteringConfiguration.getClusterName());
  assertEquals(Default.CLUSTER_CONFIG, clusteringConfiguration.getConfiguration());
}

代码示例来源：origin: ModeShape/modeshape

this.connectors = new Connectors(this, config.getFederation(), problems);                    
RepositoryConfiguration.Clustering clustering = config.getClustering();
long lockTimeoutMillis = config.getLockTimeoutMillis();
if (clustering.isEnabled()) {

代码示例来源：origin: org.fcrepo/modeshape-jcr

this.connectors = new Connectors(this, config.getFederation(), problems);                    
RepositoryConfiguration.Clustering clustering = config.getClustering();
long lockTimeoutMillis = config.getLockTimeoutMillis();
if (clustering.isEnabled()) {