Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WCF / System.ServiceModel.Activation / System / ServiceModel / Channels / MsmqHostedTransportManager.cs / 1305376 / MsmqHostedTransportManager.cs
//---------------------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------------------- namespace System.ServiceModel.Channels { using System.Collections.Generic; using System.Runtime; using System.ServiceModel; using System.ServiceModel.Activation; using System.Threading; using System.Web; using System.Web.Hosting; class MsmqHostedTransportManager : TransportManager { string[] hosts; ListbindingMonitors; HostedBindingFilter filter; MsmqUri.IAddressTranslator addressing; Action messageReceivedCallback; public MsmqHostedTransportManager(string[] hosts, MsmqUri.IAddressTranslator addressing) { this.hosts = hosts; this.bindingMonitors = new List (); this.addressing = addressing; this.filter = new HostedBindingFilter(HostingEnvironment.ApplicationVirtualPath, addressing); foreach(string host in this.hosts) { MsmqBindingMonitor monitor = new MsmqBindingMonitor(host); monitor.AddFilter(this.filter); this.bindingMonitors.Add(monitor); } foreach(MsmqBindingMonitor monitor in this.bindingMonitors) { monitor.Open(); } } public Uri[] GetBaseAddresses(string virtualPath) { // Make sure this is not called until initialization is done: foreach(MsmqBindingMonitor monitor in this.bindingMonitors) { monitor.WaitForFirstRoundComplete(); } string absoluteVirtualPath = VirtualPathUtility.ToAbsolute(virtualPath, HostingEnvironment.ApplicationVirtualPath); List baseAddresses = new List (this.hosts.Length); string queueName = absoluteVirtualPath.Substring(1); foreach(string host in this.hosts) { bool isPrivate = this.filter.IsPrivateMatch(queueName); Uri uri = this.addressing.CreateUri(host, queueName, isPrivate); baseAddresses.Add(uri); MsmqDiagnostics.FoundBaseAddress(uri, absoluteVirtualPath); } return baseAddresses.ToArray(); } internal override string Scheme { get { return this.addressing.Scheme; } } internal override void OnClose(TimeSpan timeout) { // Nothing to do - we never use the transport manager during normal // operation. } internal override void OnOpen() { // Nothing to do - we only use the transport manager for WebHosted case. } internal override void Register(TransportChannelListener channelListener) { channelListener.SetMessageReceivedCallback(new Action(OnMessageReceived)); } internal void Start(Action messageReceivedCallback) { this.messageReceivedCallback = messageReceivedCallback; } internal override void Unregister(TransportChannelListener channelListener) { // Nothing to do - we never use the transport manager during normal // operation. } void OnMessageReceived() { Action callback = this.messageReceivedCallback; if (callback != null) { callback(); } } class HostedBindingFilter : MsmqBindingFilter { Dictionary privateMatches = new Dictionary (StringComparer.OrdinalIgnoreCase); public HostedBindingFilter(string path, MsmqUri.IAddressTranslator addressing) : base(path, addressing) { } public override object MatchFound(string host, string name, bool isPrivate) { string processedVirtualPath = CreateRelativeVirtualPath(host, name, isPrivate); string relativeServiceFile = ServiceHostingEnvironment.NormalizeVirtualPath(processedVirtualPath); // Compute the remainder path: lock(this) { if(isPrivate) { string baseQueue = CreateBaseQueue(relativeServiceFile); this.privateMatches[baseQueue] = baseQueue; } } // Start the service on a different thread so we can complete // initialization if(CheckServiceExists(relativeServiceFile)) { MsmqDiagnostics.StartingService(host, name, isPrivate, processedVirtualPath); ActionItem.Schedule(StartService, processedVirtualPath); } // no callback state here... return null; } public bool IsPrivateMatch(string processedVirtualPath) { lock(this) { return this.privateMatches.ContainsKey(processedVirtualPath); } } public override void MatchLost(string host, string name, bool isPrivate, object callbackState) { // We don't do anything here - the service will stay alive, // and if the queue ever comes back, then it will begin to // process again. } string CreateRelativeVirtualPath(string host, string name, bool isPrivate) { // the canonical prefix looks something like: "invoices/" // Because the queue name matched, it looks like "invoices/..." // remove the common piece, and prefix with the "~/" home specifier return "~/" + name.Substring(CanonicalPrefix.Length); } string CreateBaseQueue(string serviceFile) { // Clean up the service file... if(serviceFile.StartsWith("~", StringComparison.OrdinalIgnoreCase)) serviceFile = serviceFile.Substring(1); if(serviceFile.StartsWith("/", StringComparison.OrdinalIgnoreCase)) serviceFile = serviceFile.Substring(1); string virtualPath = HostingEnvironment.ApplicationVirtualPath; if(virtualPath.EndsWith("/", StringComparison.OrdinalIgnoreCase)) virtualPath = virtualPath.Substring(0, virtualPath.Length-1); if(virtualPath.StartsWith("/", StringComparison.OrdinalIgnoreCase)) virtualPath = virtualPath.Substring(1); return virtualPath + "/" + serviceFile; } bool CheckServiceExists(string serviceFile) { try { return (ServiceHostingEnvironment.IsConfigurationBasedService(serviceFile) || HostingEnvironmentWrapper.ServiceFileExists(serviceFile)); } catch(ArgumentException ex) { MsmqDiagnostics.ExpectedException(ex); return false; } } void StartService(object state) { try { string processedVirtualPath = (string)state; ServiceHostingEnvironment.EnsureServiceAvailable(processedVirtualPath); } catch(ServiceActivationException e) { // Non-fatal exceptions from the user code are wrapped in ServiceActivationException // The best we can do is to trace them MsmqDiagnostics.ExpectedException(e); } catch(EndpointNotFoundException e) { // This means that the server disappeared between the time we // saw the service, and the time we tried to start it. // That's okay. MsmqDiagnostics.ExpectedException(e); } } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //---------------------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------------------- namespace System.ServiceModel.Channels { using System.Collections.Generic; using System.Runtime; using System.ServiceModel; using System.ServiceModel.Activation; using System.Threading; using System.Web; using System.Web.Hosting; class MsmqHostedTransportManager : TransportManager { string[] hosts; List bindingMonitors; HostedBindingFilter filter; MsmqUri.IAddressTranslator addressing; Action messageReceivedCallback; public MsmqHostedTransportManager(string[] hosts, MsmqUri.IAddressTranslator addressing) { this.hosts = hosts; this.bindingMonitors = new List (); this.addressing = addressing; this.filter = new HostedBindingFilter(HostingEnvironment.ApplicationVirtualPath, addressing); foreach(string host in this.hosts) { MsmqBindingMonitor monitor = new MsmqBindingMonitor(host); monitor.AddFilter(this.filter); this.bindingMonitors.Add(monitor); } foreach(MsmqBindingMonitor monitor in this.bindingMonitors) { monitor.Open(); } } public Uri[] GetBaseAddresses(string virtualPath) { // Make sure this is not called until initialization is done: foreach(MsmqBindingMonitor monitor in this.bindingMonitors) { monitor.WaitForFirstRoundComplete(); } string absoluteVirtualPath = VirtualPathUtility.ToAbsolute(virtualPath, HostingEnvironment.ApplicationVirtualPath); List baseAddresses = new List (this.hosts.Length); string queueName = absoluteVirtualPath.Substring(1); foreach(string host in this.hosts) { bool isPrivate = this.filter.IsPrivateMatch(queueName); Uri uri = this.addressing.CreateUri(host, queueName, isPrivate); baseAddresses.Add(uri); MsmqDiagnostics.FoundBaseAddress(uri, absoluteVirtualPath); } return baseAddresses.ToArray(); } internal override string Scheme { get { return this.addressing.Scheme; } } internal override void OnClose(TimeSpan timeout) { // Nothing to do - we never use the transport manager during normal // operation. } internal override void OnOpen() { // Nothing to do - we only use the transport manager for WebHosted case. } internal override void Register(TransportChannelListener channelListener) { channelListener.SetMessageReceivedCallback(new Action(OnMessageReceived)); } internal void Start(Action messageReceivedCallback) { this.messageReceivedCallback = messageReceivedCallback; } internal override void Unregister(TransportChannelListener channelListener) { // Nothing to do - we never use the transport manager during normal // operation. } void OnMessageReceived() { Action callback = this.messageReceivedCallback; if (callback != null) { callback(); } } class HostedBindingFilter : MsmqBindingFilter { Dictionary privateMatches = new Dictionary (StringComparer.OrdinalIgnoreCase); public HostedBindingFilter(string path, MsmqUri.IAddressTranslator addressing) : base(path, addressing) { } public override object MatchFound(string host, string name, bool isPrivate) { string processedVirtualPath = CreateRelativeVirtualPath(host, name, isPrivate); string relativeServiceFile = ServiceHostingEnvironment.NormalizeVirtualPath(processedVirtualPath); // Compute the remainder path: lock(this) { if(isPrivate) { string baseQueue = CreateBaseQueue(relativeServiceFile); this.privateMatches[baseQueue] = baseQueue; } } // Start the service on a different thread so we can complete // initialization if(CheckServiceExists(relativeServiceFile)) { MsmqDiagnostics.StartingService(host, name, isPrivate, processedVirtualPath); ActionItem.Schedule(StartService, processedVirtualPath); } // no callback state here... return null; } public bool IsPrivateMatch(string processedVirtualPath) { lock(this) { return this.privateMatches.ContainsKey(processedVirtualPath); } } public override void MatchLost(string host, string name, bool isPrivate, object callbackState) { // We don't do anything here - the service will stay alive, // and if the queue ever comes back, then it will begin to // process again. } string CreateRelativeVirtualPath(string host, string name, bool isPrivate) { // the canonical prefix looks something like: "invoices/" // Because the queue name matched, it looks like "invoices/..." // remove the common piece, and prefix with the "~/" home specifier return "~/" + name.Substring(CanonicalPrefix.Length); } string CreateBaseQueue(string serviceFile) { // Clean up the service file... if(serviceFile.StartsWith("~", StringComparison.OrdinalIgnoreCase)) serviceFile = serviceFile.Substring(1); if(serviceFile.StartsWith("/", StringComparison.OrdinalIgnoreCase)) serviceFile = serviceFile.Substring(1); string virtualPath = HostingEnvironment.ApplicationVirtualPath; if(virtualPath.EndsWith("/", StringComparison.OrdinalIgnoreCase)) virtualPath = virtualPath.Substring(0, virtualPath.Length-1); if(virtualPath.StartsWith("/", StringComparison.OrdinalIgnoreCase)) virtualPath = virtualPath.Substring(1); return virtualPath + "/" + serviceFile; } bool CheckServiceExists(string serviceFile) { try { return (ServiceHostingEnvironment.IsConfigurationBasedService(serviceFile) || HostingEnvironmentWrapper.ServiceFileExists(serviceFile)); } catch(ArgumentException ex) { MsmqDiagnostics.ExpectedException(ex); return false; } } void StartService(object state) { try { string processedVirtualPath = (string)state; ServiceHostingEnvironment.EnsureServiceAvailable(processedVirtualPath); } catch(ServiceActivationException e) { // Non-fatal exceptions from the user code are wrapped in ServiceActivationException // The best we can do is to trace them MsmqDiagnostics.ExpectedException(e); } catch(EndpointNotFoundException e) { // This means that the server disappeared between the time we // saw the service, and the time we tried to start it. // That's okay. MsmqDiagnostics.ExpectedException(e); } } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- AdjustableArrowCap.cs
- XmlSchemaDatatype.cs
- ReferentialConstraint.cs
- Utility.cs
- TextWriter.cs
- ThemeInfoAttribute.cs
- HttpTransportManager.cs
- TextEffectCollection.cs
- CombinedGeometry.cs
- SafeHandles.cs
- NamedObject.cs
- EntityDataSourceChangingEventArgs.cs
- CodeTypeOfExpression.cs
- LogEntry.cs
- HtmlInputText.cs
- EntityProxyTypeInfo.cs
- JsonSerializer.cs
- SafeNativeMethods.cs
- EventMappingSettingsCollection.cs
- LogicalMethodInfo.cs
- TagMapCollection.cs
- ControlValuePropertyAttribute.cs
- PathFigureCollection.cs
- HostingEnvironment.cs
- Stacktrace.cs
- CompModSwitches.cs
- XmlSerializationReader.cs
- CaseKeyBox.xaml.cs
- TimerExtension.cs
- XmlSchemaObjectTable.cs
- SoapRpcServiceAttribute.cs
- VisualStates.cs
- FrameworkElement.cs
- StructuralType.cs
- SystemResourceKey.cs
- PrintPreviewControl.cs
- WindowsSpinner.cs
- XhtmlCssHandler.cs
- EpmContentDeSerializer.cs
- ClientSettingsProvider.cs
- TextTreeObjectNode.cs
- CommentEmitter.cs
- BooleanStorage.cs
- RemotingAttributes.cs
- SqlDuplicator.cs
- FtpRequestCacheValidator.cs
- HMACRIPEMD160.cs
- DbConnectionPoolOptions.cs
- SmtpNetworkElement.cs
- StateWorkerRequest.cs
- HotCommands.cs
- SendMailErrorEventArgs.cs
- Line.cs
- Model3DGroup.cs
- TableParagraph.cs
- Mouse.cs
- CursorInteropHelper.cs
- DBDataPermission.cs
- BroadcastEventHelper.cs
- BinHexEncoder.cs
- StrokeCollectionDefaultValueFactory.cs
- COM2PropertyDescriptor.cs
- DesignTimeResourceProviderFactoryAttribute.cs
- QilXmlWriter.cs
- BindToObject.cs
- ObjectPersistData.cs
- iisPickupDirectory.cs
- DragEvent.cs
- DetailsViewPageEventArgs.cs
- CharUnicodeInfo.cs
- SiteOfOriginContainer.cs
- PanelStyle.cs
- DataGridViewCellLinkedList.cs
- WaitHandle.cs
- TextSelectionHighlightLayer.cs
- InputProcessorProfilesLoader.cs
- DataGridViewCellStyleContentChangedEventArgs.cs
- ResourceAttributes.cs
- GridViewHeaderRowPresenter.cs
- PropertyGrid.cs
- OdbcPermission.cs
- RuleSetDialog.cs
- SqlCaseSimplifier.cs
- ChannelServices.cs
- KeyPullup.cs
- DataAccessor.cs
- EncoderBestFitFallback.cs
- Missing.cs
- EntityKeyElement.cs
- BackgroundFormatInfo.cs
- SqlRowUpdatedEvent.cs
- AccessorTable.cs
- DivideByZeroException.cs
- StaticResourceExtension.cs
- MsmqBindingElementBase.cs
- VerificationException.cs
- PropertySet.cs
- PropertyGridEditorPart.cs
- TableChangeProcessor.cs
- ValidationErrorEventArgs.cs