1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
|
//------------------------------------------------------------------------------
// <copyright file="WorkflowTransactionService.cs" company="Microsoft">
// Copyright (c) Microsoft Corporation. All rights reserved.
// </copyright>
//------------------------------------------------------------------------------
#region Using directives
using System;
using System.Transactions;
#endregion
namespace System.Workflow.Runtime.Hosting
{
[Obsolete("The System.Workflow.* types are deprecated. Instead, please use the new types from System.Activities.*")]
public abstract class WorkflowCommitWorkBatchService : WorkflowRuntimeService
{
public delegate void CommitWorkBatchCallback();
virtual internal protected void CommitWorkBatch(CommitWorkBatchCallback commitWorkBatchCallback)
{
Transaction tx = null;
if (null == Transaction.Current)
tx = new CommittableTransaction();
else
tx = Transaction.Current.DependentClone(DependentCloneOption.BlockCommitUntilComplete);
try
{
using (TransactionScope ts = new TransactionScope(tx))
{
commitWorkBatchCallback();
ts.Complete();
}
CommittableTransaction committableTransaction = tx as CommittableTransaction;
if (committableTransaction != null)
committableTransaction.Commit();
DependentTransaction dependentTransaction = tx as DependentTransaction;
if (dependentTransaction != null)
dependentTransaction.Complete();
}
catch (Exception e)
{
tx.Rollback(e);
throw;
}
finally
{
if (tx != null)
{
tx.Dispose();
}
}
}
}
}
|
