Fixed example spelling

Examples/Example1/CompnentBased/Channels.cs → Examples/Example1/ComponentBased/Channels.cs

@@ -1,7 +1,7 @@
 using System;
 using Fibrous;
 
-namespace Example1.CompnentBased
+namespace Example1.ComponentBased
 {
     public class Channels
     {

Examples/Example1/CompnentBased/ISomeDataAccess.cs → Examples/Example1/ComponentBased/ISomeDataAccess.cs

@@ -1,6 +1,6 @@
 using System;
 
-namespace Example1.CompnentBased
+namespace Example1.ComponentBased
 {
     public interface ISomeDataAccess
     {

Examples/Example1/CompnentBased/ISomeService.cs → Examples/Example1/ComponentBased/ISomeService.cs

@@ -1,6 +1,6 @@
 using System;
 
-namespace Example1.CompnentBased
+namespace Example1.ComponentBased
 {
     public interface ISomeService
     {

Examples/Example1/CompnentBased/Payload.cs → Examples/Example1/ComponentBased/Payload.cs

@@ -1,6 +1,6 @@
 using System.Collections.Generic;
 
-namespace Example1.CompnentBased
+namespace Example1.ComponentBased
 {
     public class Payload
     {

Examples/Example1/CompnentBased/Stage1.cs → Examples/Example1/ComponentBased/Stage1.cs

@@ -2,7 +2,7 @@
 using Fibrous;
 using Fibrous.Pipelines;
 
-namespace Example1.CompnentBased
+namespace Example1.ComponentBased
 {
     public class Stage1 : IProcessor<Payload, Payload>
     {

Examples/Example1/ComponentBased/Stage2.cs

@@ -0,0 +1,30 @@
+using System;
+using Fibrous;
+using Fibrous.Pipelines;
+
+namespace Example1.ComponentBased;
+
+public class Stage2 : IProcessor<Payload, Payload>
+{
+    private readonly ISomeDataAccess _dal;
+
+    public Stage2(ISomeDataAccess service)
+    {
+        _dal = service;
+    }
+
+    public event Action<Payload>   Output;
+    public event Action<Exception> Exception;
+
+    public void Process(Payload input)
+    {
+        //Do some other things and save to a database
+        _dal.SaveData(input);
+        Output?.Invoke(input);
+    }
+
+    public void Initialize(IScheduler scheduler)
+    {
+        //If we don't need scheduling for this stage, leave empty
+    }
+}

Examples/Example1/PipelineExample.cs

@@ -1,6 +1,6 @@
 using System;
 using System.IO;
-using Example1.CompnentBased;
+using Example1.ComponentBased;
 using Fibrous;
 using Fibrous.Pipelines;