From efcd736f9442eb568cef57e5794fa7f63c0513b2 Mon Sep 17 00:00:00 2001
From: Michael Kober <michaelkober@mike-laptop.local>
Date: Wed, 17 Mar 2010 10:21:29 +0100
Subject: [PATCH] added integration tests

---
 .../akka/spring/foo/Bar.java                  | 10 ++++
 .../akka/spring/foo/Foo.java                  |  9 ++++
 .../akka/spring/foo/IBar.java                 |  7 +++
 .../akka/spring/foo/MyPojo.java               | 40 ++++++++++++++++
 .../akka/spring/foo/StatefulPojo.java         | 47 +++++++++++++++++++
 5 files changed, 113 insertions(+)
 create mode 100644 akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/Bar.java
 create mode 100644 akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/Foo.java
 create mode 100644 akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/IBar.java
 create mode 100644 akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/MyPojo.java
 create mode 100644 akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/StatefulPojo.java

diff --git a/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/Bar.java b/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/Bar.java
new file mode 100644
index 0000000000..fc3392250a
--- /dev/null
+++ b/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/Bar.java
@@ -0,0 +1,10 @@
+package se.scalablesolutions.akka.spring.foo;
+
+public class Bar implements IBar {
+
+	@Override
+	public String getBar() {
+		return "bar";
+	}
+
+}
diff --git a/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/Foo.java b/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/Foo.java
new file mode 100644
index 0000000000..36536cdb5d
--- /dev/null
+++ b/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/Foo.java
@@ -0,0 +1,9 @@
+package se.scalablesolutions.akka.spring.foo;
+
+public class Foo {
+
+  public String foo() {
+    return "foo";
+  }
+
+}
diff --git a/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/IBar.java b/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/IBar.java
new file mode 100644
index 0000000000..66f91ee464
--- /dev/null
+++ b/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/IBar.java
@@ -0,0 +1,7 @@
+package se.scalablesolutions.akka.spring.foo;
+
+public interface IBar {
+	
+	String getBar();
+
+}
diff --git a/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/MyPojo.java b/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/MyPojo.java
new file mode 100644
index 0000000000..2d1f032cf8
--- /dev/null
+++ b/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/MyPojo.java
@@ -0,0 +1,40 @@
+package se.scalablesolutions.akka.spring.foo;
+
+public class MyPojo {
+	
+	private String foo;
+	private String bar;
+	
+	
+	public MyPojo() {
+		this.foo = "foo";
+		this.bar = "bar";
+	}
+
+
+	public String getFoo() {
+		return foo;
+	}
+
+
+	public String getBar() {
+		return bar;
+	}
+	
+	public void preRestart() {
+		System.out.println("pre restart");
+	}
+	
+	public void postRestart() {
+		System.out.println("post restart");
+	}
+
+    public String longRunning() {
+      try {
+          Thread.sleep(6000);
+      } catch (InterruptedException e) {
+      }
+      return "this took long";
+    }
+
+}
diff --git a/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/StatefulPojo.java b/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/StatefulPojo.java
new file mode 100644
index 0000000000..7db06c9a65
--- /dev/null
+++ b/akka-spring/akka-spring-test-java/src/main/java/se/scalablesolutions/akka/spring/foo/StatefulPojo.java
@@ -0,0 +1,47 @@
+package se.scalablesolutions.akka.spring.foo;
+
+import se.scalablesolutions.akka.stm.TransactionalMap;
+import se.scalablesolutions.akka.stm.TransactionalVector;
+import se.scalablesolutions.akka.stm.TransactionalRef;
+import se.scalablesolutions.akka.stm.TransactionalState;
+
+public class StatefulPojo {
+    private TransactionalMap<String, String> mapState;
+    private TransactionalVector<String> vectorState;
+    private TransactionalRef<String> refState;
+    private boolean isInitialized = false;
+
+    public void init() {
+      if (!isInitialized) {
+        mapState = TransactionalState.newMap();
+        vectorState = TransactionalState.newVector();
+        refState = TransactionalState.newRef();
+        isInitialized = true;
+      }
+    }
+
+    public String getMapState(String key) {
+      return (String)mapState.get(key).get();
+    }
+
+    public String getVectorState() {
+      return (String)vectorState.last();
+    }
+
+    public String getRefState() {
+      return (String)refState.get().get();
+    }
+
+    public void setMapState(String key, String msg) {
+      mapState.put(key, msg);
+    }
+
+    public void setVectorState(String msg) {
+      vectorState.add(msg);
+    }
+
+    public void setRefState(String msg) {
+      refState.swap(msg);
+    }
+
+}