Samples/InversionOfControl/AnotherExtendingSample/TransactionInterceptor.cs

   1 // Copyright 2004-2008 Castle Project - http://www.castleproject.org/
   2 //
   3 // Licensed under the Apache License, Version 2.0 (the "License");
   4 // you may not use this file except in compliance with the License.
   5 // You may obtain a copy of the License at
   6 //
   7 //     http://www.apache.org/licenses/LICENSE-2.0
   8 //
   9 // Unless required by applicable law or agreed to in writing, software
  10 // distributed under the License is distributed on an "AS IS" BASIS,
  11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12 // See the License for the specific language governing permissions and
  13 // limitations under the License.
  14
  15 namespace Extending2
  16 {
  17         using System;
  18
  19         using Castle.Core.Interceptor;
  20
  21         /// <summary>
  22         /// Summary description for TransactionInterceptor.
  23         /// </summary>
  24         public class TransactionInterceptor : IMethodInterceptor
  25         {
  26                 private ITransactionManager _transactionManager;
  27                 private TransactionConfigHolder _transactionConfHolder;
  28
  29                 public TransactionInterceptor(ITransactionManager transactionManager,
  30                         TransactionConfigHolder transactionConfHolder)
  31                 {
  32                         _transactionManager = transactionManager;
  33                         _transactionConfHolder = transactionConfHolder;
  34                 }
  35
  36                 public object Intercept(IMethodInvocation invocation, params object[] args)
  37                 {
  38                         if (_transactionManager.CurrentTransaction != null)
  39                         {
  40                                 // No support for nested transactions
  41                                 // is necessary
  42                                 return invocation.Proceed(args);
  43                         }
  44
  45                         TransactionConfig config =
  46                                 _transactionConfHolder.GetConfig(
  47                                         invocation.Method.DeclaringType );
  48
  49                         if (config != null && config.IsMethodTransactional( invocation.Method ))
  50                         {
  51                                 ITransaction transaction =
  52                                         _transactionManager.CreateTransaction();
  53
  54                                 object value = null;
  55
  56                                 try
  57                                 {
  58                                         value = invocation.Proceed(args);
  59
  60                                         transaction.Commit();
  61                                 }
  62                                 catch(Exception ex)
  63                                 {
  64                                         transaction.Rollback();
  65
  66                                         throw ex;
  67                                 }
  68                                 finally
  69                                 {
  70                                         _transactionManager.Release(transaction);
  71                                 }
  72
  73                                 return value;
  74                         }
  75                         else
  76                         {
  77                                 return invocation.Proceed(args);
  78                         }
  79                 }
  80         }
  81 }