Fix test failures in pipeline and messenger specs.

Author: ajoberstar

src/main/groovy/org/pipelinelabs/pipeline/dsl/internal/DefaultPipelineDsl.java

@@ -6,6 +6,7 @@
 import org.pipelinelabs.pipeline.dsl.MessengerDsl;
 import org.pipelinelabs.pipeline.dsl.StageDsl;
 import org.pipelinelabs.pipeline.event.PipeEvent;
+import org.pipelinelabs.pipeline.exception.PipelineException;
 import org.pipelinelabs.pipeline.messenger.MessageContext;
 import org.pipelinelabs.pipeline.runner.DefaultPipeline;
 import org.pipelinelabs.pipeline.util.ConfigureUtil;
@@ -29,7 +30,7 @@ public StageDsl stage(final String name, final Closure closure) {
             events.add(new PipeEvent("ProjectName", "Success", stage.getDescription(), ""));
             stages.add(stage);
             return stage;
-        } catch (Exception e) {
+        } catch (PipelineException e) {
             events.add(new PipeEvent("ProjectName", "Failure", stage.getDescription(), e.getMessage()));
             return stage;
         }

src/main/groovy/org/pipelinelabs/pipeline/dsl/internal/DefaultStageDsl.java

@@ -1,6 +1,7 @@
 package org.pipelinelabs.pipeline.dsl.internal;
 
 import org.pipelinelabs.pipeline.api.Stage;
+import org.pipelinelabs.pipeline.exception.PipelineException;
 import org.pipelinelabs.pipeline.runner.DefaultStage;
 import org.apache.maven.shared.utils.cli.CommandLineException;
 import org.apache.maven.shared.utils.cli.CommandLineUtils;
@@ -71,7 +72,7 @@ public void run() {
             final int exitStatus = executeCommand(cl, createStreamingConsumer(out), createStreamingConsumer(err));
             if (0 != exitStatus) {
                 final String msg = "Error occurred during execution of command [%s]";
-                throw new RuntimeException(String.format(msg, command));
+                throw new PipelineException(String.format(msg, command));
             }
         }
 
@@ -81,7 +82,7 @@ private int executeCommand(final Commandline cl,
             try {
                 exitStatus = CommandLineUtils.executeCommandLine(cl, stdOut, stdErr);
             } catch (CommandLineException e) {
-                throw new RuntimeException("Failed to execute command", e);
+                throw new PipelineException("Failed to execute command", e);
             }
             return exitStatus;
         }

src/main/groovy/org/pipelinelabs/pipeline/exception/PipelineException.java

@@ -0,0 +1,19 @@
+package org.pipelinelabs.pipeline.exception;
+
+public class PipelineException extends RuntimeException {
+    public PipelineException() {
+        super();
+    }
+
+    public PipelineException(String message) {
+        super(message);
+    }
+
+    public PipelineException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    public PipelineException(Throwable cause) {
+        super(cause);
+    }
+}

src/test/groovy/org/pipelinelabs/pipeline/messenger/internal/AggregateMessengerSpec.groovy

@@ -9,7 +9,7 @@ import org.pipelinelabs.pipeline.messenger.SpecializedMessenger
 
 class AggregateMessengerSpec extends Specification {
     MessageContext context = Mock()
-    PipeEvent event = Mock()
+    PipeEvent event = new PipeEvent('', '', '', '')
 
     def 'if no messengers, does nothing'() {
         given:

src/test/groovy/org/pipelinelabs/pipeline/messenger/internal/EmailMessengerSpec.groovy

@@ -27,12 +27,11 @@ class EmailMessengerSpec extends Specification {
 
     def 'process generates the correct email'() {
         given:
-        PipeEvent event = [
-            getName: { 'MyProject' },
-            getStatus: { 'Success' },
-            getDescription: { 'Gradle build succeeded in 10 seconds.' },
-            getDetails: { 'a bunch of\nlog data\n' }
-        ] as PipeEvent
+        PipeEvent event = new PipeEvent(
+            'MyProject',
+            'Success',
+            'Gradle build succeeded in 10 seconds.',
+            'a bunch of\nlog data\n')
         def from = '[email protected]'
         def to = ['[email protected]', '[email protected]']
         def cc = ['[email protected]']