event.scala

src/main/scala/event.scala

@@ -7,6 +7,18 @@ trait Event {
 
 }
 
+case class LaunchProcess() extends Event {
+}
+
+case class ProcessStarted(processName: String) extends Event {
+}
+
+case class ProcessFailed(processName: String) extends Event {
+}
+
+case class ProcessCompleted(processName: String) extends Event {
+}
+
 trait EventHandler {
   def handle(event: Event, args: Any): Unit;
 }

src/main/scala/flow.scala

@@ -212,23 +212,12 @@ class FlowExecutionImpl(id: String, flow: Flow, args: Map[String, Any])
 
   override def getId(): String = id;
 
-  override def addListener(listener: FlowExecutionListener): Unit = listeners += listener;
+  override def addListener(listener: FlowExecutionListener): Unit =
+    listeners += listener;
 
   override def getFlow(): Flow = flow;
 }
 
-case class LaunchProcess() extends Event {
-}
-
-case class ProcessStarted(processName: String) extends Event {
-}
-
-case class ProcessFailed(processName: String) extends Event {
-}
-
-case class ProcessCompleted(processName: String) extends Event {
-}
-
 class ProcessAsQuartzJob extends Job with Logging {
   override def execute(context: JobExecutionContext): Unit = {
     val map = context.getJobDetail.getJobDataMap;