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

refactored and renamed AMQP code, refactored STM, fixed persistence bugs, renamed reactor package to dispatch, added programmatic API for RemoteServer

Browse source
This commit is contained in:
jboner 2009-10-08 19:01:04 +02:00
parent 046fa217b1
commit eb919aa818
37 changed files with 572 additions and 338 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-fun-test-java/src/test/java/se/scalablesolutions/akka/api/InMemStateful.java
View file

@ -56,7 +56,8 @@ public class InMemStateful {
mapState.put(key, msg);
vectorState.add(msg);
refState.swap(msg);
nested.success(key, msg);
nested.success(key, msg);
System.out.println("--- after success ");
}
public String failure(String key, String msg, InMemFailer failer) {