Routing (Java)
==============

UntypedDispatcher
-----------------

An UntypedDispatcher is an actor that routes incoming messages to outbound actors.

.. code-block:: java

  import static akka.actor.Actors.*;
  import akka.actor.*;
  import akka.routing.*;

  //A Pinger is an UntypedActor that prints "Pinger: <message>"
  class Pinger extends UntypedActor {
    public void onReceive(Object message) throws Exception {
      System.out.println("Pinger: " + message);
    }
  }

  //A Ponger is an UntypedActor that prints "Ponger: <message>"
  class Ponger extends UntypedActor {
    public void onReceive(Object message) throws Exception {
      System.out.println("Ponger: " + message);
    }
  }

  public class MyDispatcher extends UntypedDispatcher {
    private ActorRef pinger = actorOf(Pinger.class).start();
    private ActorRef ponger = actorOf(Ponger.class).start();

    //Route Ping-messages to the pinger, and Pong-messages to the ponger
    public ActorRef route(Object message) {
      if("Ping".equals(message)) return pinger;
      else if("Pong".equals(message)) return ponger;
      else throw new IllegalArgumentException("I do not understand " + message);
    }
  }

  ActorRef dispatcher = actorOf(MyDispatcher.class).start();
  dispatcher.sendOneWay("Ping"); //Prints "Pinger: Ping"
  dispatcher.sendOneWay("Pong"); //Prints "Ponger: Pong"

UntypedLoadBalancer
-------------------

An UntypedLoadBalancer is an actor that forwards messages it receives to a boundless sequence of destination actors.

.. code-block:: java

  import static akka.actor.Actors.*;
  import akka.actor.*;
  import akka.routing.*;
  import static java.util.Arrays.asList;

  //A Pinger is an UntypedActor that prints "Pinger: <message>"
  class Pinger extends UntypedActor {
    public void onReceive(Object message) throws Exception {
      System.out.println("Pinger: " + message);
    }
  }

  //A Ponger is an UntypedActor that prints "Ponger: <message>"
  class Ponger extends UntypedActor {
    public void onReceive(Object message) throws Exception {
      System.out.println("Ponger: " + message);
    }
  }

  //Our load balancer, sends messages to a pinger, then a ponger, rinse and repeat.
  public class MyLoadBalancer extends UntypedLoadBalancer {
    private InfiniteIterator<ActorRef> actors = new CyclicIterator<ActorRef>(asList(
      actorOf(Pinger.class).start(),
      actorOf(Ponger.class).start()
    ));

    public InfiniteIterator<ActorRef> seq() {
      return actors;
    }
  }

  ActorRef dispatcher = actorOf(MyLoadBalancer.class).start();
  dispatcher.sendOneWay("Pong"); //Prints "Pinger: Pong"
  dispatcher.sendOneWay("Ping"); //Prints "Ponger: Ping"
  dispatcher.sendOneWay("Ping"); //Prints "Pinger: Ping"
  dispatcher.sendOneWay("Pong"); //Prints "Ponger: Pong

You can also send a 'new Routing.Broadcast(msg)' message to the router to have it be broadcasted out to all the actors it represents.

.. code-block:: java

  router.sendOneWay(new Routing.Broadcast(new PoisonPill()));