Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / Activities / LocalService / WorkflowMessageEventHandler.cs / 1305376 / WorkflowMessageEventHandler.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- using System; using System.Diagnostics; using System.Collections; using System.Collections.Generic; using System.Reflection; using System.Workflow.ComponentModel; using System.Workflow.Runtime; using System.Workflow.Runtime.Hosting; using System.Security.Principal; using System.Runtime.Serialization; namespace System.Workflow.Activities { [Serializable] public sealed class EventDeliveryFailedException : SystemException { public EventDeliveryFailedException() { } public EventDeliveryFailedException(String message) : base(message) { } public EventDeliveryFailedException(String message, Exception innerException) : base(message, innerException) { } private EventDeliveryFailedException(SerializationInfo info, StreamingContext context) : base(info, context) { } } [Serializable] internal sealed class WorkflowMessageEventHandler { Type proxiedType; string eventName; [NonSerialized] Type eventHandlerType; [NonSerialized] IDeliverMessage enqueueWrapper; internal WorkflowMessageEventHandler(Type proxiedType, EventInfo eventInfo, IDeliverMessage enqueueWrapper) { this.proxiedType = proxiedType; this.eventName = eventInfo.Name; this.eventHandlerType = eventInfo.EventHandlerType; this.enqueueWrapper = enqueueWrapper; } internal IDeliverMessage EnqueueWrapper { get { return this.enqueueWrapper; } set { if (value == null) { throw new ArgumentNullException("value"); } this.enqueueWrapper = value; } } internal Delegate Delegate { get { MethodInfo interceptedHandler = this.eventHandlerType.GetMethod("Invoke"); ParameterInfo[] parameters = interceptedHandler.GetParameters(); bool isValidParameter = false; if (parameters.Length == 2) { if (parameters[1].ParameterType.IsSubclassOf(typeof(ExternalDataEventArgs)) || parameters[1].ParameterType == (typeof(ExternalDataEventArgs))) isValidParameter = true; } if (isValidParameter) { MethodInfo mHandler = typeof(WorkflowMessageEventHandler).GetMethod("EventHandler"); return (Delegate)Activator.CreateInstance(eventHandlerType, new object[] { this, mHandler.MethodHandle.GetFunctionPointer() }); } return null; } } public void EventHandler(object sender, ExternalDataEventArgs eventArgs) { if (eventArgs == null) { throw new ArgumentNullException("eventArgs"); } try { object workItem; IPendingWork workHandler; object[] args = this.enqueueWrapper.PrepareEventArgsArray(sender, eventArgs, out workItem, out workHandler); EventQueueName key = GetKey(args); String securityIdentifier = null; if (eventArgs.Identity == null) { IIdentity identity = System.Threading.Thread.CurrentPrincipal.Identity; WindowsIdentity windowsIdentity = identity as WindowsIdentity; if (windowsIdentity != null && windowsIdentity.User != null) securityIdentifier = windowsIdentity.User.Translate(typeof(NTAccount)).ToString(); else if (identity != null) securityIdentifier = identity.Name; eventArgs.Identity = securityIdentifier; } else { securityIdentifier = eventArgs.Identity; } MethodMessage message = new MethodMessage(this.proxiedType, this.eventName, args, securityIdentifier); WorkflowActivityTrace.Activity.TraceEvent(TraceEventType.Information, 0, "Firing event {0} for instance {1}", this.eventName, eventArgs.InstanceId); this.enqueueWrapper.DeliverMessage(eventArgs, key, message, workItem, workHandler); } catch (Exception e) { if (ExternalDataExchangeService.IsIrrecoverableException(e)) { throw; } else { throw new EventDeliveryFailedException(SR.GetString(SR.Error_EventDeliveryFailedException, this.proxiedType, this.eventName, eventArgs.InstanceId), e); } } } private EventQueueName GetKey(object[] eventArgs) { bool provideInitializerTokens = CorrelationResolver.IsInitializingMember(this.proxiedType, this.eventName, eventArgs); ICollectionpredicates = CorrelationResolver.ResolveCorrelationValues(this.proxiedType, this.eventName, eventArgs, provideInitializerTokens); return new EventQueueName(this.proxiedType, this.eventName, predicates); } } } // 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
- SynthesizerStateChangedEventArgs.cs
- TemplateApplicationHelper.cs
- ButtonFieldBase.cs
- ResourceContainer.cs
- CustomValidator.cs
- ToolStripItemClickedEventArgs.cs
- ScrollBarAutomationPeer.cs
- FontNamesConverter.cs
- panel.cs
- DesignTimeTemplateParser.cs
- UserPreferenceChangingEventArgs.cs
- XDeferredAxisSource.cs
- ResolveInfo.cs
- TreeIterators.cs
- BamlVersionHeader.cs
- UrlMappingsModule.cs
- NullRuntimeConfig.cs
- UnsafeNativeMethodsPenimc.cs
- MergablePropertyAttribute.cs
- TextSelectionProcessor.cs
- DefaultValidator.cs
- DBPropSet.cs
- WebBodyFormatMessageProperty.cs
- OutputCacheProfile.cs
- XmlDataCollection.cs
- Mouse.cs
- ConsoleTraceListener.cs
- TokenBasedSet.cs
- FilterEventArgs.cs
- WinFormsSecurity.cs
- SoapSchemaImporter.cs
- FaultHandlingFilter.cs
- ExceptionUtil.cs
- MobileListItem.cs
- CachedBitmap.cs
- DoubleCollectionConverter.cs
- EntityKey.cs
- WebPartDisplayMode.cs
- TextTreeObjectNode.cs
- OdbcDataAdapter.cs
- CodeLabeledStatement.cs
- SafeRightsManagementHandle.cs
- LicenseContext.cs
- SetIterators.cs
- RemotingConfigParser.cs
- CultureInfo.cs
- FormViewPagerRow.cs
- _ListenerRequestStream.cs
- TraceContext.cs
- ArgumentNullException.cs
- DataControlImageButton.cs
- ParenExpr.cs
- ParameterDataSourceExpression.cs
- XmlILOptimizerVisitor.cs
- CornerRadius.cs
- PlainXmlWriter.cs
- BamlRecordReader.cs
- InvokeFunc.cs
- PropertyTabChangedEvent.cs
- VSWCFServiceContractGenerator.cs
- TCPClient.cs
- CalendarDay.cs
- TimeStampChecker.cs
- NetSectionGroup.cs
- XmlException.cs
- Matrix.cs
- QuaternionRotation3D.cs
- XsltLoader.cs
- DirectoryLocalQuery.cs
- StylusSystemGestureEventArgs.cs
- Mapping.cs
- IIS7UserPrincipal.cs
- DataTableTypeConverter.cs
- CompiledRegexRunner.cs
- DoubleCollectionConverter.cs
- QilGeneratorEnv.cs
- ModelUIElement3D.cs
- MessageLoggingElement.cs
- BamlLocalizerErrorNotifyEventArgs.cs
- DoubleIndependentAnimationStorage.cs
- SchemaAttDef.cs
- ProfilePropertySettingsCollection.cs
- ServiceEndpointElement.cs
- ApplyTemplatesAction.cs
- EntityClassGenerator.cs
- HostingEnvironmentException.cs
- TextBox.cs
- MethodRental.cs
- sqlstateclientmanager.cs
- NotificationContext.cs
- XPathItem.cs
- UnauthorizedAccessException.cs
- Pen.cs
- ToolStripPanelRenderEventArgs.cs
- XslException.cs
- _KerberosClient.cs
- BrushMappingModeValidation.cs
- SmtpReplyReader.cs
- FlatButtonAppearance.cs
- DesignerActionList.cs