Facilities/Wcf/Castle.Facilities.WcfIntegration/Client/AbstractChannelBuilder.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 System.ServiceModel;
  19         using System.ServiceModel.Description;
  20         using System.ServiceModel.Channels;
  21         using Castle.MicroKernel;
  22
  23         public abstract class AbstractChannelBuilder : IWcfEndpointVisitor
  24         {
  25                 private Type contract;
  26                 private readonly IKernel kernel;
  27                 private ChannelCreator channelCreator;
  28
  29                 public AbstractChannelBuilder(IKernel kernel)
  30                 {
  31                         this.kernel = kernel;
  32                 }
  33
  34                 protected IKernel Kernel
  35                 {
  36                         get { return kernel; }
  37                 }
  38
  39                 protected ChannelCreator GetEndpointChannelCreator(IWcfEndpoint endpoint)
  40                 {
  41                         return GetEndpointChannelCreator(endpoint, null);
  42                 }
  43
  44                 protected ChannelCreator GetEndpointChannelCreator(IWcfEndpoint endpoint, Type contract)
  45                 {
  46                         this.contract = contract ?? endpoint.Contract;
  47                         endpoint.Accept(this);
  48                         return channelCreator;
  49                 }
  50
  51                 protected abstract ChannelCreator GetChannel(Type contract);
  52                 protected abstract ChannelCreator GetChannel(Type contract, ServiceEndpoint endpoint);
  53                 protected abstract ChannelCreator GetChannel(Type contract, string configurationName);
  54                 protected abstract ChannelCreator GetChannel(Type contract, Binding binding, string address);
  55                 protected abstract ChannelCreator GetChannel(Type contract, Binding binding, EndpointAddress address);
  56
  57                 #region IWcfEndpointVisitor Members
  58
  59                 void IWcfEndpointVisitor.VisitContractEndpoint(ContractEndpointModel model)
  60                 {
  61                         channelCreator = GetChannel(contract);
  62                 }
  63
  64                 void IWcfEndpointVisitor.VisitServiceEndpoint(ServiceEndpointModel model)
  65                 {
  66                         channelCreator = GetChannel(contract, model.ServiceEndpoint);
  67                 }
  68
  69                 void IWcfEndpointVisitor.VisitConfigurationEndpoint(ConfigurationEndpointModel model)
  70                 {
  71                         channelCreator = GetChannel(contract, model.EndpointName);
  72                 }
  73
  74                 void IWcfEndpointVisitor.VisitBindingEndpoint(BindingEndpointModel model)
  75                 {
  76                         channelCreator = GetChannel(contract, model.Binding, string.Empty);
  77                 }
  78
  79                 void IWcfEndpointVisitor.VisitBindingAddressEndpoint(BindingAddressEndpointModel model)
  80                 {
  81                         if (model.HasViaAddress)
  82                         {
  83                                 EndpointAddress address = model.EndpointAddress ?? new EndpointAddress(model.Address);
  84                                 ContractDescription description = ContractDescription.GetContract(contract);
  85                                 ServiceEndpoint endpoint = new ServiceEndpoint(description, model.Binding, address);
  86                                 endpoint.Behaviors.Add(new ClientViaBehavior(model.ViaAddress));
  87                                 channelCreator = GetChannel(contract, endpoint);
  88                         }
  89                         else
  90                         {
  91                                 if (model.EndpointAddress != null)
  92                                 {
  93                                         channelCreator = GetChannel(contract, model.Binding, model.EndpointAddress);
  94                                 }
  95                                 else
  96                                 {
  97                                         channelCreator = GetChannel(contract, model.Binding, model.Address);
  98                                 }
  99                         }
 100                 }
 101
 102                 #endregion
 103         }
 104 }