../dist/configure --enable-pthread-api

As described above, you introduce replication to an application by starting with a transactional application, performing some basic replication configuration, and then starting replication using Environment.replicationManagerStart().

You stop replication by closing your environment cleanly in the same way you would for any DB application.

For example, the following code fragment initializes, then stops and starts replication. Note that other replication activities are omitted for brevity.

import com.sleepycat.db.Environment;
import com.sleepycat.db.EnvironmentConfig;
import com.sleepycat.db.ReplicationHostAddress;
import com.sleepycat.db.ReplicationManagerStartPolicy;
import com.sleepycat.db.ReplicationManagerSiteConfig;

...
    String progname = "example_replication";
    String envHome = "TESTDIR";
    int cachesize = 10 * 1024 * 1024;

    Environment dbenv;
    String listenHost = "mymachine.sleepycat.com";
    String otherHost = "anothermachine.sleepycat.com";
    int listenPort = 8080;
    int otherPort = 8081;


try {
    // Configure the environment handle
    EnvironmentConfig envConfig = new EnvironmentConfig();
    envConfig.setErrorStream(System.err);
    envConfig.setErrorPrefix(progname);
    envConfig.setCacheSize(cachesize);
    envConfig.setTxnNoSync(true);

    // Identify the local replication site. This is the local hostname
    // and  port that this replication participant will use to receive
    // incoming replication messages. Note that this can be
    // performed only once for the application. It is required.
    ReplicationManagerSiteConfig thisHostConfig = 
        new ReplicationManagerSiteConfig(listenHost, listenPort);
    thisHostConfig.setGroupCreator(creator);
    thisHostConfig.setLocalSite(true)
    envConfig.addReplicationManagerSite(thisHostConfig);

    // Set this application's priority. This is used for elections.
    // 
    // Set this number to a positive integer, or 0 if you do not want
    // this site to be able to become a master.
    envConfig.setReplicationPriority(100);

    // Add a site to the list of replication environments known to 
    // this application.
    ReplicationManagerSiteConfig remoteSiteConfig =
        new ReplicationManagerSiteConfig(otherHost, otherPort);
    remoteSiteConfig.setBootstrapHelper(true);
    envConfig.addReplicationManagerSite(remoteSiteConfig);

    // Configure the environment's subsystems. Note that we initialize
    // replication. This is required.
    envConfig.setAllowCreate(true);
    envConfig.setRunRecovery(true);
    envConfig.setThreaded(true);
    envConfig.setInitializeReplication(true);
    envConfig.setInitializeLocking(true);
    envConfig.setInitializeLogging(true);
    envConfig.setInitializeCache(true);
    envConfig.setTransactional(true);

    // Missing from this is where we set the event handle and the
    // acknowledgement policy. We discuss these things later in this 
    // book. 

    // Open our environment handle.
    try {
        dbenv = new Environment(envHome, envConfig);
    } catch(FileNotFoundException e) {
        System.err.println("FileNotFound exception: " + e.toString());
        System.err.println(
            "Ensure that the environment directory is pre-created.");
    }

    // Start the replication manager such that it has three threads.
    dbenv.replicationManagerStart(3,
        ReplicationManagerStartPolicy.REP_ELECTION);

    //////////////////////////////////////////////////
    // All other application code goes here, including
    // database opens.
    //////////////////////////////////////////////////

} catch (DatabaseException dbe) {
    // Error handling goes here
}

// Close out your application here.
try {
    // Make sure all your databases are closed.

    // Closing your environment stops replication.
   dbenv.close();
} catch (DatabaseException dbe) {
    // Error handling here.
}

// All done.