Examples of ConfigStore

Examples of com.cloudera.flume.master.ConfigStore

279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
    FlumeNode node = new FlumeNode(cfg);
    node.start();

    // avoiding gossip ack manager until it shuts down cleanly.
    ConfigStore cfgStore = FlumeMaster.createConfigStore(cfg);
    FlumeMaster fm = new FlumeMaster(new CommandManager(), new ConfigManager(
        cfgStore), new StatusManager(), new MasterAckManager(), cfg);

    assertEquals(0, fm.getKnownNodes().size());
    fm.serve();
    LOG.info("flume master 1 open ");
    while (fm.getKnownNodes().size() == 0) {
      Clock.sleep(1000);
    }
    fm.shutdown();
    LOG.info("flume master 1 closed");

    ConfigStore cfgStore2 = FlumeMaster.createConfigStore(cfg);
    FlumeMaster fm2 = new FlumeMaster(new CommandManager(), new ConfigManager(
        cfgStore2), new StatusManager(), new MasterAckManager(), cfg);
    assertEquals(0, fm2.getKnownNodes().size());
    fm2.serve();
    LOG.info("flume master 2 open ");
View Full Code Here

Examples of com.cloudera.flume.master.ConfigStore

268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
    FlumeNode node = new FlumeNode(cfg);
    node.start();

    // avoiding gossip ack manager until it shuts down cleanly.
    ConfigStore cfgStore = FlumeMaster.createConfigStore(cfg);
    FlumeMaster fm = new FlumeMaster(new CommandManager(), new ConfigManager(
        cfgStore), new StatusManager(), new MasterAckManager(), cfg);

    assertEquals(0, fm.getKnownNodes().size());
    fm.serve();
    LOG.info("flume master 1 open ");
    while (fm.getKnownNodes().size() == 0) {
      Clock.sleep(1000);
    }
    fm.shutdown();
    LOG.info("flume master 1 closed");

    ConfigStore cfgStore2 = FlumeMaster.createConfigStore(cfg);
    FlumeMaster fm2 = new FlumeMaster(new CommandManager(), new ConfigManager(
        cfgStore2), new StatusManager(), new MasterAckManager(), cfg);
    assertEquals(0, fm2.getKnownNodes().size());
    fm2.serve();
    LOG.info("flume master 2 open ");
View Full Code Here

Examples of com.cloudera.flume.master.ConfigStore

269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
    FlumeNode node = new FlumeNode(cfg);
    node.start();

    // avoiding gossip ack manager until it shuts down cleanly.
    ConfigStore cfgStore = FlumeMaster.createConfigStore(cfg);
    FlumeMaster fm = new FlumeMaster(new CommandManager(), new ConfigManager(
        cfgStore), new StatusManager(), new MasterAckManager(), cfg);

    assertEquals(0, fm.getKnownNodes().size());
    fm.serve();
    LOG.info("flume master 1 open ");
    while (fm.getKnownNodes().size() == 0) {
      Clock.sleep(1000);
    }
    fm.shutdown();
    LOG.info("flume master 1 closed");

    ConfigStore cfgStore2 = FlumeMaster.createConfigStore(cfg);
    FlumeMaster fm2 = new FlumeMaster(new CommandManager(), new ConfigManager(
        cfgStore2), new StatusManager(), new MasterAckManager(), cfg);
    assertEquals(0, fm2.getKnownNodes().size());
    fm2.serve();
    LOG.info("flume master 2 open ");
View Full Code Here

Examples of io.fathom.auto.config.ConfigStore

7
8
9
10
11
12
13
14
15
16
17
18
19
public class AutonomousZookeeperMain {
    private static final Logger log = LoggerFactory.getLogger(AutonomousZookeeperMain.class);

    public static void main(String[] args) throws InterruptedException {
        ConfigStore configStore = ConfigStore.get("zookeeper");

        ZookeeperInstance zk = new ZookeeperInstance(configStore.getConfigRoot());
        try {
            zk.run();
        } catch (Exception e) {
            log.error("Error during ZK run; forcing exit", e);
            System.exit(1);
View Full Code Here

Examples of io.fathom.auto.config.ConfigStore

18
19
20
21
22
23
24
25
26
27
28
    AutoHaproxyMain(ConfigStore configStore) {
        this.configStore = configStore;
    }

    public static void main(String[] args) throws InterruptedException {
        ConfigStore configStore = ConfigStore.get("lb");

        AutoHaproxyMain main = new AutoHaproxyMain(configStore);
        try {
            main.run();
        } catch (Exception e) {
View Full Code Here

Examples of io.fathom.auto.config.ConfigStore

24
25
26
27
28
29
30
31
32
33
34
    }

    public static void main(String[] args) throws InterruptedException {
        File configFile = new File("/var/fathomcloud/bootstrap");

        ConfigStore configStore = null;

        // if (shouldBootstrap) {
        while (true) {
            try {
                ConfigStoreProvider configStoreProvider = null;
View Full Code Here

Examples of io.fathom.auto.config.ConfigStore

18
19
20
21
22
23
24
25
26
27
28
    AutonomousHorizonMain(ConfigStore configStore) {
        this.configStore = configStore;
    }

    public static void main(String[] args) throws InterruptedException {
        ConfigStore configStore = ConfigStore.get("openstack-horizon");

        AutonomousHorizonMain horizon = new AutonomousHorizonMain(configStore);
        try {
            horizon.run();
        } catch (Exception e) {
View Full Code Here

Examples of org.apache.qpid.server.configuration.ConfigStore

181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
        }

        _logger.info("Initialising Application Registry(" + instance + ")");


        final ConfigStore store = ConfigStore.newInstance();
        store.setRoot(new SystemConfigImpl(store));
        instance.setConfigStore(store);

        final BrokerConfig brokerConfig = new BrokerConfigAdapter(instance);

        final SystemConfig system = store.getRoot();
        system.addBroker(brokerConfig);
        instance.setBrokerConfig(brokerConfig);

        try
        {
View Full Code Here

Examples of org.apache.qpid.server.configuration.ConfigStore

137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
        if (instance != null)
        {
            _logger.info("Initialising Application Registry(" + instance + "):" + instanceID);
            _instanceMap.put(instanceID, instance);

            final ConfigStore store = ConfigStore.newInstance();
            store.setRoot(new SystemConfigImpl(store));
            instance.setConfigStore(store);

            BrokerConfig broker = new BrokerConfigAdapter(instance);

            SystemConfig system = (SystemConfig) store.getRoot();
            system.addBroker(broker);
            instance.setBroker(broker);

            try
            {
View Full Code Here

Examples of org.apache.qpid.server.configuration.ConfigStore

144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
        if (instance != null)
        {
            _logger.info("Initialising Application Registry(" + instance + "):" + instanceID);
            _instanceMap.put(instanceID, instance);

            final ConfigStore store = ConfigStore.newInstance();
            store.setRoot(new SystemConfigImpl(store));
            instance.setConfigStore(store);

            BrokerConfig broker = new BrokerConfigAdapter(instance);

            SystemConfig system = (SystemConfig) store.getRoot();
            system.addBroker(broker);
            instance.setBroker(broker);

            try
            {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.