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

fixed bug with using ThreadBasedDispatcher + added tests for dispatchers

Browse source
This commit is contained in:
jboner 2009-10-14 12:59:05 +02:00
parent 0f6823215a
commit bcbfa84e8d
21 changed files with 303 additions and 101 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-samples-java/src/main/java/sample/java/PersistentSimpleService.java
View file

@ -13,7 +13,7 @@ import se.scalablesolutions.akka.annotation.prerestart;
import se.scalablesolutions.akka.annotation.postrestart;
import se.scalablesolutions.akka.state.TransactionalState;
import se.scalablesolutions.akka.state.PersistentState;
import se.scalablesolutions.akka.state.TransactionalMap;
import se.scalablesolutions.akka.state.PersistentMap;
import se.scalablesolutions.akka.state.CassandraStorageConfig;
/**
@ -26,11 +26,10 @@ import se.scalablesolutions.akka.state.CassandraStorageConfig;
@Path("/persistentjavacount")
@transactionrequired
public class PersistentSimpleService {
private String KEY = "COUNTER";
private Object KEY = "COUNTER";
private boolean hasStartedTicking = false;
private PersistentState factory = new PersistentState();
private TransactionalMap<Object, Object> storage = factory.newMap(new CassandraStorageConfig());
private PersistentMap storage = PersistentState.newMap(new CassandraStorageConfig());
@GET
@Produces({"application/html"})