Interop

A Scala Reactor can send messages to an AsyncFP Actor for synchronous, asynchronous or transactional processing through the use of an Interop object. The only restriction is that messages whose classes are bound to a Safe object can not be sent. Here then is a sample AsyncFP actor.

case class SimpleEcho(value: String)
case class QueryEcho(value: String)
case class Ex()

class SimpleActor extends Actor {
  bind(classOf[SimpleEcho], simpleEcho)
  bindSafe(classOf[QueryEcho], new Query(queryEcho))
  bind(classOf[Ex], ex)

  private def simpleEcho(msg: AnyRef, rf: Any => Unit) {
    rf(msg.asInstanceOf[SimpleEcho].value)
  }

  private def queryEcho(msg: AnyRef, rf: Any => Unit) {
    rf(msg.asInstanceOf[QueryEcho].value)
  }

  private def ex(msg: AnyRef, rf: Any => Unit) {
    throw new IllegalArgumentException
  }
}

To test interoperability, here is a simple Reactor class.

case class T1()
case class T2()
case class T3()
case class T4()

class SimpleReactor extends Reactor[Any] {
  val interop = new Interop(this)
  val simpleActor = new SimpleActor
  simpleActor.setMailbox(new ReactorMailbox)

  start

  override def act {
    loop{
      react{
        case afpResponse: MailboxRsp => interop.afpResponse(afpResponse)
        case req: T1 => println("a")
        case req: T2 => {
          interop.afpSend(simpleActor, SimpleEcho("b"), exceptionHandler) {
            rsp => println(rsp)
          }
        }
        case req: T3 => {
          interop.afpSend(simpleActor, QueryEcho("c"), exceptionHandler) {
            rsp => println(rsp)
          }
        }
        case req: T4 => {
          interop.afpSend(simpleActor, Ex(), exh) {
            rsp => println("Can't get here")
          }
        }
      }
    }
  }

  def exh: PartialFunction[Exception, Unit] = {
    case ex => println(ex.getClass.getName)
  }
}

Here then is the test code.

val simpleReactor = new SimpleReactor
simpleReactor ! T1()
simpleReactor ! T2()
simpleReactor ! T3()
simpleReactor ! T4()

Output.

a
b
c
java.lang.IllegalArgumentException

InteropTest

Tutorial