Package org.openstreetmap.osmosis.core.pipeline.common

Examples of org.openstreetmap.osmosis.core.pipeline.common.TaskRunner.start()

105
106
107
108
109
110
111
112
113
114
115
    // sequence server.
    ReplicationDataServer dataServer = new ReplicationDataServer(sequenceServer.getPort(), workingDir1, 0);

    // Start the HTTP data server.
    TaskRunner serverRunner = new TaskRunner(dataServer, "data-server");
    serverRunner.start();

    /*
     * The server starts in another thread so we need to wait until it has
     * started. We will wait until the dynamically allocated port is
     * exported via the getPort method which occurs after server startup.
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
    File workingDir2 = dataUtils.newFolder();
    dataClient.setChangeSink(new ReplicationWriter(workingDir2));

    // Start the HTTP data server and HTTP data client.
    TaskRunner clientRunner = new TaskRunner(dataClient, "data-client");
    clientRunner.start();

    // Send the test replication intervals.
    for (int i = 0; i < sequenceCount; i++) {
      source.sendSequence();
    }
View Full Code Here
340
341
342
343
344
345
346
347
348
349
350
       
        taskRunner = taskRunners.get(i);
       
        LOG.fine("Launching changeset worker + " + i + " in a new thread.");
       
        taskRunner.start();
      }
     
      // Wait for all the tasks to complete.
      tasksSuccessful = true;
      for (int i = 0; i < taskRunners.size(); i++) {
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.