sdk/samples/WCFSamples/TechnologySamples/Extensibility/Instancing/Durable/CS/extensions/OperationInvoker.cs

   1 using System;
   2 using System.Collections.Generic;
   3 using System.Text;
   4 using System.ServiceModel;
   5 using System.ServiceModel.Dispatcher;
   6
   7 namespace Microsoft.ServiceModel.Samples
   8 {
   9
  10     //This class contains the implementation of IOperationInvoker
  11     //which is used to persist the service instance after invoking the
  12     //operation.
  13     class OperationInvoker : IOperationInvoker
  14     {
  15         IOperationInvoker innerOperationInvoker;
  16
  17         public OperationInvoker(IOperationInvoker innerOperationInvoker)
  18         {
  19             this.innerOperationInvoker = innerOperationInvoker;
  20         }
  21
  22         public object[] AllocateInputs()
  23         {
  24             return innerOperationInvoker.AllocateInputs();
  25         }
  26
  27         public object Invoke(object instance, object[] inputs, out object[] outputs)
  28         {
  29             // Invoke the operation using the inner operation
  30             // invoker.
  31             object result = innerOperationInvoker.Invoke(instance,
  32                 inputs, out outputs);
  33
  34             // Save the instance using the storage manager saved in the
  35             // current InstanceContext.
  36             InstanceContextExtension extension =
  37                 OperationContext.Current.InstanceContext.Extensions.Find<InstanceContextExtension>();
  38
  39             extension.StorageManager.SaveInstance(extension.ContextId, instance);
  40             return result;
  41         }
  42
  43         public IAsyncResult InvokeBegin(object instance, object[] inputs,
  44             AsyncCallback callback, object state)
  45         {
  46             return innerOperationInvoker.InvokeBegin(instance, inputs, callback, state);
  47         }
  48
  49         public object InvokeEnd(object instance, out object[] outputs, IAsyncResult asyncResult)
  50         {
  51             // Finish invoking the operation using the inner operation
  52             // invoker.
  53             object result = innerOperationInvoker.InvokeEnd(instance, out outputs, asyncResult);
  54
  55             // Save the instance using the storage manager saved in the
  56             // current InstanceContext.
  57             InstanceContextExtension extension =
  58                 OperationContext.Current.InstanceContext.Extensions.Find<InstanceContextExtension>();
  59
  60             extension.StorageManager.SaveInstance(extension.ContextId, instance);
  61             return result;
  62         }
  63
  64         public bool IsSynchronous
  65         {
  66             get { return innerOperationInvoker.IsSynchronous; }
  67         }
  68     }
  69 }