Package akka.actor

Examples of akka.actor.ActorSystem.actorOf()

26
27
28
29
30
31
32
33
34
35
36
      withFallback(ConfigFactory.parseString("akka.cluster.roles = [frontend]")).
      withFallback(ConfigFactory.load());

    ActorSystem system = ActorSystem.create("ClusterSystem", config);

    final ActorRef frontend = system.actorOf(
        Props.create(TransformationFrontend.class), "frontend");
    final FiniteDuration interval = Duration.create(2, TimeUnit.SECONDS);
    final Timeout timeout = new Timeout(Duration.create(5, TimeUnit.SECONDS));
    final ExecutionContext ec = system.dispatcher();
    final AtomicInteger counter = new AtomicInteger();
View Full Code Here
15
16
17
18
19
20
21
22
23
24
      withFallback(ConfigFactory.parseString("akka.cluster.roles = [backend]")).
      withFallback(ConfigFactory.load());

    ActorSystem system = ActorSystem.create("ClusterSystem", config);

    system.actorOf(Props.create(TransformationBackend.class), "backend");

  }

}
View Full Code Here
30
31
32
33
34
35
36
37
38
39
40
          .withFallback(ConfigFactory.load("stats2"));

      ActorSystem system = ActorSystem.create("ClusterSystem", config);

      //#create-singleton-manager
      system.actorOf(ClusterSingletonManager.defaultProps(
          Props.create(StatsService.class), "statsService",
          PoisonPill.getInstance(), "compute"), "singleton");
      //#create-singleton-manager

      //#singleton-proxy
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
          Props.create(StatsService.class), "statsService",
          PoisonPill.getInstance(), "compute"), "singleton");
      //#create-singleton-manager

      //#singleton-proxy
      system.actorOf(ClusterSingletonProxy.defaultProps("/user/singleton/statsService",
        "compute"), "statsServiceProxy");
      //#singleton-proxy
    }

  }
View Full Code Here
9
10
11
12
13
14
15
16
17
  public static void main(String[] args) {
    // note that client is not a compute node, role not defined
    ActorSystem system = ActorSystem.create("ClusterSystem",
        ConfigFactory.load("stats1"));
    system.actorOf(Props.create(StatsSampleClient.class, "/user/statsService"),
        "client");
  }
}
View Full Code Here
26
27
28
29
30
31
32
33
34
35
36
              ConfigFactory.parseString("akka.cluster.roles = [compute]"))
          .withFallback(ConfigFactory.load("stats1"));

      ActorSystem system = ActorSystem.create("ClusterSystem", config);

      system.actorOf(Props.create(StatsWorker.class), "statsWorker");
      system.actorOf(Props.create(StatsService.class), "statsService");
    }

  }
}
View Full Code Here
27
28
29
30
31
32
33
34
35
36
          .withFallback(ConfigFactory.load("stats1"));

      ActorSystem system = ActorSystem.create("ClusterSystem", config);

      system.actorOf(Props.create(StatsWorker.class), "statsWorker");
      system.actorOf(Props.create(StatsService.class), "statsService");
    }

  }
}
View Full Code Here
9
10
11
12
13
14
15
16
17
18
19
  public static void main(String[] args) {
    // note that client is not a compute node, role not defined
    ActorSystem system = ActorSystem.create("ClusterSystem",
        ConfigFactory.load("stats2"));
    system.actorOf(Props.create(StatsSampleClient.class, "/user/statsServiceProxy"),
        "client");

  }

}
View Full Code Here
24
25
26
27
28
29
30
31
32
33
34
      // Create an Akka system
      ActorSystem system = ActorSystem.create("ClusterSystem", config);

      // Create an actor that handles cluster domain events
      system.actorOf(Props.create(SimpleClusterListener.class),
          "clusterListener");

    }
  }
}
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
    @Test
    public void mustSupportMdcNull() throws Exception {
        final ActorSystem system = ActorSystem.create("test-system", config);
        new LogJavaTestKit(system) {{
            system.eventStream().subscribe(getRef(), LogEvent.class);
            ActorRef ref = system.actorOf(Props.create(ActorWithMDC.class));

            ref.tell(new Log(InfoLevel(), "Null MDC"), system.deadLetters());
            expectLog(InfoLevel(), "Null MDC", "Map()");
        }};
    }
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.