mcs/class/Microsoft.Web.Services/Microsoft.Web.Services.Messaging/SoapReceivers.cs

   1 //
   2 // Microsoft.Web.Services.Messaging.SoapReceivers
   3 //
   4 // Author: Todd Berman <tberman@gentoo.org>
   5 //
   6 // (C) 2003 Todd Berman
   7
   8 using System;
   9 using System.Collections;
  10 using Microsoft.Web.Services.Configuration;
  11
  12 namespace Microsoft.Web.Services.Messaging
  13 {
  14
  15         public class SoapReceivers
  16         {
  17
  18                 private static Hashtable _receivers = new Hashtable ();
  19
  20                 private SoapReceivers () { }
  21
  22                 public static void Add (Uri uri, SoapReceiver receiver)
  23                 {
  24                         Add (uri, receiver, false);
  25                 }
  26
  27                 public static void Add (Uri uri, Type type)
  28                 {
  29                         Add (uri, type, false);
  30                 }
  31
  32                 public static void Add (Uri uri, SoapReceiver receiver, bool passive)
  33                 {
  34                         if(uri == null) {
  35                                 throw new ArgumentNullException ("uri");
  36                         }
  37                         if(receiver == null) {
  38                                 throw new ArgumentNullException ("receiver");
  39                         }
  40
  41                         lock(SyncRoot) {
  42                                 if(_receivers.Contains (uri)) {
  43                                         throw new ArgumentException ("An item with this key already exists");
  44                                 }
  45
  46                                 if(passive == false) {
  47                                         ISoapTransport trans = WebServicesConfiguration.MessagingConfiguration.GetTransport (uri.Scheme);
  48
  49                                         if(trans != null) {
  50                                                 trans.RegisterPort (uri, receiver);
  51                                         } else {
  52                                                 throw new NotSupportedException ("Transport " + uri.Scheme + " not supported.");
  53                                         }
  54                                 }
  55
  56                                 _receivers.Add (uri, receiver);
  57                         }
  58                 }
  59
  60                 public static void Add (Uri uri, Type type, bool passive)
  61                 {
  62                         if(uri == null) {
  63                                 throw new ArgumentNullException ("uri");
  64                         }
  65                         if(type == null) {
  66                                 throw new ArgumentNullException ("type");
  67                         }
  68                         lock(SyncRoot) {
  69                                 if(_receivers.Contains (uri)) {
  70                                         throw new ArgumentException ("An item with this key already exists");
  71                                 }
  72
  73                                 if(passive == false) {
  74                                         ISoapTransport trans = WebServicesConfiguration.MessagingConfiguration.GetTransport (uri.Scheme);
  75
  76                                         if(trans != null) {
  77                                                 trans.RegisterPort (uri, type);
  78                                         } else {
  79                                                 throw new NotSupportedException ("Transport " + uri.Scheme + " is not supported");
  80                                         }
  81                                 }
  82
  83                                 _receivers.Add (uri, type);
  84                         }
  85                 }
  86
  87                 public static void Clear ()
  88                 {
  89                         lock(SyncRoot) {
  90                                 foreach(ISoapTransport trans in WebServicesConfiguration.MessagingConfiguration.Transports) {
  91                                         trans.UnregisterAll ();
  92                                 }
  93                                 _receivers.Clear ();
  94                         }
  95                 }
  96
  97                 public static bool Contains (Uri to)
  98                 {
  99                         if(to == null) {
 100                                 throw new ArgumentNullException ("to");
 101                         }
 102                         bool retVal = false;
 103                         lock(SyncRoot) {
 104                                 retVal = _receivers.Contains (to);
 105                         }
 106                         return retVal;
 107                 }
 108
 109                 public static IDictionaryEnumerator GetEnumerator ()
 110                 {
 111                         return _receivers.GetEnumerator ();
 112                 }
 113
 114                 public static object Receiver (Uri to)
 115                 {
 116                         return _receivers[to];
 117                 }
 118
 119                 public static void Remove (Uri to)
 120                 {
 121                         if(to == null) {
 122                                 throw new ArgumentNullException ("to");
 123                         }
 124
 125                         lock(SyncRoot) {
 126                                 if(_receivers.Contains (to) == false) {
 127                                         ISoapTransport trans = WebServicesConfiguration.MessagingConfiguration.GetTransport (to.Scheme);
 128                                         if(trans != null) {
 129                                                 trans.UnregisterPort (to);
 130                                                 _receivers.Remove (to);
 131                                         }
 132                                 }
 133                         }
 134                 }
 135
 136                 public static int Count {
 137                         get { return _receivers.Values.Count; }
 138                 }
 139
 140                 public static object SyncRoot {
 141                         get { return _receivers.SyncRoot; }
 142                 }
 143         }
 144 }