raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

fixed sample problem

Browse source
This commit is contained in:
jboner 2009-10-19 10:52:18 +02:00
parent 887d3af199
commit 67f6a66fdb
1 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-samples-security/src/main/scala/SimpleService.scala
View file

@ -34,8 +34,7 @@ class Boot {
/*
* In akka.conf you can set the FQN of any AuthenticationActor of your wish, under the property name: akka.rest.authenticator
*/
class SimpleAuthenticationService extends DigestAuthenticationActor
{
class SimpleAuthenticationService extends DigestAuthenticationActor {
//If you want to have a distributed nonce-map, you can use something like below,
//don't forget to configure your standalone Cassandra instance
//
@ -67,7 +66,7 @@ class SecureService extends Actor with Logging {
case object Tick
private val KEY = "COUNTER";
private var hasStartedTicking = false;
private val storage = TransactionalState.newMap
private val storage = TransactionalState.newMap[String, Integer]
@GET
@Produces(Array("text/html"))
@ -76,7 +75,7 @@ class SecureService extends Actor with Logging {
override def receive: PartialFunction[Any, Unit] = {
case Tick => if (hasStartedTicking) {
val counter = storage.get(KEY).get.asInstanceOf[Integer].intValue
val counter = storage.get(KEY).get.intValue
storage.put(KEY, new Integer(counter + 1))
reply(<success>Tick:{counter + 1}</success>)
} else {