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

Group.start介绍

[英]Start this member
[中]启动此成员

代码示例

代码示例来源：origin: io.fabric8/fabric-groups

protected void doStart() {
  if (group != null) {
    group.start();
  }
}

代码示例来源：origin: jboss-fuse/fabric8

protected void doStart() {
  if (group != null) {
    group.start();
  }
}

代码示例来源：origin: io.fabric8/fabric-camel

@Override
public void doStart() throws Exception {
  super.doStart();
  group.start();
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public void doStart() throws Exception {
  super.doStart();
  group.start();
}

代码示例来源：origin: io.fabric8/fabric-camel

@Override
public void start() throws Exception {
  super.start();
  if (loadBalancer == null) {
    loadBalancer = createLoadBalancer();
  }
  group.start();
}

代码示例来源：origin: io.fabric8/fabric-partition

public void start() {
  group.add(this);
  repository.addListener(this);
  group.start();
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public void start() throws Exception {
  super.start();
  if (loadBalancer == null) {
    loadBalancer = createLoadBalancer();
  }
  group.start();
}

代码示例来源：origin: jboss-fuse/fabric8

private void activateInternal() {
  group = new ZooKeeperGroup<InfluxDBNode>(curator.get(), INFLUXDB_CLUSTER_PATH, InfluxDBNode.class);
  group.add(this);
  group.start();
}

代码示例来源：origin: io.fabric8.insight/insight-influxdb-metrics

private void activateInternal() {
  group = new ZooKeeperGroup<InfluxDBNode>(curator.get(), INFLUXDB_CLUSTER_PATH, InfluxDBNode.class);
  group.add(this);
  group.start();
}

代码示例来源：origin: jboss-fuse/fabric8

public void start() throws Exception {
  factory = ManagedGroupFactoryBuilder.create(curator, getClass().getClassLoader(), this);
  group = factory.createGroup("/fabric/camel-clusters/" + groupName, CamelNodeState.class);
  group.update(createState());
  group.add(this);
  group.start();
  info("Camel context %s is waiting to become the master", groupName);
}

代码示例来源：origin: io.fabric8/fabric-git

@Activate
void activate() throws IOException {
  activateComponent();
  group = new ZooKeeperGroup<GitNode>(curator.get(), ZkPath.GIT.getPath(), GitNode.class);
  group.add(this);
  group.start();
}

代码示例来源：origin: io.fabric8/fabric-camel

public void start() throws Exception {
  factory = ManagedGroupFactoryBuilder.create(curator, getClass().getClassLoader(), this);
  group = factory.createGroup("/fabric/camel-clusters/" + groupName, CamelNodeState.class);
  group.update(createState());
  group.add(this);
  group.start();
  info("Camel context %s is waiting to become the master", groupName);
}

代码示例来源：origin: io.fabric8/fabric-camel

@Override
protected void doStart() throws Exception {
  super.doStart();
  singleton.start();
  LOG.debug("Attempting to become master for endpoint: " + endpoint + " in " + endpoint.getCamelContext() + " with singletonID: " + endpoint.getSingletonId());
  singleton.update(createNodeState());
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
protected void doStart() throws Exception {
  super.doStart();
  singleton.start();
  LOG.debug("Attempting to become master for endpoint: " + endpoint + " in " + endpoint.getCamelContext() + " with singletonID: " + endpoint.getSingletonId());
  singleton.update(createNodeState());
}

代码示例来源：origin: jboss-fuse/fabric8

public synchronized Group getGroup() throws Exception {
   if (group == null) {
     group = new ZooKeeperGroup<CxfNodeState>(getCurator(), zkRoot + fabricPath, CxfNodeState.class, new NamedThreadFactory("zkgroup-lb-feature"));
     group.start();
   }
  return group;
}

代码示例来源：origin: io.fabric8.insight/insight-elasticsearch-discovery

@Override
public CuratorFramework addingService(ServiceReference<CuratorFramework> reference) {
  CuratorFramework curator = context.getService(reference);
  try {
    logger.debug("CuratorFramework found, starting group");
    GroupFactory factory = new ZooKeeperGroupFactory(curator);
    singleton = factory.createGroup("/fabric/registry/clusters/elasticsearch/" + clusterName.value(), ESNode.class);
    singleton.add(this);
    singleton.update(new ESNode(clusterName.value(), localNode, false));
    singleton.start();
  } catch (Exception e) {
    LOG.error("Error starting group", e);
  }
  return curator;
}

代码示例来源：origin: jboss-fuse/fabric8

@Activate
void activate() throws IOException {
  activateComponent();
  group = new ZooKeeperGroup<GitNode>(curator.get(), ZkPath.GIT.getPath(), GitNode.class, new NamedThreadFactory("zkgroup-gml"));
  group.add(this);
  group.start();
}

代码示例来源：origin: io.fabric8/fabric-openshift

@Activate
void activate(Map<String, ?> configuration) {
  //this.realm =  properties != null && properties.containsKey(REALM_PROPERTY_NAME) ? properties.get(REALM_PROPERTY_NAME) : DEFAULT_REALM;
  //this.role =  properties != null && properties.containsKey(ROLE_PROPERTY_NAME) ? properties.get(ROLE_PROPERTY_NAME) : DEFAULT_ROLE;
  group = new ZooKeeperGroup(curator.get(), ZkPath.OPENSHIFT.getPath(), ControllerNode.class);
  group.add(this);
  group.update(createState());
  group.start();
  activateComponent();
}

代码示例来源：origin: jboss-fuse/fabric8

@Activate
void activate() {
  CuratorFramework curator = this.curator.get();
  enableMasterZkCache(curator);
  group = new ZooKeeperGroup<AutoScalerNode>(curator, ZkPath.AUTO_SCALE_CLUSTER.getPath(), AutoScalerNode.class);
  group.add(this);
  group.update(createState());
  group.start();
  activateComponent();
}

代码示例来源：origin: io.fabric8/fabric-git-server

@Activate
void activate(Map<String, ?> configuration) throws Exception {
  RuntimeProperties sysprops = runtimeProperties.get();
  realm = getConfiguredRealm(sysprops, configuration);
  role = getConfiguredRole(sysprops, configuration);
  dataPath = sysprops.getDataPath();
  activateComponent();
  group = new ZooKeeperGroup<GitNode>(curator.get(), ZkPath.GIT.getPath(), GitNode.class);
  group.add(this);
  group.update(createState());
  group.start();
}