sdk/samples/WCFSamples/TechnologySamples/Extensibility/Channels/MessageInterceptor/CS/service/service.cs

   1
   2 //  Copyright (c) Microsoft Corporation.  All Rights Reserved.
   3
   4 using System;
   5
   6 using System.ServiceModel.Channels;
   7 using System.ServiceModel;
   8 using System.Configuration;
   9 using System.Collections;
  10
  11 namespace Microsoft.ServiceModel.Samples
  12 {
  13     // Create a service contract and define the service operations.
  14     [ServiceContract]
  15     public interface ISampleContract
  16     {
  17         [OperationContract(IsOneWay = true)]
  18         void ReportWindSpeed(int speed);
  19     }
  20
  21     // The Service implementation implements your service contract.
  22     public class SampleService : ISampleContract
  23     {
  24         public void ReportWindSpeed(int speed)
  25         {
  26             if (speed >= 64)
  27             {
  28                 Console.WriteLine("Dangerous wind detected! Reported speed (" + speed + ") is greater than 64 kph.");
  29             }
  30         }
  31     }
  32
  33     class DroppingServerElement : InterceptingElement
  34     {
  35         protected override ChannelMessageInterceptor CreateMessageInterceptor()
  36         {
  37             return new DroppingServerInterceptor();
  38         }
  39     }
  40
  41     public class DroppingServerInterceptor : ChannelMessageInterceptor
  42     {
  43         int messagesSinceLastReport = 0;
  44         readonly int reportPeriod = 5;
  45
  46         public DroppingServerInterceptor() { }
  47
  48         public override void OnReceive(ref Message msg)
  49         {
  50             if (msg.Headers.FindHeader("ByPass", "urn:InterceptorNamespace") > 0)
  51             {
  52                 if (++messagesSinceLastReport == this.reportPeriod)
  53                 {
  54                     Console.WriteLine(reportPeriod + " wind speed reports have been received.");
  55                 }
  56                 return;
  57             }
  58             // Drop incoming Message if the Message does not have the special header
  59             msg = null;
  60         }
  61
  62         public override ChannelMessageInterceptor Clone()
  63         {
  64             return new DroppingServerInterceptor();
  65         }
  66     }
  67
  68     class Service
  69     {
  70         static void Main(string[] args)
  71         {
  72             ServiceHost serviceHost = new ServiceHost(typeof(SampleService));
  73             bool success = false;
  74
  75             try
  76             {
  77                 serviceHost.Open();
  78
  79                 System.Console.WriteLine("Press ENTER to exit.");
  80                 System.Console.ReadLine();
  81
  82                 serviceHost.Close();
  83                 success = true;
  84             }
  85             finally
  86             {
  87                 if (!success)
  88                     serviceHost.Abort();
  89             }
  90         }
  91     }
  92 }