42 lines
1.3 KiB
Scala
42 lines
1.3 KiB
Scala
package sample.lift
|
|
|
|
import se.scalablesolutions.akka.kernel.state.{TransactionalState, CassandraStorageConfig}
|
|
import se.scalablesolutions.akka.kernel.actor.{SupervisorFactory, Actor}
|
|
import se.scalablesolutions.akka.kernel.config.ScalaConfig._
|
|
import se.scalablesolutions.akka.kernel.util.Logging
|
|
|
|
import javax.ws.rs.core.MultivaluedMap
|
|
import javax.ws.rs.{GET, POST, Path, Produces, WebApplicationException, Consumes}
|
|
|
|
/**
|
|
* Try service out by invoking (multiple times):
|
|
* <pre>
|
|
* curl http://localhost:9998/liftcount
|
|
* </pre>
|
|
* Or browse to the URL from a web browser.
|
|
*/
|
|
@Path("/liftcount")
|
|
class SimpleService extends Actor {
|
|
makeTransactionRequired
|
|
|
|
case object Tick
|
|
private val KEY = "COUNTER";
|
|
private var hasStartedTicking = false;
|
|
private val storage = TransactionalState.newPersistentMap(CassandraStorageConfig())
|
|
|
|
@GET
|
|
@Produces(Array("text/html"))
|
|
def count = (this !! Tick).getOrElse(<h1>Error in counter</h1>)
|
|
|
|
override def receive: PartialFunction[Any, Unit] = {
|
|
case Tick => if (hasStartedTicking) {
|
|
val counter = storage.get(KEY).get.asInstanceOf[Integer].intValue
|
|
storage.put(KEY, new Integer(counter + 1))
|
|
reply(<h1>Tick: {counter + 1}</h1>)
|
|
} else {
|
|
storage.put(KEY, new Integer(0))
|
|
hasStartedTicking = true
|
|
reply(<h1>Tick: 0</h1>)
|
|
}
|
|
}
|
|
}
|