Examples of org.rhq.cassandra.schema.SchemaManager.shutdown()

Class org.rhq.cassandra.schema.SchemaManager

Examples of org.rhq.cassandra.schema.SchemaManager.shutdown()

org.rhq.cassandra.schema.SchemaManager.shutdown()

        } catch (NoHostAvailableException e) {
            throw e;
        } catch (Exception e) {
            throw new RuntimeException(e.getMessage(), e);
        } finally {
            schemaManager.shutdown();
        }
    }


    public synchronized void shutdown() {
        LOG.info("Shutting down storage client subsystem");

View Full Code Here

                } catch (InstalledSchemaTooOldException e3) {
                    log("Storage cluster Schema out of date. Applying Storage Cluster schema updates.");
                    storageNodeSchemaManager.install(schemaProperties);
                }
                storageNodeAddresses = storageNodeSchemaManager.getStorageNodeAddresses();
                storageNodeSchemaManager.shutdown();
            } else {
                log("Ignoring storage cluster schema - installer will assume it exists and is already up-to-date.");
            }
        } catch (NoHostAvailableException e) {
            log.error("Failed to connect to the storage cluster. Please check the following:\n"

View Full Code Here

            log.info("Creating schema");
            schemaManager.install();
        } catch (Exception e) {
            throw new RuntimeException("Failed to start simulator. An error occurred during schema creation.", e);
        } finally {
            schemaManager.shutdown();
        }
    }


    private Session createSession(String[] nodes, int cqlPort) throws NoHostAvailableException {
        try {

View Full Code Here

            if (annotation.waitForSchemaAgreement()) {
                clusterInitService.waitForSchemaAgreement(nodes, jmxPorts);
            }
            schemaManager.updateTopology();
        } finally {
            schemaManager.shutdown();
        }
    }


    private void shutdownCluster() throws Exception {
        ccm.shutdownCluster();

View Full Code Here

                            throw new RuntimeException("Cassandra schema initialization failed", e);
                        }
                        return null;
                    } finally {
                        if (schemaManager != null) {
                            schemaManager.shutdown();
                        }
                    }
                }
            });
        }

View Full Code Here

            addresses, 9142);
        try {
            schemaManager.install();
            schemaManager.updateTopology();
        } finally {
            schemaManager.shutdown();
        }
    }


    private void doDeployment(DeploymentOptions deploymentOptions) throws Exception {
        Deployer deployer = new Deployer();

View Full Code Here

TOP

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.