coordination example

coordinationexample.scala

class AvailablePool extends Actor {
  var coordinationSequence = 0
  var allocatorSequence = 0

  var pool = 100
  
  def receive = {
    case Get(count, coordSeq) if count <= pool =>
      if ( coordSeq >= coodinationSequence )
        coordinationSequence = coordSeq

      coordinationSequence = coordinationSequence + 1
      
      pool = pool - count

      self.channel ! Inventory(count, coordinationSequence )
  }
}

class InventoryAllocator( availablePool :ActorRef, eventStore :EventStore ) extends Actor {

  var coordinationSequence = 0
  var allocatorSequence = 0


  def receive = {
    case AllocateInventory(count) =>

      val result = ( availablePool ? Get( count, coordinationSequence ).mapTo[Inventory].get
      coordinationSequence = result.coordinationSequence
      allocatorSequence = allocatorSequence + 1
      eventStore.persist( InventoryAllocated( id, count, coordinationSequence, allocatorSequence )

      self.channel ! Response(..., event)// yada yada

  }
}