Scala Smtp Client Actors: part 2

import scala.actors.Actor

import scala.actors.Actor._
import javax.mail._ 
import javax.mail.internet._
import java.util.Properties._
case class Request(sender : Actor, payload : String)
case class Ready(sender : Actor)
case object Stop
object Client extends Application {
  val body = scala.io.Source.fromFile("foo1").mkString

def consumer(n : Int) = actor {
  loop {
    react {
      case Ready(sender) => 
        sender ! Ready(self)
      case Request(sender, payload) =>
        //println("request to consumer " + n + " with " + payload)        
        // Set up the mail object
        val  properties = System.getProperties
        properties.put("mail.smtp.host","127.0.0.1")
        properties.put("mail.smtp.port", "2025")
        val session = Session.getDefaultInstance(properties)
        val message = new MimeMessage(session)
        // Set the from, to, subject, body text
        message.setFrom(new InternetAddress("[email protected]"))
        message.setRecipients(Message.RecipientType.TO, "[email protected]")
        message.setSubject("Greetings from langref.org")
        message.setText(body)
        Transport.send(payload)
        println("consumer " + n + " is done processing")
      case Stop => exit
    }
  }
}
  // a pool of 10 consumers
  val consumers = for (n <- 0 to 1000) yield consumer(n)
  val coordinator = actor {
    loop {
       react {
          case msg @ Request(sender, payload) =>
             consumers.foreach( arg =>  { arg ! Ready(self) })
             react {
               // send the request to the first available consumer
               case Ready(consumer) => consumer ! msg
             }
           case Stop => 
             consumers.foreach( arg =>  { arg ! Stop } )
             exit
       }
    }
  }
  for (i <- 0 to 1000) coordinator ! Request(self, body)
}