So I am trying to create a producer/consumer type scala app. The LoopControl just sends a message to the MessageReceiver continoually. The MessageReceiver then delegates work to the MessageCreatorActor (whose work is to check a map for an object, and if not found create one and start it up). Each MessageActor created by this MessageCreatorActor is associated with an Id. Eventually this is where I want to do business logic. But I run out of memory after 15 minutes. Any help is appreciated

import scala.actors.Actor import java.util.HashMap; import scala.actors.Actor._

case object LoopControl case object MessageReceiver case object MessageActor case object MessageActorCreator

class MessageReceiver(msg: String) extends Actor {

var messageActorMap = new HashMap[String, MessageActor] val messageCreatorActor = new MessageActorCreator(null, null)

def act() { messageCreatorActor.start loop { react { case MessageActor(messageId) =>
if (msg.length() > 0) {
var messageActor = messageActorMap.get(messageId);

 if(messageActor == null) {
  messageCreatorActor ! MessageActorCreator(messageId, messageActorMap)
 }else {   
  messageActor ! MessageActor
 }
}

} } } }

case class MessageActorCreator(msg:String, messageActorMap: HashMap[String, MessageActor]) extends Actor { def act() { loop { react { case MessageActorCreator(messageId, messageActorMap) => if(messageId != null ) { var messageActor = new MessageActor(messageId); messageActorMap.put(messageId, messageActor) println(messageActorMap) messageActor.start messageActor ! MessageActor } } } } }

class LoopControl(messageReceiver:MessageReceiver) extends Actor { var count : Int = 0; def act() { while (true) { messageReceiver ! MessageActor ("00-122-0X95-FEC0" + count) //Thread.sleep(100) count = count +1; if(count > 5) { count = 0; } } } }

case class MessageActor(msg: String) extends Actor { def act() { loop { react { case MessageActor => println() println("MessageActor: Got something-> " + msg) } } } }

object messages extends Application {

val messageReceiver = new MessageReceiver("bootstrap") val loopControl = new LoopControl(messageReceiver)

messageReceiver.start loopControl.start }