List of deployNetwork() Examples

Examples of deployNetwork()

net.kuujo.vertigo.cluster.Cluster.deployNetwork()
Deploys a bare network to the cluster.
The network will be deployed with no components and no connections. You can add components and connections to the network with an {@link ActiveNetwork}instance. @param name The name of the network to deploy. @return The cluster.

Examples of net.kuujo.vertigo.cluster.Cluster.deployNetwork()

        network.addVerticle("worker", TestWorker.class.getName(), 2);
        network.createConnection("feeder", "stream", "worker", "stream");
        network.createConnection("worker", "out", "nowhere", "in");


        Cluster cluster = result.result();
        cluster.deployNetwork(network, new Handler<AsyncResult<ActiveNetwork>>() {
          @Override
          public void handle(AsyncResult<ActiveNetwork> result) {
            assertTrue(result.succeeded());
            testComplete();
          }

View Full Code Here

Examples of net.kuujo.vertigo.cluster.Cluster.deployNetwork()

        network.addVerticle("feeder", TestFeeder.class.getName());
        network.addVerticle("worker", TestWorker.class.getName());
        network.createConnection("feeder", "out", "worker", "in");


        final Cluster cluster = result.result();
        cluster.deployNetwork(network, new Handler<AsyncResult<ActiveNetwork>>() {
          @Override
          public void handle(AsyncResult<ActiveNetwork> result) {
            assertTrue(result.succeeded());
            NetworkConfig network = vertigo.createNetwork("test-deploy-merge");
            network.addVerticle("feeder2", TestFeeder.class.getName());

View Full Code Here

Examples of net.kuujo.vertigo.cluster.Cluster.deployNetwork()

            NetworkConfig network = vertigo.createNetwork("test-deploy-merge");
            network.addVerticle("feeder2", TestFeeder.class.getName());
            network.addVerticle("worker2", TestWorker.class.getName());
            network.createConnection("feeder2", "out", "worker2", "in");


            cluster.deployNetwork(network, new Handler<AsyncResult<ActiveNetwork>>() {
              @Override
              public void handle(AsyncResult<ActiveNetwork> result) {
                assertTrue(result.succeeded());
                testComplete();
              }

View Full Code Here

0 1 2 3

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.