Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- class ReplicationMasterSearchWithResizer extends Actor {
- val resizer = DefaultResizer(lowerBound = 2, upperBound = 15)
- val router30: ActorRef =
- context.actorOf(RoundRobinPool(5, Some(resizer)).props(Props[AuctionSearch]),
- "router30")
- def receive = {
- case Register(auctionName: String, auctionRef: ActorRef) => {
- router30 forward Register(auctionName, auctionRef);
- }
- case Find(filter: String) => {
- router30 forward Find(filter);
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement