Facilities/Wcf/Castle.Facilities.WcfIntegration/WcfClientActivator.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 Castle.Facilities.WcfIntegration
  16 {
  17         using System;
  18         using Castle.Core;
  19         using Castle.MicroKernel;
  20         using Castle.MicroKernel.ComponentActivator;
  21
  22         internal delegate object CreateChannel();
  23
  24         public class WcfClientActivator : AbstractComponentActivator
  25         {
  26                 private readonly CreateChannel createChannel;
  27
  28                 public WcfClientActivator(ComponentModel model, IKernel kernel,
  29                         ComponentInstanceDelegate onCreation, ComponentInstanceDelegate onDestruction)
  30                         : base(model, kernel, onCreation, onDestruction)
  31                 {
  32                         WcfClientModel clientModel = (WcfClientModel)
  33                                 model.ExtendedProperties[WcfConstants.ClientModelKey];
  34                         createChannel = clientModel.GetChannelBuilder(model.Service);
  35                 }
  36
  37                 protected override object InternalCreate(CreationContext context)
  38                 {
  39                         WcfClientModel clientModelOverride = GetClientModelOverride(context);
  40
  41                         if (clientModelOverride != null)
  42                         {
  43                                 return clientModelOverride.GetChannelBuilder(Model.Service)();
  44                         }
  45                         else
  46                         {
  47                                 return createChannel();
  48                         }
  49                 }
  50
  51                 protected override void InternalDestroy(object instance)
  52                 {
  53                 }
  54
  55                 private WcfClientModel GetClientModelOverride(CreationContext context)
  56                 {
  57                         WcfClientModel clientModel = null;
  58                         Predicate<WcfClientModel> contractMatch = delegate(WcfClientModel candidate)
  59                         {
  60                                 return candidate.Contract == null ||
  61                                         (Model.Service == candidate.Contract);
  62                         };
  63
  64                         if (context != null && context.HasAdditionalParameters)
  65                         {
  66                                 if (WcfUtils.FindDependency<WcfClientModel>(
  67                                                 context.AdditionalParameters, contractMatch,
  68                                                 out clientModel))
  69                                 {
  70                                         return clientModel;
  71                                 }
  72                         }
  73                         return clientModel;
  74                 }
  75         }
  76 }
  77