Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / RunTime / Hosting / DefaultWorkflowTransactionService.cs / 1305376 / DefaultWorkflowTransactionService.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- using System; using System.Transactions; using System.Collections.Specialized; using System.Diagnostics; using System.Configuration; namespace System.Workflow.Runtime.Hosting { ///A simple TransactionService that creates /// public class DefaultWorkflowCommitWorkBatchService : WorkflowCommitWorkBatchService { private bool _enableRetries = false; private bool _ignoreCommonEnableRetries = false; public DefaultWorkflowCommitWorkBatchService() { } public DefaultWorkflowCommitWorkBatchService(NameValueCollection parameters) { if (parameters == null) throw new ArgumentNullException("parameters", ExecutionStringManager.MissingParameters); if (parameters.Count > 0) { foreach (string key in parameters.Keys) { if (0 == string.Compare("EnableRetries", key, StringComparison.OrdinalIgnoreCase)) { _enableRetries = bool.Parse(parameters[key]); _ignoreCommonEnableRetries = true; } } } } public bool EnableRetries { get { return _enableRetries; } set { _enableRetries = value; _ignoreCommonEnableRetries = true; } } protected internal override void Start() { WorkflowTrace.Host.TraceEvent(TraceEventType.Information, 0, "DefaultWorkflowCommitWorkBatchService: Starting"); // // If we didn't find a local value for enable retries // check in the common section if ((!_ignoreCommonEnableRetries)&&(null != base.Runtime)) { NameValueConfigurationCollection commonConfigurationParameters = base.Runtime.CommonParameters; if (commonConfigurationParameters != null) { // Then scan for connection string in the common configuration parameters section foreach (string key in commonConfigurationParameters.AllKeys) { if (string.Compare("EnableRetries", key, StringComparison.OrdinalIgnoreCase) == 0) { _enableRetries = bool.Parse(commonConfigurationParameters[key].Value); break; } } } } base.Start(); } protected override void OnStopped() { WorkflowTrace.Host.TraceEvent(TraceEventType.Information, 0, "DefaultWorkflowCommitWorkBatchService: Stopping"); base.OnStopped(); } internal protected override void CommitWorkBatch(CommitWorkBatchCallback commitWorkBatchCallback) { DbRetry dbRetry = new DbRetry(_enableRetries); short retryCounter = 0; while (true) { if (null != Transaction.Current) { // // Can't retry as we don't own the tx // Set the counter to only allow one iteration retryCounter = dbRetry.MaxRetries; } try { base.CommitWorkBatch(commitWorkBatchCallback); break; } catch( Exception e ) { WorkflowTrace.Host.TraceEvent(TraceEventType.Error, 0, "DefaultWorkflowCommitWorkBatchService caught exception from commitWorkBatchCallback: " + e.ToString()); if (dbRetry.TryDoRetry(ref retryCounter)) { WorkflowTrace.Host.TraceEvent(TraceEventType.Information, 0, "DefaultWorkflowCommitWorkBatchService retrying commitWorkBatchCallback (retry attempt " + retryCounter.ToString(System.Globalization.CultureInfo.InvariantCulture) + ")"); continue; } else throw; } } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.System.Transactions.CommittableTransaction .
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- Help.cs
- WaitHandle.cs
- MobileFormsAuthentication.cs
- RoleExceptions.cs
- TemplateNodeContextMenu.cs
- ConsoleCancelEventArgs.cs
- XmlCustomFormatter.cs
- QilPatternVisitor.cs
- HttpListenerContext.cs
- RichTextBoxConstants.cs
- categoryentry.cs
- CharacterShapingProperties.cs
- DeploymentSection.cs
- SimpleTextLine.cs
- XmlElement.cs
- ScriptingWebServicesSectionGroup.cs
- WebPartZone.cs
- XmlILIndex.cs
- ViewManager.cs
- ImageBrush.cs
- ResourcePropertyMemberCodeDomSerializer.cs
- UrlMappingCollection.cs
- xmlsaver.cs
- TreeViewImageGenerator.cs
- SiteOfOriginContainer.cs
- UrlMapping.cs
- ZipIOLocalFileHeader.cs
- UIPropertyMetadata.cs
- CompilerTypeWithParams.cs
- FrameSecurityDescriptor.cs
- WSHttpSecurityElement.cs
- ListViewCancelEventArgs.cs
- AdRotator.cs
- ThrowOnMultipleAssignment.cs
- COM2ComponentEditor.cs
- TraceContext.cs
- EventProvider.cs
- LambdaReference.cs
- EventToken.cs
- UIElementParaClient.cs
- ImageIndexConverter.cs
- SerialPort.cs
- CodeMethodInvokeExpression.cs
- SortedList.cs
- XmlTextEncoder.cs
- ObjectDataSourceDisposingEventArgs.cs
- TextDecorationLocationValidation.cs
- SessionParameter.cs
- Vars.cs
- TreeView.cs
- UndirectedGraph.cs
- DataStreams.cs
- ChooseAction.cs
- ScriptingProfileServiceSection.cs
- WindowsFont.cs
- ValidationHelper.cs
- ContextMenuAutomationPeer.cs
- LinkButton.cs
- NameObjectCollectionBase.cs
- XmlSchemaAttributeGroupRef.cs
- SocketPermission.cs
- MutexSecurity.cs
- ObjectConverter.cs
- TemplateInstanceAttribute.cs
- RegexStringValidatorAttribute.cs
- IIS7WorkerRequest.cs
- IPHostEntry.cs
- SqlNodeTypeOperators.cs
- ContentPresenter.cs
- XmlProcessingInstruction.cs
- ConfigurationProperty.cs
- FileUtil.cs
- XPathDocumentBuilder.cs
- SchemaImporter.cs
- PolyLineSegmentFigureLogic.cs
- ProfilePropertySettings.cs
- TableAdapterManagerGenerator.cs
- LayoutEvent.cs
- XmlDownloadManager.cs
- CodeGenerator.cs
- PatternMatcher.cs
- DataGridViewHitTestInfo.cs
- ApplicationId.cs
- TextCompositionManager.cs
- DataGridViewLayoutData.cs
- Point3DCollectionValueSerializer.cs
- OleDbTransaction.cs
- ModelTypeConverter.cs
- LinqExpressionNormalizer.cs
- ManifestResourceInfo.cs
- DesignerProperties.cs
- MdImport.cs
- InternalMappingException.cs
- ResourcePermissionBase.cs
- ViewBox.cs
- AnnotationHelper.cs
- TreeNodeConverter.cs
- FamilyTypeface.cs
- EntityTypeEmitter.cs
- XPathSelfQuery.cs