|
Akka/Scala example source code file (RedundancyGroup.java)
The RedundancyGroup.java Akka example source code/** * Copyright (C) 2009-2014 Typesafe Inc. <http://www.typesafe.com> */ package docs.jrouting; //#group import java.util.List; import scala.Option; import scala.collection.immutable.Iterable; import akka.actor.ActorContext; import akka.actor.ActorPath; import akka.actor.ActorSystem; import akka.actor.Props; import akka.dispatch.Dispatchers; import akka.routing.Group; import akka.routing.Routee; import akka.routing.Router; import akka.routing.RouterActor; import akka.routing.RouterConfig; import akka.routing.RoutingLogic; import com.typesafe.config.Config; import akka.routing.GroupBase; import static docs.jrouting.CustomRouterDocTest.RedundancyRoutingLogic; public class RedundancyGroup extends GroupBase { private final List<String> paths; private final int nbrCopies; public RedundancyGroup(List<String> paths, int nbrCopies) { this.paths = paths; this.nbrCopies = nbrCopies; } public RedundancyGroup(Config config) { this(config.getStringList("routees.paths"), config.getInt("nbr-copies")); } @Override public java.lang.Iterable<String> getPaths() { return paths; } @Override public Router createRouter(ActorSystem system) { return new Router(new RedundancyRoutingLogic(nbrCopies)); } @Override public String routerDispatcher() { return Dispatchers.DefaultDispatcherId(); } } //#group Other Akka source code examplesHere is a short list of links related to this Akka RedundancyGroup.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.