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
- DirtyTextRange.cs
- TokenBasedSet.cs
- EventLogPermissionEntryCollection.cs
- Helpers.cs
- RelationshipDetailsCollection.cs
- DefaultBindingPropertyAttribute.cs
- UnknownBitmapEncoder.cs
- SqlFactory.cs
- PageThemeCodeDomTreeGenerator.cs
- UrlUtility.cs
- ChtmlTextWriter.cs
- FormViewPagerRow.cs
- COSERVERINFO.cs
- WebEventTraceProvider.cs
- SrgsOneOf.cs
- SqlDataSourceConfigureFilterForm.cs
- SqlDataSourceCustomCommandEditor.cs
- OrderedDictionary.cs
- MethodCallTranslator.cs
- SqlParameterizer.cs
- DependencyPropertyDescriptor.cs
- CodeSnippetCompileUnit.cs
- safex509handles.cs
- LinkTarget.cs
- EditorZone.cs
- DataGridViewCellEventArgs.cs
- SiteMapNodeCollection.cs
- FunctionGenerator.cs
- WebBrowserNavigatedEventHandler.cs
- TimeSpanMinutesConverter.cs
- WebPartCollection.cs
- TitleStyle.cs
- CanExecuteRoutedEventArgs.cs
- WindowsPrincipal.cs
- QueryParameter.cs
- DataGridViewTextBoxCell.cs
- DataTransferEventArgs.cs
- XPathNodeIterator.cs
- RenderOptions.cs
- ObjectQuery_EntitySqlExtensions.cs
- WaveHeader.cs
- RelatedEnd.cs
- DbModificationClause.cs
- ConfigurationElement.cs
- EncodingDataItem.cs
- GuidTagList.cs
- PartialList.cs
- OraclePermissionAttribute.cs
- DecimalConstantAttribute.cs
- BindingManagerDataErrorEventArgs.cs
- ButtonPopupAdapter.cs
- StrokeCollection2.cs
- QilLoop.cs
- RegistryExceptionHelper.cs
- X509ChainPolicy.cs
- DynamicQueryableWrapper.cs
- ThicknessAnimation.cs
- SettingsPropertyNotFoundException.cs
- HijriCalendar.cs
- VisualStyleTypesAndProperties.cs
- XmlSchemaComplexContentRestriction.cs
- TemplatePartAttribute.cs
- ToolStripDropDownClosedEventArgs.cs
- BoundColumn.cs
- HttpApplicationStateWrapper.cs
- BorderGapMaskConverter.cs
- UpdatableWrapper.cs
- SystemIcmpV6Statistics.cs
- ZipPackage.cs
- Visitor.cs
- CalendarData.cs
- GroupQuery.cs
- TracePayload.cs
- Msec.cs
- Comparer.cs
- EntityTypeEmitter.cs
- UInt16Converter.cs
- HTTPNotFoundHandler.cs
- EmptyStringExpandableObjectConverter.cs
- XmlSchemaImport.cs
- HeaderCollection.cs
- EntityDataSourceValidationException.cs
- QuadraticEase.cs
- XmlComment.cs
- FilterableAttribute.cs
- SafeNativeMemoryHandle.cs
- Buffer.cs
- FileCodeGroup.cs
- TreeNodeCollection.cs
- ToolStripItemTextRenderEventArgs.cs
- ThemeDictionaryExtension.cs
- RadioButtonFlatAdapter.cs
- WindowsFont.cs
- MonthCalendar.cs
- _DigestClient.cs
- DataRow.cs
- ImpersonationContext.cs
- BridgeDataRecord.cs
- EventArgs.cs
- SetIterators.cs