Permalink
Browse files

Use non-blocking processorOf method

  • Loading branch information...
krasserm committed Jan 26, 2013
1 parent 5f34d5b commit c3a2ee71de58d41ea3a5810cc0428d3c157a8050
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/main/scala/org/eligosource/eventsourced/example/server/Appserver.scala
@@ -49,8 +49,8 @@ object Appserver {
system.actorOf(Props(new StatisticsProcessor(statisticsRef) with Receiver)),
system.actorOf(Props(new PaymentProcess with Emitter)))
val invoiceProcessor = extension.processorOf(Props(new InvoiceProcessor(invoicesRef) with Emitter with Eventsourced { val id = 1 } ))
val multicastProcessor = extension.processorOf(Props(new Multicast(multicastTargets, identity) with Confirm with Eventsourced { val id = 2 }))
val invoiceProcessor = extension.processorOf(ProcessorProps(1, pid => new InvoiceProcessor(invoicesRef) with Emitter with Eventsourced { val id = pid } ))
val multicastProcessor = extension.processorOf(ProcessorProps(2, pid => new Multicast(multicastTargets, identity) with Confirm with Eventsourced { val id = pid }))
val paymentGateway = system.actorOf(Props(new PaymentGateway(invoiceProcessor) with Receiver with Confirm))

0 comments on commit c3a2ee7

Please sign in to comment.