Package akka.routing

Examples of akka.routing.SmallestMailboxRouter

13
14
15
16
17
18
19
20
21
22
23
   * @param args
   */
  public static void main(String[] args) {
    ActorSystem _system = ActorSystem.create("SmallestMailBoxRouterExample");
    ActorRef smallestMailBoxRouter = _system.actorOf(new Props(MsgEchoActor.class)
        .withRouter(new SmallestMailboxRouter(5)),"mySmallestMailBoxRouterActor");

    for (int i = 1; i <= 10; i++) {
      //works like roundrobin but tries to rebalance the load based on
      //size of actor's mailbox
      smallestMailBoxRouter.tell(i);
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
68
69
70
   */
  public CoreActors(ActorSystem actorSystem, String metaDataActorName, int instances, String processInstanceCleansingActorName) {
    this.actorSystem = actorSystem;
    this.metaDataActor = this.actorSystem.actorOf(
        new Props(MetaDataService.class).withRouter(
            new SmallestMailboxRouter(instances))
            .withDispatcher("file-mailbox-dispatcher"),
            metaDataActorName);
    this.processInstanceCleansingActor = this.actorSystem.actorOf(
        new Props(ProcessInstanceCleansingService.class).withRouter(
            new SmallestMailboxRouter(instances))
            .withDispatcher("file-mailbox-dispatcher"),
            processInstanceCleansingActorName);
  }
View Full Code Here
TOP

Related Classes of akka.routing.SmallestMailboxRouter

  • com.catify.processengine.core.CoreActors
  • org.akka.essentials.java.router.example.smallestmailbox.Example
    • Copyright © 2018 www.massapicom. 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.