diff --git a/samples/apis/SagasTest.Api/Activities/Transaction1CompensateErrorActivity.cs b/samples/apis/SagasTest.Api/Activities/Transaction1CompensateErrorActivity.cs
new file mode 100644
index 0000000..ddad902
--- /dev/null
+++ b/samples/apis/SagasTest.Api/Activities/Transaction1CompensateErrorActivity.cs
@@ -0,0 +1,31 @@
+using Pole.Sagas.Core;
+using Pole.Sagas.Core.Abstraction;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net.Http;
+using System.Threading.Tasks;
+
+namespace SagasTest.Api.Activities
+{
+    public class Transaction1CompensateErrorActivity : IActivity<Transaction1Dto>
+    {
+        private readonly IHttpClientFactory httpClientFactory;
+        public Transaction1CompensateErrorActivity(IHttpClientFactory httpClientFactory)
+        {
+            this.httpClientFactory = httpClientFactory;
+        }
+        public Task Compensate(Transaction1Dto data)
+        {
+            throw new NotImplementedException();
+        }
+
+        public async Task<ActivityExecuteResult> Execute(Transaction1Dto data)
+        {
+            var httpclient = httpClientFactory.CreateClient();
+            httpclient.BaseAddress = new Uri("http://localhost:5000");
+            var result = await httpclient.GetAsync("api/OutGoingMock/Transaction1Ok");
+            return ActivityExecuteResult.Success;
+        }
+    }
+}
diff --git a/samples/apis/SagasTest.Api/Activities/Transaction1ExceptionActivity.cs b/samples/apis/SagasTest.Api/Activities/Transaction1ExceptionActivity.cs
new file mode 100644
index 0000000..1f64ab8
--- /dev/null
+++ b/samples/apis/SagasTest.Api/Activities/Transaction1ExceptionActivity.cs
@@ -0,0 +1,31 @@
+using Pole.Sagas.Core;
+using Pole.Sagas.Core.Abstraction;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net.Http;
+using System.Threading.Tasks;
+
+namespace SagasTest.Api.Activities
+{
+    public class Transaction1ExceptionActivity : IActivity<Transaction1Dto>
+    {
+        private readonly IHttpClientFactory httpClientFactory;
+        public Transaction1ExceptionActivity(IHttpClientFactory httpClientFactory)
+        {
+            this.httpClientFactory = httpClientFactory;
+
+        }
+        public async Task Compensate(Transaction1Dto data)
+        {
+            var httpclient = httpClientFactory.CreateClient();
+            httpclient.BaseAddress = new Uri("http://localhost:5000");
+            var result = await httpclient.GetAsync("api/OutGoingMock/Transaction1RollBack");
+        }
+
+        public Task<ActivityExecuteResult> Execute(Transaction1Dto data)
+        {
+            throw new NotImplementedException();
+        }
+    }
+}
diff --git a/samples/apis/SagasTest.Api/Activities/Transaction1OkActivity.cs b/samples/apis/SagasTest.Api/Activities/Transaction1OkActivity.cs
index d701ac2..df23b98 100644
--- a/samples/apis/SagasTest.Api/Activities/Transaction1OkActivity.cs
+++ b/samples/apis/SagasTest.Api/Activities/Transaction1OkActivity.cs
@@ -13,8 +13,7 @@ namespace SagasTest.Api.Activities
         private readonly IHttpClientFactory httpClientFactory;
         public Transaction1OkActivity(IHttpClientFactory httpClientFactory)
         {
-            this.httpClientFactory = httpClientFactory;
-            
+            this.httpClientFactory = httpClientFactory;            
         }
         public async Task Compensate(Transaction1Dto data)
         {
diff --git a/samples/apis/SagasTest.Api/Activities/Transaction2CompensateErrorActivity.cs b/samples/apis/SagasTest.Api/Activities/Transaction2CompensateErrorActivity.cs
new file mode 100644
index 0000000..85af77c
--- /dev/null
+++ b/samples/apis/SagasTest.Api/Activities/Transaction2CompensateErrorActivity.cs
@@ -0,0 +1,31 @@
+using Pole.Sagas.Core;
+using Pole.Sagas.Core.Abstraction;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net.Http;
+using System.Threading.Tasks;
+
+namespace SagasTest.Api.Activities
+{
+    public class Transaction2CompensateErrorActivity : IActivity<Transaction2Dto>
+    {
+        private readonly IHttpClientFactory httpClientFactory;
+        public Transaction2CompensateErrorActivity(IHttpClientFactory httpClientFactory)
+        {
+            this.httpClientFactory = httpClientFactory;
+        }
+        public Task Compensate(Transaction2Dto data)
+        {
+            throw new NotImplementedException();
+        }
+
+        public async Task<ActivityExecuteResult> Execute(Transaction2Dto data)
+        {
+            var httpclient = httpClientFactory.CreateClient();
+            httpclient.BaseAddress = new Uri("http://localhost:5000");
+            var result = await httpclient.GetAsync("api/OutGoingMock/Transaction2Ok");
+            return ActivityExecuteResult.Success;
+        }
+    }
+}
diff --git a/samples/apis/SagasTest.Api/Activities/Transaction2ExceptionActivity.cs b/samples/apis/SagasTest.Api/Activities/Transaction2ExceptionActivity.cs
new file mode 100644
index 0000000..4118a8b
--- /dev/null
+++ b/samples/apis/SagasTest.Api/Activities/Transaction2ExceptionActivity.cs
@@ -0,0 +1,31 @@
+using Pole.Sagas.Core;
+using Pole.Sagas.Core.Abstraction;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net.Http;
+using System.Threading.Tasks;
+
+namespace SagasTest.Api.Activities
+{
+    public class Transaction2ExceptionActivity : IActivity<Transaction2Dto>
+    {
+        private readonly IHttpClientFactory httpClientFactory;
+        public Transaction2ExceptionActivity(IHttpClientFactory httpClientFactory)
+        {
+            this.httpClientFactory = httpClientFactory;
+
+        }
+        public async Task Compensate(Transaction2Dto data)
+        {
+            var httpclient = httpClientFactory.CreateClient();
+            httpclient.BaseAddress = new Uri("http://localhost:5000");
+            var result = await httpclient.GetAsync("api/OutGoingMock/Transaction2RollBack");
+        }
+
+        public Task<ActivityExecuteResult> Execute(Transaction2Dto data)
+        {
+            throw new NotImplementedException();
+        }
+    }
+}
diff --git a/samples/apis/SagasTest.Api/Activities/Transaction2OkActivity.cs b/samples/apis/SagasTest.Api/Activities/Transaction2OkActivity.cs
index 90c24fd..24c19e4 100644
--- a/samples/apis/SagasTest.Api/Activities/Transaction2OkActivity.cs
+++ b/samples/apis/SagasTest.Api/Activities/Transaction2OkActivity.cs
@@ -14,7 +14,6 @@ namespace SagasTest.Api.Activities
         public Transaction2OkActivity(IHttpClientFactory httpClientFactory)
         {
             this.httpClientFactory = httpClientFactory;
-
         }
         public async Task Compensate(Transaction2Dto data)
         {
diff --git a/samples/apis/SagasTest.Api/Activities/Transaction3ExceptionActivity.cs b/samples/apis/SagasTest.Api/Activities/Transaction3ExceptionActivity.cs
new file mode 100644
index 0000000..57b3da2
--- /dev/null
+++ b/samples/apis/SagasTest.Api/Activities/Transaction3ExceptionActivity.cs
@@ -0,0 +1,23 @@
+using Pole.Sagas.Core;
+using Pole.Sagas.Core.Abstraction;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace SagasTest.Api.Activities
+{
+    public class Transaction3ExceptionActivity : IActivity<Transaction3Dto>
+    {
+        public Task Compensate(Transaction3Dto data)
+        {
+            Console.WriteLine("Transaction3 Rollback");
+            return Task.CompletedTask;
+        }
+
+        public Task<ActivityExecuteResult> Execute(Transaction3Dto data)
+        {
+            throw new NotImplementedException();
+        }
+    }
+}
diff --git a/samples/apis/SagasTest.Api/Controllers/SagasTestController.cs b/samples/apis/SagasTest.Api/Controllers/SagasTestController.cs
index 0040a1b..70a0bc5 100644
--- a/samples/apis/SagasTest.Api/Controllers/SagasTestController.cs
+++ b/samples/apis/SagasTest.Api/Controllers/SagasTestController.cs
@@ -62,7 +62,61 @@ namespace SagasTest.Api.Controllers
 
             var result = await sagas.GetResult();
         }
+        [HttpGet("Transaction3Exception")]
+        public async Task Transaction3Exception()
+        {
+            var sagas = sagaFactory.CreateSaga();
+
+            sagas.AddActivity("Transaction1Ok", new Transaction1Dto { Id = 1, Name = "22" });
+            sagas.AddActivity("Transaction2Ok", new Transaction2Dto { Price = 1, Message = "我们" });
+            sagas.AddActivity("Transaction3Exception", new Transaction3Dto { Age = 1, Name = "333" });
+
+            var result = await sagas.GetResult();
+        }
+        [HttpGet("Transaction2Exception")]
+        public async Task Transaction2Exception()
+        {
+            var sagas = sagaFactory.CreateSaga();
 
+            sagas.AddActivity("Transaction1Ok", new Transaction1Dto { Id = 1, Name = "22" });
+            sagas.AddActivity("Transaction2Exception", new Transaction2Dto { Price = 1, Message = "我们" });
+            sagas.AddActivity("Transaction3HasResult", new Transaction3Dto { Age = 1, Name = "333" });
+
+            var result = await sagas.GetResult();
+        }
+        [HttpGet("Transaction1Exception")]
+        public async Task Transaction1Exception()
+        {
+            var sagas = sagaFactory.CreateSaga();
+
+            sagas.AddActivity("Transaction1Exception", new Transaction1Dto { Id = 1, Name = "22" });
+            sagas.AddActivity("Transaction2Ok", new Transaction2Dto { Price = 1, Message = "我们" });
+            sagas.AddActivity("Transaction3HasResult", new Transaction3Dto { Age = 1, Name = "333" });
+
+            var result = await sagas.GetResult();
+        }
+        [HttpGet("Transaction2CompensateError")]
+        public async Task Transaction2CompensateError()
+        {
+            var sagas = sagaFactory.CreateSaga();
+
+            sagas.AddActivity("Transaction1Ok", new Transaction1Dto { Id = 1, Name = "22" });
+            sagas.AddActivity("Transaction2CompensateError", new Transaction2Dto { Price = 1, Message = "我们" });
+            sagas.AddActivity("Transaction3Exception", new Transaction3Dto { Age = 1, Name = "333" });
+
+            var result = await sagas.GetResult();
+        }
+        [HttpGet("Transaction1CompensateError")]
+        public async Task Transaction1CompensateError()
+        {
+            var sagas = sagaFactory.CreateSaga();
+
+            sagas.AddActivity("Transaction1CompensateError", new Transaction1Dto { Id = 1, Name = "22" });
+            sagas.AddActivity("Transaction2Ok", new Transaction2Dto { Price = 1, Message = "我们" });
+            sagas.AddActivity("Transaction3Exception", new Transaction3Dto { Age = 1, Name = "333" });
+
+            var result = await sagas.GetResult();
+        }
         // GET api/values/5
         [HttpGet("{id}")]
         public ActionResult<string> Get(int id)
diff --git a/src/Pole.Sagas/Core/Saga.cs b/src/Pole.Sagas/Core/Saga.cs
index 72213c9..259f46b 100644
--- a/src/Pole.Sagas/Core/Saga.cs
+++ b/src/Pole.Sagas/Core/Saga.cs
@@ -80,7 +80,7 @@ namespace Pole.Sagas.Core
                 return null;
             }
             _currentExecuteOrder++;
