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 <[email protected]> Authored: Mon Mar 4 20:39:17 2013 +0100 Committer: Tammo van Lessen <[email protected]> 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(); }
