private void startEmbeddedCassandra(){
  if (log != null) {
    log.info("-------------------------------");
    log.info("| Starting embedded Cassandra |");
    log.info("-------------------------------");
  }
  try {
    if (jmxPort != null)     System.setProperty(CASSANDRA_JMX_PORT_PROP,jmxPort);
    if (cassandraCfgFile != null)     System.setProperty(CASSANDRA_CONFIG_PROP,FILE_PREFIX + cassandraCfgFile);
    embeddedCassandraDaemon=new CassandraDaemon(true);
    embeddedCassandraDaemon.init(null);
    embeddedCassandraDaemon.start();
  }
 catch (  Exception e) {
    throw new RuntimeException("Failed to start embedded Cassandra",e);
  }
  if (log != null) {
    log.info("------------------------------");
    log.info("| Embedded Cassandra started |");
    log.info("------------------------------");
  }
}

private void startEmbeddedCassandra ( ) { if ( log != null ) { log . info ( "-------------------------------" ) ; log . info ( "| Starting embedded Cassandra |" ) ; log . info ( "-------------------------------" ) ; } try { if ( jmxPort != null ) System . setProperty ( CASSANDRA_JMX_PORT_PROP , jmxPort ) ; if ( cassandraCfgFile != null ) System . setProperty ( CASSANDRA_CONFIG_PROP , FILE_PREFIX + cassandraCfgFile ) ; embeddedCassandraDaemon = new CassandraDaemon ( true ) ; embeddedCassandraDaemon . init ( null ) ; embeddedCassandraDaemon . start ( ) ; } catch ( Exception e ) { throw new RuntimeException ( "Failed to start embedded Cassandra" , e ) ; } if ( log != null ) { log . info ( "------------------------------" ) ; log . info ( "| Embedded Cassandra started |" ) ; log . info ( "------------------------------" ) ; } }
starts embedded cassandra instance
