You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by va...@apache.org on 2013/03/04 20:43:59 UTC
[1/2] git commit: fixing a testcase bug.
fixing a testcase bug.
Project: http://git-wip-us.apache.org/repos/asf/ode-jacob/repo
Commit: http://git-wip-us.apache.org/repos/asf/ode-jacob/commit/4513f0c9
Tree: http://git-wip-us.apache.org/repos/asf/ode-jacob/tree/4513f0c9
Diff: http://git-wip-us.apache.org/repos/asf/ode-jacob/diff/4513f0c9
Branch: refs/heads/master
Commit: 4513f0c9804b985212b7643b3fe37aae37f78dca
Parents: b982c5d
Author: Tammo van Lessen <tv...@gmail.com>
Authored: Mon Mar 4 20:39:17 2013 +0100
Committer: Tammo van Lessen <tv...@gmail.com>
Committed: Mon Mar 4 20:39:17 2013 +0100
----------------------------------------------------------------------
.../ode/jacob/examples/helloworld/HelloWorld.java | 20 ++++++++------
1 files changed, 11 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ode-jacob/blob/4513f0c9/src/test/java/org/apache/ode/jacob/examples/helloworld/HelloWorld.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/ode/jacob/examples/helloworld/HelloWorld.java b/src/test/java/org/apache/ode/jacob/examples/helloworld/HelloWorld.java
index d755789..1b1e565 100644
--- a/src/test/java/org/apache/ode/jacob/examples/helloworld/HelloWorld.java
+++ b/src/test/java/org/apache/ode/jacob/examples/helloworld/HelloWorld.java
@@ -54,15 +54,16 @@ public class HelloWorld extends JacobRunnable {
}
public void run() {
- object(true, new ReceiveProcess() {
- private static final long serialVersionUID = 1L;
- }.setChannel(in).setReceiver(new Callback<String, Synch>(){
- @Override
- public void invoke(String value, Synch callback) {
- System.out.println(value);
- callback.ret();
- }
- }));
+ object(true, new ReliablePrinterReceiveProcess().setChannel(in).setReceiver(new ReliablePrinterCallback()));
+ }
+
+ static class ReliablePrinterReceiveProcess extends ReceiveProcess {}
+ static class ReliablePrinterCallback implements Callback<String, Synch> {
+ @Override
+ public void invoke(String value, Synch callback) {
+ System.out.println(value);
+ callback.ret();
+ }
}
}
@@ -250,6 +251,7 @@ public class HelloWorld extends JacobRunnable {
vpu.inject(new HelloWorld());
while (vpu.execute()) {
queue = loadAndRestoreQueue(mapper, queue);
+ //vpu.setContext(queue);
System.out.println(vpu.isComplete() ? "<0>" : ".");
//vpu.dumpState();
}