-            return activities[_currentExecuteOrder-1];
+            return activities[_currentExecuteOrder - 1];
         }
         private ActivityWapper GetNextCompensateActivity()
         {
@@ -90,7 +90,7 @@ namespace Pole.Sagas.Core
                 return null;
             }
 
-            return activities[_currentCompensateOrder-1];
+            return activities[_currentCompensateOrder - 1];
         }
         private async Task RecursiveCompensateActivity(ActivityWapper activityWapper)
         {
@@ -123,9 +123,7 @@ namespace Pole.Sagas.Core
                 if (!result.IsSuccess)
                 {
                     await eventSender.ActivityExecuteAborted(activityId, serializer.Serialize(result.Result), string.Empty);
-                    _currentCompensateOrder = _currentExecuteOrder;
-                    var compensateActivity = GetNextCompensateActivity();
-                    await RecursiveCompensateActivity(compensateActivity);
+                    await CompensateActivity(result);
                     return result;
                 }
                 await eventSender.ActivityEnded(activityId, string.Empty);
@@ -142,13 +140,26 @@ namespace Pole.Sagas.Core
             catch (Exception exception)
             {
                 var errors = exception.InnerException != null ? exception.InnerException.Message + exception.StackTrace : exception.Message + exception.StackTrace;
-                await eventSender.ActivityExecuteAborted(activityId, string.Empty, errors);
-                return new ActivityExecuteResult
+                var result = new ActivityExecuteResult
                 {
                     IsSuccess = false,
                     Errors = errors
                 };
+                await eventSender.ActivityExecuteAborted(activityId, string.Empty, errors);
+                return await CompensateActivity(result);
+            }
+        }
+
+        private async Task<ActivityExecuteResult> CompensateActivity(ActivityExecuteResult result)
+        {
+            _currentCompensateOrder = _currentExecuteOrder;
+            var compensateActivity = GetNextCompensateActivity();
+            if (compensateActivity == null)
+            {
+                return result;
             }
+            await RecursiveCompensateActivity(compensateActivity);
+            return result;
         }
     }
 }
diff --git a/src/Pole.Sagas/Core/SagaStatus.cs b/src/Pole.Sagas/Core/SagaStatus.cs
new file mode 100644
index 0000000..59940dd
--- /dev/null
+++ b/src/Pole.Sagas/Core/SagaStatus.cs
@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace Pole.Sagas.Core
+{
+    enum SagaStatus
+    {
+        Started,
+        Ended,
+        Error
+    }
+}