commit 0ca55d0ae346e8a12b0eb40230a455bd5a04161f
author Hadrian Zbarcea <hadrian@apache.org> Sat Jan 19 17:39:06 2013 +0000
committer Hadrian Zbarcea <hadrian@apache.org> Sat Jan 19 17:39:06 2013 +0000
tree 2e37316a877c42578337a76b619e404f7f2d6158
parent 58e6c4facb607e996cd2655927e5809a09aa00d8

Improve example to gracefully handle imporoper use of dsl

git-svn-id: https://svn.apache.org/repos/asf/ode/trunk@1435620 13f79535-47bb-0310-9956-ffa450edef68

src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java

diff --git a/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java b/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java
index fce098a..d2482fe 100644
--- a/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java
+++ b/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java
@@ -65,6 +65,7 @@
                 .order("1")
                 .and().then().order("2")
                 .and().then().order("3")
+                .and().then().and().then().and().then().and().then()
                 .and().no().andthen();
         }
 
@@ -94,6 +95,9 @@
                 return this;
             }
             public PrinterProcess then() {
+                if (message == null) {
+                    return this;
+                }
                 next = new PrinterProcess(printer, this);
                 return next;
             }
@@ -106,14 +110,16 @@
 
             @Override
             public void run() {
-                object(receive(printer.print(message), new Synch() {
-                    private static final long serialVersionUID = 1L;
-                    public void ret() {
-                        if (next != null) {
-                            next.run();
+                if (message != null) {
+                    object(receive(printer.print(message), new Synch() {
+                        private static final long serialVersionUID = 1L;
+                        public void ret() {
+                            if (next != null) {
+                                next.run();
+                            }
                         }
-                    }
-                }));
+                    }));
+                }
             }
         }
     }