NServiceBus by Particular Software

API Diff between 8.0.0 and 5.2.18

1281 Additions 439 Removals

NServiceBus

public class Address : ISerializable
public class AllAssemblies : IExcludesBuilder, IEnumerable<Assembly>, IEnumerable, IIncludesBuilder
public class AssemblyScannerConfiguration
- public string AdditionalAssemblyScanningPath { get; set; }
- public bool ScanAppDomainAssemblies { get; set; }
- public bool ScanAssembliesInNestedDirectories { get; set; }
- public bool ScanFileSystemAssemblies { get; set; }
- public bool ThrowExceptions { get; set; }
- public AssemblyScannerConfiguration()
- public void ExcludeAssemblies(string[] assemblies)
- public void ExcludeTypes(Type[] types)
public static class AssemblyScannerConfigurationExtensions
- public static AssemblyScannerConfiguration AssemblyScanner(this EndpointConfiguration configuration)
public static class AuditConfigReader
- public static bool TryGetAuditMessageExpiration(this IReadOnlySettings settings, out TimeSpan auditMessageExpiration)
- public static bool TryGetAuditQueueAddress(this IReadOnlySettings settings, out string address)
public static class AuditContextExtensions
- public static IRoutingContext CreateRoutingContext(this IAuditActionContext context, OutgoingMessage auditMessage, RoutingStrategy routingStrategy)
public static class AutoSubscribeSettingsExtensions
- public static AutoSubscribeSettings AutoSubscribe(this BusConfiguration config)
- public static AutoSubscribeSettings AutoSubscribe(this EndpointConfiguration config)
public class BinarySerializer : SerializationDefinition
public static class BinarySerializerConfigurationExtensions
public class BsonSerializer : SerializationDefinition
public static class Bus
public class BusAsyncResultEventArgs : EventArgs
public class BusConfiguration : ExposeSettings
public class BusNotifications : IDisposable
public class CompletionResult
public static class ConfigurationBuilderExtensions
public static class BestPracticesOptionExtensions
- public static void DoNotEnforceBestPractices(this ExtendableOptions options)
- public static void DoNotEnforceBestPractices(this IOutgoingReplyContext context)
- public static void DoNotEnforceBestPractices(this IOutgoingSendContext context)
- public static void DoNotEnforceBestPractices(this ISubscribeContext context)
- public static void DoNotEnforceBestPractices(this IOutgoingPublishContext context)
- public static void DoNotEnforceBestPractices(this IUnsubscribeContext context)
- public static bool IgnoredBestPractices(this ExtendableOptions options)
public static class ConfigurationTimeoutExtensions
- public static void TimeToWaitBeforeTriggeringCriticalErrorOnTimeoutOutages(this BusConfiguration config, TimeSpan timeToWait)
- public static void TimeToWaitBeforeTriggeringCriticalErrorOnTimeoutOutages(this EndpointConfiguration config, TimeSpan timeToWait)
public class Configure
public static class ConfigureBinarySerializer
public static class ConfigureAudit
- public static void AuditProcessedMessagesTo(this EndpointConfiguration config, string auditQueue, TimeSpan? timeToBeReceived = default)
public static class ConfigureCriticalErrorAction
- public static Configure DefineCriticalErrorAction(this Configure config, Action<string, Exception> onCriticalError)
- public static void DefineCriticalErrorAction(this BusConfiguration busConfiguration, Action<string, Exception> onCriticalError)
- public static void RaiseCriticalError(string errorMessage, Exception exception)
- public static void DefineCriticalErrorAction(this EndpointConfiguration endpointConfiguration, Func<ICriticalErrorContext, CancellationToken, Task> onCriticalError)
- public static void DefineCriticalErrorAction(this EndpointConfiguration endpointConfiguration, Func<ICriticalErrorContext, Task> onCriticalError)
public static class ConfigureDefaultBuilder
public static class ConfigureDistributor
public static class ConfigureExtensions
public static class ConfigureFaultsForwarder
public static class ConfigureError
- public static void SendFailedMessagesTo(this EndpointConfiguration config, string errorQueue)
public static class ConfigureFileShareDataBus
- public static DataBusExtentions<FileShareDataBus> BasePath(this DataBusExtentions<FileShareDataBus> config, string basePath)
- public static Configure FileShareDataBus(this Configure config, string basePath)
- public static void FileShareDataBus(this BusConfiguration config, string basePath)
- public static DataBusExtensions<FileShareDataBus> BasePath(this DataBusExtensions<FileShareDataBus> config, string basePath)
public static class ConfigureHandlerSettings
public static class ConfigureInMemoryFaultManagement
public static class ConfigureInMemorySagaPersister
public static class ConfigureInMemorySubscriptionStorage
public static class ConfigureInMemoryTimeoutPersister
public static class ConfigureJsonSerializer
public static class ConfigureForwarding
- public static void ForwardReceivedMessagesTo(this EndpointConfiguration config, string address)
public static class ConfigureLicenseExtensions
- public static Configure License(this Configure config, string licenseText)
- public static void License(this BusConfiguration config, string licenseText)
- public static Configure LicensePath(this Configure config, string licenseFile)
- public static void LicensePath(this BusConfiguration config, string licenseFile)
- public static void License(this EndpointConfiguration config, string licenseText)
- public static void LicensePath(this EndpointConfiguration config, string licenseFile)
public static class ConfigureMasterNode
public static class ConfigureMsmqMessageQueue
public static class ConfigureMsmqSubscriptionStorage
public static class ConfigurePurging
- public static bool PurgeRequested { get; }
- public static Configure PurgeOnStartup(this Configure config, bool value)
- public static void PurgeOnStartup(this BusConfiguration config, bool value)
- public static bool PurgeOnStartup(this Configure config)
- public static void PurgeOnStartup(this EndpointConfiguration config, bool value)
public static class ConfigureQueueCreation
- public static bool DontCreateQueues { get; }
- public static bool CreateQueues(this Configure config)
- public static Configure DoNotCreateQueues(this Configure config)
- public static void DoNotCreateQueues(this BusConfiguration config)
- public static bool CreateQueues(this ReadOnlySettings settings)
- public static void DoNotCreateQueues(this EndpointConfiguration config)
public static class ConfigureRavenPersistence
public static class ConfigureRavenSagaPersister
public static class ConfigureRavenSubscriptionStorage
public static class ConfigureRijndaelEncryptionService
public static class ConfigureSettingLocalAddressNameAction
public static class ConfigureTimeoutManager
public static class ConfigureTransportConnectionString
public static class ConfigureUnicastBus
public static class ConfigureXmlSerializer
public static class ConnectorContextExtensions
- public static IAuditContext CreateAuditContext(this ForkConnector<IIncomingPhysicalMessageContext, IAuditContext> forkConnector, OutgoingMessage message, string auditAddress, IIncomingPhysicalMessageContext sourceContext)
- public static IAuditContext CreateAuditContext(this ForkConnector<IIncomingPhysicalMessageContext, IAuditContext> forkConnector, OutgoingMessage message, string auditAddress, TimeSpan? timeToBeReceived, IIncomingPhysicalMessageContext sourceContext)
- public static IBatchDispatchContext CreateBatchDispatchContext(this StageForkConnector<ITransportReceiveContext, IIncomingPhysicalMessageContext, IBatchDispatchContext> stageForkConnector, IReadOnlyCollection<TransportOperation> transportOperations, IIncomingPhysicalMessageContext sourceContext)
- public static IDispatchContext CreateDispatchContext(this StageConnector<IBatchDispatchContext, IDispatchContext> stageConnector, IReadOnlyCollection<TransportOperation> transportOperations, IBatchDispatchContext sourceContext)
- public static IDispatchContext CreateDispatchContext(this StageConnector<IRoutingContext, IDispatchContext> stageConnector, IReadOnlyCollection<TransportOperation> transportOperations, IRoutingContext sourceContext)
- public static IForwardingContext CreateForwardingContext(this ForkConnector<IIncomingPhysicalMessageContext, IForwardingContext> forwardingContext, OutgoingMessage message, string forwardingAddress, IIncomingPhysicalMessageContext sourceContext)
- public static IIncomingLogicalMessageContext CreateIncomingLogicalMessageContext(this StageConnector<IIncomingPhysicalMessageContext, IIncomingLogicalMessageContext> stageConnector, LogicalMessage logicalMessage, IIncomingPhysicalMessageContext sourceContext)
- public static IIncomingPhysicalMessageContext CreateIncomingPhysicalMessageContext(this StageForkConnector<ITransportReceiveContext, IIncomingPhysicalMessageContext, IBatchDispatchContext> stageForkConnector, IncomingMessage incomingMessage, ITransportReceiveContext sourceContext)
- public static IIncomingPhysicalMessageContext CreateIncomingPhysicalMessageContext(this StageConnector<ITransportReceiveContext, IIncomingPhysicalMessageContext> stageConnector, IncomingMessage incomingMessage, ITransportReceiveContext sourceContext)
- public static IInvokeHandlerContext CreateInvokeHandlerContext(this StageConnector<IIncomingLogicalMessageContext, IInvokeHandlerContext> stageConnector, MessageHandler messageHandler, ICompletableSynchronizedStorageSession storageSession, IIncomingLogicalMessageContext sourceContext)
- public static IOutgoingLogicalMessageContext CreateOutgoingLogicalMessageContext(this StageConnector<IOutgoingPublishContext, IOutgoingLogicalMessageContext> stageConnector, OutgoingLogicalMessage outgoingMessage, IReadOnlyCollection<RoutingStrategy> routingStrategies, IOutgoingPublishContext sourceContext)
- public static IOutgoingLogicalMessageContext CreateOutgoingLogicalMessageContext(this StageConnector<IOutgoingReplyContext, IOutgoingLogicalMessageContext> stageConnector, OutgoingLogicalMessage outgoingMessage, IReadOnlyCollection<RoutingStrategy> routingStrategies, IOutgoingReplyContext sourceContext)
- public static IOutgoingLogicalMessageContext CreateOutgoingLogicalMessageContext(this StageConnector<IOutgoingSendContext, IOutgoingLogicalMessageContext> stageConnector, OutgoingLogicalMessage outgoingMessage, IReadOnlyCollection<RoutingStrategy> routingStrategies, IOutgoingSendContext sourceContext)
- public static IOutgoingPhysicalMessageContext CreateOutgoingPhysicalMessageContext(this StageConnector<IOutgoingLogicalMessageContext, IOutgoingPhysicalMessageContext> stageConnector, ReadOnlyMemory<byte> messageBody, IReadOnlyCollection<RoutingStrategy> routingStrategies, IOutgoingLogicalMessageContext sourceContext)
- public static IRoutingContext CreateRoutingContext(this ForkConnector<ITransportReceiveContext, IRoutingContext> forkConnector, OutgoingMessage outgoingMessage, string localAddress, ITransportReceiveContext sourceContext)
- public static IRoutingContext CreateRoutingContext(this StageConnector<IForwardingContext, IRoutingContext> stageConnector, OutgoingMessage outgoingMessage, RoutingStrategy routingStrategy, IForwardingContext sourceContext)
- public static IRoutingContext CreateRoutingContext(this StageConnector<IAuditContext, IRoutingContext> stageConnector, OutgoingMessage outgoingMessage, RoutingStrategy routingStrategy, IAuditContext sourceContext)
- public static IRoutingContext CreateRoutingContext(this StageConnector<IOutgoingPhysicalMessageContext, IRoutingContext> stageConnector, OutgoingMessage outgoingMessage, IReadOnlyCollection<RoutingStrategy> routingStrategies, IOutgoingPhysicalMessageContext sourceContext)
public abstract class ContainSagaData : IContainSagaData
- public virtual Guid Id { get; set; }
- public virtual string OriginalMessageId { get; set; }
- public virtual string Originator { get; set; }
- protected ContainSagaData()
public static class ContentTypes
- public const string Binary = "application/binary"
- public const string Bson = "application/bson"
public class Conventions
- public TimeSpan GetTimeToBeReceived(Type messageType)
- public bool IsEncryptedProperty(PropertyInfo property)
- public bool IsExpressMessageType(Type t)
public class ConventionsBuilder : ExposeSettings
- public ConventionsBuilder()
- public Conventions Conventions { get; }
- public ConventionsBuilder(SettingsHolder settings)
- public ConventionsBuilder Add(IMessageConvention messageConvention)
- public ConventionsBuilder DefiningEncryptedPropertiesAs(Func<PropertyInfo, bool> definesEncryptedProperty)
- public ConventionsBuilder DefiningExpressMessagesAs(Func<Type, bool> definesExpressMessageType)
- public ConventionsBuilder DefiningTimeToBeReceivedAs(Func<Type, TimeSpan> retrieveTimeToBeReceived)
public class ConversationId
- public static ConversationId Default { get; }
- public static ConversationId Custom(string customValue)
public class ConversationIdStrategyContext
- public IReadOnlyDictionary<string, string> Headers { get; }
- public OutgoingLogicalMessage Message { get; }
- public ConversationIdStrategyContext(OutgoingLogicalMessage message, IReadOnlyDictionary<string, string> headers)
public static class ConversationRoutingExtensions
- public static void StartNewConversation(this SendOptions sendOptions, string conversationId = null)
public class CorrelatedSagaPropertyMapper<TSagaData> where TSagaData : IContainSagaData
- public CorrelatedSagaPropertyMapper<TSagaData> ToMessage<TMessage>(Expression<Func<TMessage, object>> messageProperty)
- public CorrelatedSagaPropertyMapper<TSagaData> ToMessageHeader<TMessage>(string headerName)
public class CriticalError
- public CriticalError(Action<string, Exception> onCriticalErrorAction, Configure configure)
- public void Raise(string errorMessage, Exception exception)
- public CriticalError(Func<ICriticalErrorContext, CancellationToken, Task> onCriticalErrorAction)
- public CriticalError(Func<ICriticalErrorContext, Task> onCriticalErrorAction)
- public virtual void Raise(string errorMessage, Exception exception, CancellationToken cancellationToken = default)
public static class CriticalTimeMonitoringConfig
public class CriticalErrorContext : ICriticalErrorContext
- public string Error { get; }
- public Exception Exception { get; }
- public Func<CancellationToken, Task> Stop { get; }
- public CriticalErrorContext(Func<CancellationToken, Task> stop, string error, Exception exception)
- public CriticalErrorContext(Func<Task> stop, string error, Exception exception)
public class DataBusProperty<T> : IDataBusProperty, ISerializable
- public Type Type { get; }
- public DataBusProperty()
public static class DateTimeOffsetHelper
- public static DateTimeOffset ToDateTimeOffset(string wireFormattedString)
- public static string ToWireFormattedString(DateTimeOffset dateTime)
public static class DefaultRecoverabilityPolicy
- public static RecoverabilityAction Invoke(RecoverabilityConfig config, ErrorContext errorContext)
public class DelayedConfig
- public int MaxNumberOfRetries { get; }
- public TimeSpan TimeIncrease { get; }
- public DelayedConfig(int maxNumberOfRetries, TimeSpan timeIncrease)
public static class DelayedDeliveryOptionExtensions
- public static void DelayDeliveryWith(this SendOptions options, TimeSpan delay)
- public static void DoNotDeliverBefore(this SendOptions options, DateTimeOffset at)
- public static DateTimeOffset? GetDeliveryDate(this SendOptions options)
- public static TimeSpan? GetDeliveryDelay(this SendOptions options)
public class DelayedRetriesSettings : ExposeSettings
- public DelayedRetriesSettings NumberOfRetries(int numberOfRetries)
- public DelayedRetriesSettings OnMessageBeingRetried(Func<DelayedRetryMessage, Task> notificationCallback)
- public DelayedRetriesSettings OnMessageBeingRetried(Func<DelayedRetryMessage, CancellationToken, Task> notificationCallback)
- public DelayedRetriesSettings TimeIncrease(TimeSpan timeIncrease)
public class DelayedRetry : RecoverabilityAction
- public TimeSpan Delay { get; }
public static class DiagnosticSettingsExtensions
- public static void AddStartupDiagnosticsSection(this IReadOnlySettings settings, string sectionName, object section)
- public static void CustomDiagnosticsWriter(this EndpointConfiguration config, Func<string, CancellationToken, Task> customDiagnosticsWriter)
- public static void CustomDiagnosticsWriter(this EndpointConfiguration config, Func<string, Task> customDiagnosticsWriter)
- public static void SetDiagnosticsPath(this EndpointConfiguration config, string path)
public class Discard : RecoverabilityAction
- public string Reason { get; }
- public Discard(string reason)
public class DistributionPolicy : IDistributionPolicy
- public DistributionPolicy()
- public void SetDistributionStrategy(DistributionStrategy distributionStrategy)
public enum DistributionStrategyScope
- Publish = 1
- Send = 0
public static class DurableMessagesConfig
- public static void DisableDurableMessages(this BusConfiguration config)
- public static bool DurableMessagesEnabled(this Configure config)
- public static void EnableDurableMessages(this BusConfiguration config)
- public static void DisableDurableMessages(this EndpointConfiguration config)
- public static bool DurableMessagesEnabled(this ReadOnlySettings settings)
- public static void EnableDurableMessages(this EndpointConfiguration config)
public class EncryptedValue
public static class EndpointConventions
public sealed class EndpointNameAttribute : Attribute
public sealed class EndpointSLAAttribute : Attribute
public static class DurableMessagesConventionExtensions
- public static ConventionsBuilder DefiningExpressMessagesAs(this ConventionsBuilder builder, Func<Type, bool> definesExpressMessageType)
public static class Endpoint
- public static Task<IStartableEndpoint> Create(EndpointConfiguration configuration, CancellationToken cancellationToken = default)
- public static Task<IEndpointInstance> Start(EndpointConfiguration configuration, CancellationToken cancellationToken = default)
public class EndpointConfiguration : ExposeSettings
- public Notifications Notifications { get; }
- public PipelineSettings Pipeline { get; }
- public EndpointConfiguration(string endpointName)
- public ConventionsBuilder Conventions()
- public void RegisterComponents(Action<IServiceCollection> registration)
- public void SendOnly()
- public void UseContainer<T>(Action<ContainerCustomizations> customizations = null) where T : ContainerDefinition
- public void UseContainer(Type definitionType)
- public void UseContainer(IContainer builder)
- public RoutingSettings<TTransport> UseTransport<TTransport>(TTransport transportDefinition) where TTransport : TransportDefinition
public static class EndpointConfigurationExtensions
- public static void DisableFeature<T>(this EndpointConfiguration config) where T : Feature
- public static void DisableFeature(this EndpointConfiguration config, Type featureType)
- public static void EnableFeature<T>(this EndpointConfiguration config) where T : Feature
- public static void EnableFeature(this EndpointConfiguration config, Type featureType)
public static class EndpointInstanceExtensions
- public static Task Stop(this IEndpointInstance endpoint, TimeSpan gracefulStopTimeout)
public static class EndpointWithExternallyManagedContainer
- public static IStartableEndpointWithExternallyManagedContainer Create(EndpointConfiguration configuration, IServiceCollection serviceCollection)
public static class ErrorQueueSettings
- public const string SettingsKey = "errorQueue"
- public static string ErrorQueueAddress(this IReadOnlySettings settings)
- public static bool TryGetExplicitlyConfiguredErrorQueueAddress(this IReadOnlySettings settings, out string errorQueue)
public static class ExtensionMethods
public class FailedConfig
- public string ErrorQueue { get; }
- public HashSet<Type> UnrecoverableExceptionTypes { get; }
- public FailedConfig(string errorQueue, HashSet<Type> unrecoverableExceptionTypes)
public class First<T>
public static class HeaderOptionExtensions
- public static IReadOnlyDictionary<string, string> GetHeaders(this ExtendableOptions options)
- public static void SetHeader(this ExtendableOptions options, string key, string value)
public static class Headers
- public const string DataBusConfigContentType = "NServiceBus.DataBusConfig.ContentType"
- public const string DelayedRetries = "NServiceBus.Retries"
- public const string DelayedRetriesTimestamp = "NServiceBus.Retries.Timestamp"
- public const string DeliverAt = "NServiceBus.DeliverAt"
- public const string DiagnosticsBaggage = "baggage"
- public const string DiagnosticsTraceParent = "traceparent"
- public const string DiagnosticsTraceState = "tracestate"
- public const string FLRetries = "NServiceBus.FLRetries"
- public const string InvokedSagas = "NServiceBus.InvokedSagas"
- public const string ImmediateRetries = "NServiceBus.FLRetries"
- public const string NonDurableMessage = "NServiceBus.NonDurableMessage"
- public const string PreviousConversationId = "NServiceBus.PreviousConversationId"
- public const string Retries = "NServiceBus.Retries"
- public const string RijndaelKeyIdentifier = "NServiceBus.RijndaelKeyIdentifier"
- public const string SubscriberEndpoint = "NServiceBus.SubscriberEndpoint"
- public const string SubscriberTransportAddress = "NServiceBus.SubscriberAddress"
- public const string WindowsIdentityName = "WinIdName"
- public static string GetMessageHeader(object msg, string key)
- public static void SetMessageHeader(object msg, string key, string value)
- public const string TimeToBeReceived = "NServiceBus.TimeToBeReceived"
public static class HostInfoConfigurationExtensions
- public static HostInfoSettings UniquelyIdentifyRunningInstance(this BusConfiguration config)
- public static HostInfoSettings UniquelyIdentifyRunningInstance(this EndpointConfiguration config)
public class HostInfoSettings
- public HostInfoSettings UsingCustomDisplayName(string displayName)
- public HostInfoSettings UsingHostName(string hostName)
public interface IAuthorizeSubscriptions
public interface IBus : ISendOnlyBus, IDisposable
public static class IBus_Obsoletes
public interface ICallback
public interface IAmStartedByMessages<T> : IHandleMessages<T>
public interface ICancellableContext
- CancellationToken CancellationToken { get; }
public interface IConfigureLogging
public interface IConfigureLoggingForProfile<T>
public interface IConfigureThisEndpoint
public interface IConfigureHowToFindSagaWithMessage
- void ConfigureMapping<TSagaEntity, TMessage>(Expression<Func<TSagaEntity, object>> sagaEntityProperty, Expression<Func<TMessage, object>> messageProperty) where TSagaEntity : IContainSagaData
public interface IConfigureHowToFindSagaWithMessageHeaders
- void ConfigureMapping<TSagaEntity, TMessage>(Expression<Func<TSagaEntity, object>> sagaEntityProperty, string headerName) where TSagaEntity : IContainSagaData
public interface IContainSagaData
- Guid Id { get; set; }
- string OriginalMessageId { get; set; }
- string Originator { get; set; }
public interface ICriticalErrorContext
- string Error { get; }
- Exception Exception { get; }
- Func<CancellationToken, Task> Stop { get; }
public interface IDataBusProperty
- Type Type { get; }
public interface IDistributionPolicy
- DistributionStrategy GetDistributionStrategy(string endpointName, DistributionStrategyScope scope)
public interface IEndpointInstance : IMessageSession
- Task Stop(CancellationToken cancellationToken = default)
public interface IExcludesBuilder : IEnumerable<Assembly>, IEnumerable
public interface IHandleMessages<T>
- void Handle(T message)
- Task Handle(T message, IMessageHandlerContext context)
public interface IIncludesBuilder : IEnumerable<Assembly>, IEnumerable
public interface IInMemoryOperations
public interface IManageMessageHeaders
public interface IHandleTimeouts<T>
- Task Timeout(T state, IMessageHandlerContext context)
public interface IMessageContext
public interface IMessageConvention
- string Name { get; }
- bool IsCommandType(Type type)
- bool IsEventType(Type type)
- bool IsMessageType(Type type)
public interface IMessageHandlerContext : IMessageProcessingContext, IPipelineContext, ICancellableContext, IExtendable
- ISynchronizedStorageSession SynchronizedStorageSession { get; }
- void DoNotContinueDispatchingCurrentMessageToHandlers()
public interface IMessageProcessingContext : IPipelineContext, ICancellableContext, IExtendable
- IReadOnlyDictionary<string, string> MessageHeaders { get; }
- string MessageId { get; }
- string ReplyToAddress { get; }
- Task ForwardCurrentMessageTo(string destination)
- Task Reply(object message, ReplyOptions options)
- Task Reply<T>(Action<T> messageConstructor, ReplyOptions options)
public interface IMessageSession
- Task Publish(object message, PublishOptions publishOptions, CancellationToken cancellationToken = default)
- Task Publish<T>(Action<T> messageConstructor, PublishOptions publishOptions, CancellationToken cancellationToken = default)
- Task Send(object message, SendOptions sendOptions, CancellationToken cancellationToken = default)
- Task Send<T>(Action<T> messageConstructor, SendOptions sendOptions, CancellationToken cancellationToken = default)
- Task Subscribe(Type eventType, SubscribeOptions subscribeOptions, CancellationToken cancellationToken = default)
- Task Unsubscribe(Type eventType, UnsubscribeOptions unsubscribeOptions, CancellationToken cancellationToken = default)
public class ImmediateConfig
- public int MaxNumberOfRetries { get; }
- public ImmediateConfig(int maxNumberOfRetries)
public static class ImmediateDispatchOptionExtensions
- public static bool IsImmediateDispatchSet(this ExtendableOptions options)
- public static bool RequiredImmediateDispatch(this ExtendableOptions options)
- public static void RequireImmediateDispatch(this ExtendableOptions options)
public class ImmediateRetriesSettings : ExposeSettings
- public void NumberOfRetries(int numberOfRetries)
- public ImmediateRetriesSettings OnMessageBeingRetried(Func<ImmediateRetryMessage, Task> notificationCallback)
- public ImmediateRetriesSettings OnMessageBeingRetried(Func<ImmediateRetryMessage, CancellationToken, Task> notificationCallback)
public class ImmediateRetry : RecoverabilityAction
public interface INeedInitialization
- void Customize(BusConfiguration configuration)
- void Customize(EndpointConfiguration configuration)
public static class InMemoryGatewayPersistenceConfigurationExtensions
- public static void GatewayDeduplicationCacheSize(this PersistenceExtensions<InMemoryPersistence> persistenceExtensions, int maxSize)
public class InMemoryOutboxPersistence
- public InMemoryOutboxPersistence()
public static class InMemoryOutboxSettingsExtensions
- public static OutboxSettings TimeToKeepDeduplicationData(this OutboxSettings settings, TimeSpan time)
public class InMemoryPersistence : PersistenceDefinition
- public InMemoryPersistence()
public static class Install
public class InMemorySagaPersistence
- public InMemorySagaPersistence()
public class InMemorySubscriptionPersistence
- public InMemorySubscriptionPersistence()
public class InMemoryTimeoutPersistence
- public InMemoryTimeoutPersistence()
public static class InstallConfigExtensions
- public static void EnableInstallers(this BusConfiguration config, string username = null)
- public static Configure EnableInstallers(this Configure config, string username = null)
- public static void EnableInstallers(this EndpointConfiguration config, string username = null)
public class Installer<T>
public interface ISendOnlyBus : IDisposable
public interface ISpecifyMessageHandlerOrdering
public interface IStartableBus : IBus, ISendOnlyBus, IDisposable
public interface IWantCustomInitialization
public interface IWantCustomLogging
public interface IWantTheEndpointConfig
public interface IWantToRunBeforeConfiguration
public interface IPipelineContext : ICancellableContext, IExtendable
- Task Publish(object message, PublishOptions options)
- Task Publish<T>(Action<T> messageConstructor, PublishOptions publishOptions)
- Task Send(object message, SendOptions options)
- Task Send<T>(Action<T> messageConstructor, SendOptions options)
public interface IStartableEndpoint
- Task<IEndpointInstance> Start(CancellationToken cancellationToken = default)
public interface IStartableEndpointWithExternallyManagedContainer
- Lazy<IMessageSession> MessageSession { get; }
- Task<IEndpointInstance> Start(IServiceProvider builder, CancellationToken cancellationToken = default)
public interface IToSagaExpression<TSagaData> where TSagaData : IContainSagaData
- void ToSaga(Expression<Func<TSagaData, object>> sagaEntityProperty)
public interface IWantToRunBeforeConfigurationIsFinalized
- void Run(Configure config)
- void Run(SettingsHolder settings)
public interface IWantToRunWhenBusStartsAndStops
public class JsonSerializer : SerializationDefinition
public static class JsonSerializerConfigurationExtensions
public static class LoadMessageHandlersExtentions
public class LearningPersistence : PersistenceDefinition
public static class LearningSagaPersisterConfigurationExtensions
- public static void SagaStorageDirectory(this PersistenceExtensions<LearningPersistence> persistenceExtensions, string path)
public class LearningTransport : TransportDefinition
- public bool RestrictPayloadSize { get; set; }
- public string StorageDirectory { get; set; }
- public LearningTransport()
public static class LearningTransportConfigurationExtensions
- public static TransportExtensions<LearningTransport> ConnectionString(this TransportExtensions<LearningTransport> transport, string connectionString)
- public static TransportExtensions<LearningTransport> ConnectionString(this TransportExtensions<LearningTransport> transport, Func<string> connectionString)
- public static void NoPayloadSizeRestriction(this TransportExtensions<LearningTransport> transportExtensions)
- public static void StorageDirectory(this TransportExtensions<LearningTransport> transportExtensions, string path)
- public static TransportExtensions<LearningTransport> UseTransport<T>(this EndpointConfiguration config) where T : LearningTransport
public static class LoadMessageHandlersExtensions
- public static void ExecuteTheseHandlersFirst(this EndpointConfiguration config, IEnumerable<Type> handlerTypes)
- public static void ExecuteTheseHandlersFirst(this EndpointConfiguration config, Type[] handlerTypes)
public class MessageConventionException : Exception
public static class MessageConventions
public struct LogicalAddress
- public EndpointInstance EndpointInstance { get; }
- public string Qualifier { get; }
- public static LogicalAddress CreateLocalAddress(string queueName, IReadOnlyDictionary<string, string> properties)
- public static LogicalAddress CreateRemoteAddress(EndpointInstance endpointInstance)
- public LogicalAddress CreateIndividualizedAddress(string discriminator)
- public LogicalAddress CreateQualifiedAddress(string qualifier)
public static class MessageCausationConfigurationExtensions
- public static void CustomConversationIdStrategy(this EndpointConfiguration endpointConfiguration, Func<ConversationIdStrategyContext, ConversationId> customStrategy)
public class MessageDeserializationException : SerializationException
- public MessageDeserializationException(string message)
public static class MessageHandlerExtensionMethods
public static class MessageDrivenSubscriptionsConfigExtensions
- public static void DisablePublishing<T>(this TransportExtensions<T> transportExtensions) where T : TransportDefinition, IMessageDrivenSubscriptionTransport
- public static void DisablePublishing<T>(this RoutingSettings<T> routingSettings) where T : TransportDefinition, IMessageDrivenSubscriptionTransport
- public static void RegisterPublisher<T>(this RoutingSettings<T> routingSettings, Type eventType, string publisherEndpoint) where T : TransportDefinition, IMessageDrivenSubscriptionTransport
- public static void RegisterPublisher<T>(this RoutingSettings<T> routingSettings, Assembly assembly, string publisherEndpoint) where T : TransportDefinition, IMessageDrivenSubscriptionTransport
- public static void RegisterPublisher<T>(this RoutingSettings<T> routingSettings, Assembly assembly, string namespace, string publisherEndpoint) where T : TransportDefinition, IMessageDrivenSubscriptionTransport
- public static void SubscriptionAuthorizer<T>(this TransportExtensions<T> transportExtensions, Func<IIncomingPhysicalMessageContext, bool> authorizer) where T : TransportDefinition, IMessageDrivenSubscriptionTransport
- public static void SubscriptionAuthorizer<T>(this RoutingSettings<T> routingSettings, Func<IIncomingPhysicalMessageContext, bool> authorizer) where T : TransportDefinition, IMessageDrivenSubscriptionTransport
public static class MessageIdExtensions
- public static string GetMessageId(this ExtendableOptions options)
- public static void SetMessageId(this ExtendableOptions options, string messageId)
public enum MessageIntent
- Publish = 2
- Reply = 5
- Send = 1
- Subscribe = 3
- Unsubscribe = 4
public enum MessageIntentEnum
- Publish = 2
- Reply = 5
- Send = 1
- Subscribe = 3
- Unsubscribe = 4
public static class MonitoringConfig
public class MsmqTransport : TransportDefinition
public static class MessageProcessingContextExtensions
- public static Task Reply(this IMessageProcessingContext context, object message)
- public static Task Reply<T>(this IMessageProcessingContext context, Action<T> messageConstructor)
public static class MessageProcessingOptimizationExtensions
- public static void LimitMessageProcessingConcurrencyTo(this EndpointConfiguration config, int maxConcurrency)
public static class MessageSessionExtensions
- public static Task Publish(this IMessageSession session, object message, CancellationToken cancellationToken = default)
- public static Task Publish<T>(this IMessageSession session, CancellationToken cancellationToken = default)
- public static Task Publish<T>(this IMessageSession session, Action<T> messageConstructor, CancellationToken cancellationToken = default)
- public static Task Send(this IMessageSession session, object message, CancellationToken cancellationToken = default)
- public static Task Send<T>(this IMessageSession session, Action<T> messageConstructor, CancellationToken cancellationToken = default)
- public static Task Send(this IMessageSession session, string destination, object message, CancellationToken cancellationToken = default)
- public static Task Send<T>(this IMessageSession session, string destination, Action<T> messageConstructor, CancellationToken cancellationToken = default)
- public static Task SendLocal(this IMessageSession session, object message, CancellationToken cancellationToken = default)
- public static Task SendLocal<T>(this IMessageSession session, Action<T> messageConstructor, CancellationToken cancellationToken = default)
- public static Task Subscribe(this IMessageSession session, Type messageType, CancellationToken cancellationToken = default)
- public static Task Subscribe<T>(this IMessageSession session, CancellationToken cancellationToken = default)
- public static Task Unsubscribe(this IMessageSession session, Type messageType, CancellationToken cancellationToken = default)
- public static Task Unsubscribe<T>(this IMessageSession session, CancellationToken cancellationToken = default)
public class MoveToError : RecoverabilityAction
- public string ErrorQueue { get; }
public class NonDurableDelivery
- public NonDurableDelivery()
public class Notifications
- public ErrorsNotifications Errors { get; }
- public Notifications()
public class NServiceBusMarkerInterfaceConvention : IMessageConvention
- public string Name { get; }
- public NServiceBusMarkerInterfaceConvention()
- public bool IsCommandType(Type type)
- public bool IsEventType(Type type)
- public bool IsMessageType(Type type)
public class Order
public sealed delegate OnSatelliteMessage : MulticastDelegate
- public OnSatelliteMessage(object object, IntPtr method)
- public virtual IAsyncResult BeginInvoke(IServiceProvider serviceProvider, MessageContext messageContext, CancellationToken cancellationToken, AsyncCallback callback, object object)
- public virtual Task EndInvoke(IAsyncResult result)
- public virtual Task Invoke(IServiceProvider serviceProvider, MessageContext messageContext, CancellationToken cancellationToken = default)
public static class OpenTelemetryConfigurationExtensions
- public static void EnableOpenTelemetry(this EndpointConfiguration endpointConfiguration)
public static class OutboxConfigExtensions
- public static OutboxSettings EnableOutbox(this BusConfiguration config)
- public static OutboxSettings EnableOutbox(this EndpointConfiguration config)
public class PendingTransportOperations
- public bool HasOperations { get; }
- public TransportOperation[] Operations { get; }
- public PendingTransportOperations()
- public void Add(TransportOperation transportOperation)
- public void AddRange(TransportOperation[] transportOperations)
public static class PersistenceConfig
- public static PersistenceExtentions<T> UsePersistence<T>(this BusConfiguration config) where T : PersistenceDefinition
- public static PersistenceExtentions<T, S> UsePersistence<T, S>(this BusConfiguration config) where T : PersistenceDefinition where S : StorageType
- public static PersistenceExtentions UsePersistence(this BusConfiguration config, Type definitionType)
- public static PersistenceExtensions<T> UsePersistence<T>(this EndpointConfiguration config) where T : PersistenceDefinition
- public static PersistenceExtensions<T, S> UsePersistence<T, S>(this EndpointConfiguration config) where T : PersistenceDefinition where S : StorageType
- public static PersistenceExtensions UsePersistence(this EndpointConfiguration config, Type definitionType)
public class PersistenceExtentions : ExposeSettings
public class PersistenceExtentions<T> : PersistenceExtentions where T : PersistenceDefinition
public class PersistenceExtentions<T, S> : PersistenceExtentions<T> where T : PersistenceDefinition where S : StorageType
public class PersistenceExtensions : ExposeSettings
- public PersistenceExtensions(Type definitionType, SettingsHolder settings, Type storageType)
public class PersistenceExtensions<T> : PersistenceExtensions where T : PersistenceDefinition
- public PersistenceExtensions(SettingsHolder settings)
- protected PersistenceExtensions(SettingsHolder settings, Type storageType)
public class PersistenceExtensions<T, S> : PersistenceExtensions<T> where T : PersistenceDefinition where S : StorageType
- public PersistenceExtensions(SettingsHolder settings)
public static class PipelineContextExtensions
- public static Task Publish(this IPipelineContext context, object message)
- public static Task Publish<T>(this IPipelineContext context)
- public static Task Publish<T>(this IPipelineContext context, Action<T> messageConstructor)
- public static Task Send(this IPipelineContext context, object message)
- public static Task Send<T>(this IPipelineContext context, Action<T> messageConstructor)
- public static Task Send(this IPipelineContext context, string destination, object message)
- public static Task Send<T>(this IPipelineContext context, string destination, Action<T> messageConstructor)
- public static Task SendLocal(this IPipelineContext context, object message)
- public static Task SendLocal<T>(this IPipelineContext context, Action<T> messageConstructor)
public class PublishOptions : ExtendableOptions
- public PublishOptions()
public class RateLimitSettings
- public Func<CancellationToken, Task> OnRateLimitEnded { get; }
- public Func<CancellationToken, Task> OnRateLimitStarted { get; }
- public TimeSpan TimeToWaitBetweenThrottledAttempts { get; }
- public RateLimitSettings(TimeSpan? timeToWaitBetweenThrottledAttempts = default, Func<CancellationToken, Task> onRateLimitStarted = null, Func<CancellationToken, Task> onRateLimitEnded = null)
public class ReceiveAddresses
- public string InstanceReceiveAddress { get; }
- public string MainReceiveAddress { get; }
- public string[] SatelliteReceiveAddresses { get; }
- public ReceiveAddresses(string mainReceiveAddress, string instanceReceiveAddress = null, string[] satelliteReceiveAddresses = null)
public static class ReceiveFeatureConfigurationContextExtensions
- public static QueueAddress InstanceSpecificQueueAddress(this FeatureConfigurationContext config)
- public static QueueAddress LocalQueueAddress(this FeatureConfigurationContext config)
public class ReceivePipelineCompleted
- public DateTimeOffset CompletedAt { get; }
- public IncomingMessage ProcessedMessage { get; }
- public DateTimeOffset StartedAt { get; }
- public ReceivePipelineCompleted(IncomingMessage processedMessage, DateTimeOffset startedAt, DateTimeOffset completedAt)
public static class ReceivePipelineConfigExtensions
- public static void OnReceivePipelineCompleted(this PipelineSettings pipelineSettings, Func<ReceivePipelineCompleted, Task> subscription)
- public static void OnReceivePipelineCompleted(this PipelineSettings pipelineSettings, Func<ReceivePipelineCompleted, CancellationToken, Task> subscription)
public static class ReceiveSettingsExtensions
- public static void MakeInstanceUniquelyAddressable(this EndpointConfiguration config, string discriminator)
- public static void OverrideLocalAddress(this EndpointConfiguration config, string baseInputQueueName)
public abstract class RecoverabilityAction
- public abstract ErrorHandleResult ErrorHandleResult { get; }
- public static DelayedRetry DelayedRetry(TimeSpan timeSpan)
- public static Discard Discard(string reason)
- public static ImmediateRetry ImmediateRetry()
- public static MoveToError MoveToError(string errorQueue)
- public abstract IReadOnlyCollection<IRoutingContext> GetRoutingContexts(IRecoverabilityActionContext context)
public class RecoverabilityConfig
- public DelayedConfig Delayed { get; }
- public FailedConfig Failed { get; }
- public ImmediateConfig Immediate { get; }
- public RecoverabilityConfig(ImmediateConfig immediateConfig, DelayedConfig delayedConfig, FailedConfig failedConfig)
public static class RecoverabilityEndpointConfigurationExtensions
- public static RecoverabilitySettings Recoverability(this EndpointConfiguration configuration)
public class RecoverabilitySettings : ExposeSettings
- public RecoverabilitySettings AddUnrecoverableException<T>() where T : Exception
- public RecoverabilitySettings AddUnrecoverableException(Type exceptionType)
- public RecoverabilitySettings CustomPolicy(Func<RecoverabilityConfig, ErrorContext, RecoverabilityAction> custom)
- public RecoverabilitySettings Delayed(Action<DelayedRetriesSettings> customizations)
- public RecoverabilitySettings Failed(Action<RetryFailedSettings> customizations)
- public RecoverabilitySettings Immediate(Action<ImmediateRetriesSettings> customizations)
- public RecoverabilitySettings OnConsecutiveFailures(int numberOfConsecutiveFailures, RateLimitSettings settings)
public static class RecoverabilitySettingsExtensions
- public static void AddUnrecoverableException(this SettingsHolder settings, Type exceptionType)
public class ReplyOptions : ExtendableOptions
- public ReplyOptions()
public class RetryFailedSettings : ExposeSettings
- public RetryFailedSettings HeaderCustomization(Action<Dictionary<string, string>> customization)
- public RetryFailedSettings OnMessageSentToErrorQueue(Func<FailedMessage, Task> notificationCallback)
- public RetryFailedSettings OnMessageSentToErrorQueue(Func<FailedMessage, CancellationToken, Task> notificationCallback)
public static class RoutingFeatureSettingsExtensions
- public static void OverridePublicReturnAddress(this EndpointConfiguration configuration, string address)
public static class RoutingOptionExtensions
- public static string GetDestination(this ReplyOptions options)
- public static string GetDestination(this SendOptions options)
- public static string GetReplyToRoute(this ReplyOptions options)
- public static string GetReplyToRoute(this SendOptions options)
- public static string GetRouteToSpecificInstance(this SendOptions options)
- public static bool IsRoutingReplyToAnyInstance(this SendOptions options)
- public static bool IsRoutingReplyToAnyInstance(this ReplyOptions options)
- public static bool IsRoutingReplyToThisInstance(this SendOptions options)
- public static bool IsRoutingReplyToThisInstance(this ReplyOptions options)
- public static bool IsRoutingToThisEndpoint(this SendOptions options)
- public static bool IsRoutingToThisInstance(this SendOptions options)
- public static void RouteReplyTo(this ReplyOptions options, string address)
- public static void RouteReplyTo(this SendOptions options, string address)
- public static void RouteReplyToAnyInstance(this SendOptions options)
- public static void RouteReplyToAnyInstance(this ReplyOptions options)
- public static void RouteReplyToThisInstance(this SendOptions options)
- public static void RouteReplyToThisInstance(this ReplyOptions options)
- public static void RouteToSpecificInstance(this SendOptions options, string instanceId)
- public static void RouteToThisEndpoint(this SendOptions options)
- public static void RouteToThisInstance(this SendOptions options)
- public static void SetDestination(this SendOptions options, string destination)
- public static void SetDestination(this ReplyOptions options, string destination)
public class RoutingSettings : ExposeSettings
- public RoutingSettings(SettingsHolder settings)
- public void DoNotEnforceBestPractices()
- public void RouteToEndpoint(Type messageType, string destination)
- public void RouteToEndpoint(Assembly assembly, string destination)
- public void RouteToEndpoint(Assembly assembly, string namespace, string destination)
public class RoutingSettings<T> : RoutingSettings where T : TransportDefinition
- public RoutingSettings(SettingsHolder settings)
public static class RoutingSettingsExtensions
- public static RoutingSettings Routing(this TransportExtensions config)
public abstract class Saga
- public bool Completed { get; }
- public IContainSagaData Entity { get; set; }
- protected Saga()
- protected void MarkAsComplete()
- protected Task ReplyToOriginator(IMessageHandlerContext context, object message, IReadOnlyDictionary<string, string> outgoingHeaders = null)
- protected Task RequestTimeout<TTimeoutMessageType>(IMessageHandlerContext context, DateTimeOffset at)
- protected Task RequestTimeout<TTimeoutMessageType>(IMessageHandlerContext context, DateTimeOffset at, TTimeoutMessageType timeoutMessage)
- protected Task RequestTimeout<TTimeoutMessageType>(IMessageHandlerContext context, TimeSpan within)
- protected Task RequestTimeout<TTimeoutMessageType>(IMessageHandlerContext context, TimeSpan within, TTimeoutMessageType timeoutMessage)
public abstract class Saga<TSagaData> : Saga where TSagaData : IContainSagaData
- public TSagaData Data { get; set; }
- protected Saga()
- protected abstract void ConfigureHowToFindSaga(SagaPropertyMapper<TSagaData> mapper)
public class SagaPropertyMapper<TSagaData> where TSagaData : IContainSagaData
- public IToSagaExpression<TSagaData> ConfigureHeaderMapping<TMessage>(string headerName)
- public ToSagaExpression<TSagaData, TMessage> ConfigureMapping<TMessage>(Expression<Func<TMessage, object>> messageProperty)
- public CorrelatedSagaPropertyMapper<TSagaData> MapSaga(Expression<Func<TSagaData, object>> sagaProperty)
public static class ScaleOutExtentions
public class Schedule
public static class SecondLevelRetriesConfigExtensions
public static class SagasConfigExtensions
- public static SagaSettings Sagas(this EndpointConfiguration config)
public class ScheduledTask
public static class ScheduleExtensions
- public static Task ScheduleEvery(this IMessageSession session, TimeSpan timeSpan, Func<IPipelineContext, Task> task)
- public static Task ScheduleEvery(this IMessageSession session, TimeSpan timeSpan, string name, Func<IPipelineContext, Task> task)
public class SendOptions : ExtendableOptions
- public SendOptions()
public static class SerializationConfigExtensions
- public static SerializationExtentions<T> UseSerialization<T>(this BusConfiguration config) where T : SerializationDefinition
- public static void UseSerialization(this BusConfiguration config, Type serializerType)
- public static SerializationExtensions<T> AddDeserializer<T>(this EndpointConfiguration config) where T : SerializationDefinition
- public static SerializationExtensions<T> AddDeserializer<T>(this EndpointConfiguration config, T serializationDefinition) where T : SerializationDefinition
- public static SerializationExtensions<T> UseSerialization<T>(this EndpointConfiguration config) where T : SerializationDefinition
- public static SerializationExtensions<T> UseSerialization<T>(this EndpointConfiguration config, T serializationDefinition) where T : SerializationDefinition
public static class SetLoggingLibrary
public static class SerializationContextExtensions
- public static bool ShouldSkipSerialization(this IOutgoingLogicalMessageContext context)
- public static void SkipSerialization(this IOutgoingLogicalMessageContext context)
public static class SerializationExtensionsExtensions
- public static void DisableDynamicTypeLoading<T>(this SerializationExtensions<T> config) where T : SerializationDefinition
- public static void DisableMessageTypeInference<T>(this SerializationExtensions<T> config) where T : SerializationDefinition
public static class ServiceCollectionExtensions
- public static void ConfigureComponent(this IServiceCollection serviceCollection, Type concreteComponent, DependencyLifecycle dependencyLifecycle)
- public static void ConfigureComponent<T>(this IServiceCollection serviceCollection, DependencyLifecycle dependencyLifecycle)
- public static void ConfigureComponent<T>(this IServiceCollection serviceCollection, Func<T> componentFactory, DependencyLifecycle dependencyLifecycle)
- public static void ConfigureComponent<T>(this IServiceCollection serviceCollection, Func<IServiceProvider, T> componentFactory, DependencyLifecycle dependencyLifecycle)
- public static bool HasComponent<T>(this IServiceCollection serviceCollection)
- public static bool HasComponent(this IServiceCollection serviceCollection, Type componentType)
- public static void RegisterSingleton(this IServiceCollection serviceCollection, Type lookupType, object instance)
- public static void RegisterSingleton<T>(this IServiceCollection serviceCollection, T instance)
public static class SettingsExtentions
public static class SLAMonitoringConfig
public static class SettingsExtensions
- public static string EndpointName(this IReadOnlySettings settings)
- public static string EndpointQueueName(this IReadOnlySettings settings)
- public static IList<Type> GetAvailableTypes(this IReadOnlySettings settings)
- public static string InstanceSpecificQueue(this IReadOnlySettings settings)
- public static string LocalAddress(this IReadOnlySettings settings)
- public static LogicalAddress LogicalAddress(this ReadOnlySettings settings)
public class StartupDiagnosticEntries
- public class StartupDiagnosticEntry
- public StartupDiagnosticEntries()
- public void Add(string sectionName, object section)
public static class StaticHeadersConfigExtensions
- public static void AddHeaderToAllOutgoingMessages(this EndpointConfiguration config, string key, string value)
public abstract class StorageType
- public sealed class GatewayDeduplication
- public sealed class Outbox : StorageType
- public sealed class Sagas : StorageType
- public sealed class Subscriptions : StorageType
- public sealed class Timeouts
public class SubscribeOptions : ExtendableOptions
- public SubscribeOptions()
public class SubscriptionMigrationModeSettings : ExposeSettings
- public SubscriptionMigrationModeSettings(SettingsHolder settings)
- public void RegisterPublisher(Type eventType, string publisherEndpoint)
- public void RegisterPublisher(Assembly assembly, string publisherEndpoint)
- public void RegisterPublisher(Assembly assembly, string namespace, string publisherEndpoint)
- public void SubscriptionAuthorizer(Func<IIncomingPhysicalMessageContext, bool> authorizer)
public class SystemJsonDataBusSerializer : IDataBusSerializer
- public string ContentType { get; }
- public SystemJsonDataBusSerializer()
- public object Deserialize(Type propertyType, Stream stream)
- public void Serialize(object dataBusProperty, Stream stream)
public class TimeoutManagerConfiguration
public static class TimeoutManagerConfigurationExtensions
- public static void LimitMessageProcessingConcurrencyTo(this TimeoutManagerConfiguration timeoutManagerConfiguration, int maxConcurrency)
- public static TimeoutManagerConfiguration TimeoutManager(this EndpointConfiguration endpointConfiguration)
public static class TransactionalConfigManager
public static class TransactionSettingsExtentions
public class TransportConfiguration
public static class TimeToBeReceivedConventionExtensions
- public static ConventionsBuilder DefiningTimeToBeReceivedAs(this ConventionsBuilder builder, Func<Type, TimeSpan> retrieveTimeToBeReceived)
public class ToSagaExpression<TSagaData, TMessage> where TSagaData : IContainSagaData
- public ToSagaExpression(IConfigureHowToFindSagaWithMessage sagaMessageFindingConfiguration, Expression<Func<TMessage, object>> messageProperty)
- public void ToSaga(Expression<Func<TSagaData, object>> sagaEntityProperty)
public class TransportExtensions
- public TransportExtensions Transactions(TransportTransactionMode transportTransactionMode)
public class TransportExtensions<T> where T : TransportDefinition
- public T Transport { get; }
- public TransportExtensions(T transport, RoutingSettings<T> routing)
- public TransportExtensions ConnectionString(string connectionString)
- public TransportExtensions ConnectionString(Func<string> connectionString)
- public TransportExtensions ConnectionStringName(string name)
- public TransportExtensions<T> ConnectionStringName(string name)
- public RoutingSettings<T> Routing()
- public TransportExtensions<T> Transactions(TransportTransactionMode transportTransactionMode)
public class TransportMessage
public static class TransportReceiverConfig
public enum TransportTransactionMode
- None = 0
- ReceiveOnly = 1
- SendsAtomicWithReceive = 2
- TransactionScope = 3
public class UnitOfWorkSettings
- public UnitOfWorkSettings WrapHandlersInATransactionScope(TimeSpan? timeout = default, IsolationLevel? isolationLevel = default)
public static class UnitOfWorkSettingsExtensions
- public static UnitOfWorkSettings UnitOfWork(this EndpointConfiguration config)
public class UnsubscribeOptions : ExtendableOptions
- public UnsubscribeOptions()
public static class UseDataBusExtensions
- public static DataBusExtentions<T> UseDataBus<T>(this BusConfiguration config) where T : DataBusDefinition
- public static DataBusExtentions UseDataBus(this BusConfiguration config, Type dataBusType)
- public static DataBusExtensions<TDataBusDefinition> UseDataBus<TDataBusDefinition, TDataBusSerializer>(this EndpointConfiguration config) where TDataBusDefinition : DataBusDefinition where TDataBusSerializer : IDataBusSerializer
- public static DataBusExtensions<TDataBusDefinition> UseDataBus<TDataBusDefinition>(this EndpointConfiguration config, IDataBusSerializer dataBusSerializer) where TDataBusDefinition : DataBusDefinition
- public static DataBusExtensions UseDataBus(this EndpointConfiguration config, Func<IServiceProvider, IDataBus> dataBusFactory, IDataBusSerializer dataBusSerializer)
- public static DataBusExtensions<T> UseDataBus<T>(this EndpointConfiguration config) where T : DataBusDefinition
- public static DataBusExtensions UseDataBus(this EndpointConfiguration config, Type dataBusType)
public static class UseTransportExtensions
- public static Configure UseTransport<T>(this Configure config, Action<TransportConfiguration> customizations = null) where T : TransportDefinition
- public static Configure UseTransport(this Configure config, Type transportDefinitionType, Action<TransportConfiguration> customizations = null)
- public static TransportExtensions<T> UseTransport<T>(this BusConfiguration busConfiguration) where T : TransportDefinition
- public static TransportExtensions UseTransport(this BusConfiguration busConfiguration, Type transportDefinitionType)
- public static TransportExtensions UseTransport(this EndpointConfiguration endpointConfiguration, Type transportDefinitionType)
public class WireEncryptedString : ISerializable
public static class XmlSerializationExtentions
public static class XmlSerializationExtensions
- public static SerializationExtensions<XmlSerializer> DontWrapRawXml(this SerializationExtensions<XmlSerializer> config)
- public static SerializationExtensions<XmlSerializer> Namespace(this SerializationExtensions<XmlSerializer> config, string namespaceToUse)
- public static SerializationExtensions<XmlSerializer> SanitizeInput(this SerializationExtensions<XmlSerializer> config)
public static class XmlSerializerConfigurationExtensions

NServiceBus.DataBus

public class DataBusExtentions : ExposeSettings
public class DataBusExtentions<T> : DataBusExtentions where T : DataBusDefinition
public class DataBusExtensions : ExposeSettings
- public DataBusExtensions(SettingsHolder settings)
- public DataBusExtensions AddDeserializer<TSerializer>() where TSerializer : IDataBusSerializer
- public DataBusExtensions AddDeserializer<TSerializer>(TSerializer serializer) where TSerializer : IDataBusSerializer
public class DataBusExtensions<T> : DataBusExtensions where T : DataBusDefinition
- public DataBusExtensions(SettingsHolder settings)
public interface IDataBus
- Stream Get(string key)
- string Put(Stream stream, TimeSpan timeToBeReceived)
- void Start()
- Task<Stream> Get(string key, CancellationToken cancellationToken = default)
- Task<string> Put(Stream stream, TimeSpan timeToBeReceived, CancellationToken cancellationToken = default)
- Task Start(CancellationToken cancellationToken = default)
public interface IDataBusSerializer
- object Deserialize(Stream stream)
- string ContentType { get; }
- object Deserialize(Type propertyType, Stream stream)

NServiceBus.DelayedDelivery

public class DelayDeliveryWith
- public TimeSpan Delay { get; }
- public DelayDeliveryWith(TimeSpan delay)
public class DoNotDeliverBefore
- public DateTimeOffset At { get; }
- public DoNotDeliverBefore(DateTimeOffset at)
public static class ExternalTimeoutManagerConfigurationExtensions
- public static void UseExternalTimeoutManager(this EndpointConfiguration endpointConfiguration, string externalTimeoutManagerAddress)

NServiceBus.DeliveryConstraints

public abstract class DeliveryConstraint
- protected DeliveryConstraint()
public static class DeliveryConstraintContextExtensions
- public static void AddDeliveryConstraint(this ContextBag context, DeliveryConstraint constraint)
- public static List<DeliveryConstraint> GetDeliveryConstraints(this ContextBag context)
- public static void RemoveDeliveryConstraint(this ContextBag context, DeliveryConstraint constraint)
- public static bool TryGetDeliveryConstraint<T>(this ContextBag context, out T constraint) where T : DeliveryConstraint
- public static bool TryRemoveDeliveryConstraint<T>(this ContextBag context, out T constraint) where T : DeliveryConstraint

NServiceBus.Encryption

public interface IEncryptionService

NServiceBus.Encryption.Rijndael

public class EncryptionService

NServiceBus.Extensibility

public class ContextBag : IReadOnlyContextBag
- public ContextBag(ContextBag parentBag = null)
- public T Get<T>()
- public T Get<T>(string key)
- public T GetOrCreate<T>()
- public void Remove<T>()
- public void Remove(string key)
- public void Set<T>(T t)
- public void Set<T>(string key, T t)
- public bool TryGet<T>(out T result)
- public bool TryGet<T>(string key, out T result)
public abstract class ExtendableOptions
- protected ExtendableOptions()
public static class ExtendableOptionsExtensions
- public static DispatchProperties GetDispatchProperties(this ExtendableOptions options)
- public static ContextBag GetExtensions(this ExtendableOptions options)
- public static IReadOnlyContextBag GetOperationProperties(this IOutgoingContext behaviorContext)
- public static IReadOnlyContextBag GetOperationProperties(this IUnsubscribeContext behaviorContext)
- public static IReadOnlyContextBag GetOperationProperties(this ISubscribeContext behaviorContext)
- public static IReadOnlyContextBag GetOperationProperties(this IRoutingContext behaviorContext)
public interface IExtendable
- ContextBag Extensions { get; }
public interface IReadOnlyContextBag
- T Get<T>()
- T Get<T>(string key)
- bool TryGet<T>(out T result)
- bool TryGet<T>(string key, out T result)
public interface ReadOnlyContextBag

NServiceBus.Faults

public class DelayedRetryMessage
- public ReadOnlyMemory<byte> Body { get; }
- public Exception Exception { get; }
- public Dictionary<string, string> Headers { get; }
- public string MessageId { get; }
- public int RetryAttempt { get; }
- public DelayedRetryMessage(string messageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body, Exception exception, int retryAttempt)
public class ErrorsNotifications
- public IObservable<SecondLevelRetry> MessageHasBeenSentToSecondLevelRetries { get; }
- public IObservable<FirstLevelRetry> MessageHasFailedAFirstLevelRetryAttempt { get; }
- public IObservable<FailedMessage> MessageSentToErrorQueue { get; }
- public event EventHandler<DelayedRetryMessage> MessageHasBeenSentToDelayedRetries
- public event EventHandler<ImmediateRetryMessage> MessageHasFailedAnImmediateRetryAttempt
- public event EventHandler<FailedMessage> MessageSentToErrorQueue
public class FailedMessage
- public byte[] Body { get; }
- public ReadOnlyMemory<byte> Body { get; }
- public string ErrorQueue { get; }
- public FailedMessage(Dictionary<string, string> headers, byte[] body, Exception exception)
- public string MessageId { get; }
- public FailedMessage(string messageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body, Exception exception, string errorQueue)
public struct FirstLevelRetry
public interface IManageMessageFailures
public struct SecondLevelRetry
public class ImmediateRetryMessage
- public ReadOnlyMemory<byte> Body { get; }
- public Exception Exception { get; }
- public Dictionary<string, string> Headers { get; }
- public string MessageId { get; }
- public int RetryAttempt { get; }
- public ImmediateRetryMessage(string messageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body, Exception exception, int retryAttempt)

NServiceBus.Features

public class BinarySerialization : Feature
public class BsonSerialization : Feature
public class CriticalTimeMonitoring : Feature
public class Encryptor : Feature
public abstract class Feature
- protected void DependsOnOptionally(string featureName)
- protected void DependsOnOptionally(Type featureType)
- protected void DependsOnOptionally<T>() where T : Feature
- protected void RegisterStartupTask<T>() where T : FeatureStartupTask
public class FeatureConfigurationContext
- public IConfigureComponents Container { get; }
- public IServiceCollection Container { get; }
- public ReadOnlySettings Settings { get; }
- public IServiceCollection Services { get; }
- public IReadOnlySettings Settings { get; }
- public void AddSatelliteReceiver(string name, QueueAddress transportAddress, PushRuntimeSettings runtimeSettings, Func<RecoverabilityConfig, ErrorContext, RecoverabilityAction> recoverabilityPolicy, OnSatelliteMessage onMessage)
- public void RegisterStartupTask<TTask>(TTask startupTask) where TTask : FeatureStartupTask
- public void RegisterStartupTask<TTask>(Func<TTask> startupTaskFactory) where TTask : FeatureStartupTask
- public void RegisterStartupTask<TTask>(Func<IServiceProvider, TTask> startupTaskFactory) where TTask : FeatureStartupTask
public class FeatureDiagnosticData
public class FeatureSettings
public class FeaturesReport
public abstract class FeatureStartupTask
- protected abstract void OnStart()
- protected virtual void OnStop()
- protected abstract Task OnStart(IMessageSession session, CancellationToken cancellationToken = default)
- protected abstract Task OnStop(IMessageSession session, CancellationToken cancellationToken = default)
public enum FeatureState
- Active = 2
- Deactivated = 3
- Disabled = 0
- Enabled = 1
public class InMemoryOutboxPersistence : Feature
public class InMemorySagaPersistence : Feature
public class InMemorySubscriptionPersistence : Feature
public class InMemoryTimeoutPersistence : Feature
public class InstallationSupport : Feature
public class JsonSerialization : Feature
public class MsmqSubscriptionPersistence : Feature
public class MsmqTransportConfigurator : ConfigureTransport
public class PrerequisiteStatus
public class PlatformRetryNotifications : Feature
public class Scheduler
- public Scheduler()
public class SecondLevelRetries : Feature
public static class SerializationFeatureHelper
public static class SettingsExtentions
public class SLAMonitoring : Feature
public class StorageDrivenPublisher
public class StorageDrivenPublishing : Feature
public static class SettingsExtensions
- public static SettingsHolder EnableFeatureByDefault<T>(this SettingsHolder settings) where T : Feature
- public static SettingsHolder EnableFeatureByDefault(this SettingsHolder settings, Type featureType)
- public static bool IsFeatureActive(this IReadOnlySettings settings, Type featureType)
- public static bool IsFeatureEnabled(this IReadOnlySettings settings, Type featureType)
public class SynchronizedStorage : Feature
public class TimeoutManagerBasedDeferral : Feature
public class XmlSerialization : Feature

NServiceBus.Gateway.Deduplication

public interface IDeduplicateMessages
- bool DeduplicateMessage(string clientId, DateTime timeReceived)
- Task<bool> DeduplicateMessage(string clientId, DateTime timeReceived, ContextBag context)

NServiceBus.Hosting

public class GenericHost
public class IHost

NServiceBus.Hosting.Helpers

public class AssemblyScanner
- public List<Assembly> MustReferenceAtLeastOneAssembly { get; }
- public bool ScanAppDomainAssemblies { get; set; }
- public bool ScanFileSystemAssemblies { get; set; }
public class AssemblyScannerResults
- public List<Type> Types { get; }

NServiceBus.IdGeneration

public static class CombGuid

NServiceBus.Installation

public interface IEnvironment
public interface INeedToInstallSomething
- void Install(string identity, Configure config)
- Task Install(string identity, CancellationToken cancellationToken = default)
public class INeedToInstallSomething<T>

NServiceBus.Installation.Environments

public class Windows

NServiceBus.Logging

public class LoggingLibraryException : Exception

NServiceBus.Logging.Log4NetBridge

public class ConfigureInternalLog4NetBridge

NServiceBus.Logging.Loggers

public class ConsoleLogger
public class ConsoleLoggerFactory
public class NullLogger
public class NullLoggerFactory

NServiceBus.Logging.Loggers.Log4NetAdapter

public class Log4NetAppenderFactory
public class Log4NetConfigurator
public class Log4NetLogger
public class Log4NetLoggerFactory

NServiceBus.Logging.Loggers.NLogAdapter

public class NLogConfigurator
public class NLogLogger
public class NLogLoggerFactory
public class NLogTargetFactory

NServiceBus.MessageMutator

public interface IMessageMutator : IMutateOutgoingMessages, IMutateIncomingMessages
public interface IMutateIncomingMessages
- object MutateIncoming(object message)
- Task MutateIncoming(MutateIncomingMessageContext context)
public interface IMutateIncomingTransportMessages
- void MutateIncoming(TransportMessage transportMessage)
- Task MutateIncoming(MutateIncomingTransportMessageContext context)
public interface IMutateOutgoingMessages
- object MutateOutgoing(object message)
- Task MutateOutgoing(MutateOutgoingMessageContext context)
public interface IMutateOutgoingTransportMessages
- void MutateOutgoing(LogicalMessage logicalMessage, TransportMessage transportMessage)
- Task MutateOutgoing(MutateOutgoingTransportMessageContext context)
public interface IMutateTransportMessages : IMutateIncomingTransportMessages, IMutateOutgoingTransportMessages
public class MutateIncomingMessageContext : ICancellableContext
- public CancellationToken CancellationToken { get; }
- public Dictionary<string, string> Headers { get; }
- public object Message { get; set; }
- public MutateIncomingMessageContext(object message, Dictionary<string, string> headers, CancellationToken cancellationToken = default)
public class MutateIncomingTransportMessageContext : ICancellableContext
- public ReadOnlyMemory<byte> Body { get; set; }
- public CancellationToken CancellationToken { get; }
- public Dictionary<string, string> Headers { get; }
- public MutateIncomingTransportMessageContext(ReadOnlyMemory<byte> body, Dictionary<string, string> headers, CancellationToken cancellationToken = default)
public class MutateOutgoingMessageContext : ICancellableContext
- public CancellationToken CancellationToken { get; }
- public Dictionary<string, string> OutgoingHeaders { get; }
- public object OutgoingMessage { get; set; }
- public MutateOutgoingMessageContext(object outgoingMessage, Dictionary<string, string> outgoingHeaders, object incomingMessage, IReadOnlyDictionary<string, string> incomingHeaders, CancellationToken cancellationToken = default)
- public bool TryGetIncomingHeaders(out IReadOnlyDictionary incomingHeaders)
- public bool TryGetIncomingMessage(out object incomingMessage)
public class MutateOutgoingTransportMessageContext : ICancellableContext
- public CancellationToken CancellationToken { get; }
- public ReadOnlyMemory<byte> OutgoingBody { get; set; }
- public Dictionary<string, string> OutgoingHeaders { get; }
- public object OutgoingMessage { get; }
- public MutateOutgoingTransportMessageContext(ReadOnlyMemory<byte> outgoingBody, object outgoingMessage, Dictionary<string, string> outgoingHeaders, object incomingMessage, IReadOnlyDictionary<string, string> incomingHeaders, CancellationToken cancellationToken = default)
- public bool TryGetIncomingHeaders(out IReadOnlyDictionary incomingHeaders)
- public bool TryGetIncomingMessage(out object incomingMessage)
public static class MutatorRegistrationExtensions
- public static void RegisterMessageMutator(this EndpointConfiguration endpointConfiguration, object messageMutator)

NServiceBus.ObjectBuilder

public interface IComponentConfig
public interface IComponentConfig<T>
public interface IConfigureComponents
- IComponentConfig ConfigureComponent(Type concreteComponent, DependencyLifecycle dependencyLifecycle)
- IComponentConfig<T> ConfigureComponent<T>(DependencyLifecycle dependencyLifecycle)
- IComponentConfig<T> ConfigureComponent<T>(Func<T> componentFactory, DependencyLifecycle dependencyLifecycle)
- IComponentConfig<T> ConfigureComponent<T>(Func<IBuilder, T> componentFactory, DependencyLifecycle dependencyLifecycle)
- IConfigureComponents ConfigureProperty<T>(Expression<Func<T, object>> property, object value)
- IConfigureComponents ConfigureProperty<T>(string propertyName, object value)
- void ConfigureComponent(Type concreteComponent, DependencyLifecycle dependencyLifecycle)
- void ConfigureComponent<T>(DependencyLifecycle dependencyLifecycle)
- void ConfigureComponent<T>(Func<T> componentFactory, DependencyLifecycle dependencyLifecycle)
- void ConfigureComponent<T>(Func<IServiceProvider, T> componentFactory, DependencyLifecycle dependencyLifecycle)
- IConfigureComponents RegisterSingleton(Type lookupType, object instance)
- IConfigureComponents RegisterSingleton<T>(T instance)
- void RegisterSingleton(Type lookupType, object instance)
- void RegisterSingleton<T>(T instance)
public static class ServiceProviderExtensions
- public static object Build(this IServiceProvider serviceProvider, Type typeToBuild)
- public static T Build<T>(this IServiceProvider serviceProvider)
- public static IEnumerable<T> BuildAll<T>(this IServiceProvider serviceProvider)
- public static IEnumerable<object> BuildAll(this IServiceProvider serviceProvider, Type typeToBuild)
- public static void BuildAndDispatch(this IServiceProvider serviceProvider, Type typeToBuild, Action<object> action)
- public static IServiceScope CreateChildBuilder(this IServiceProvider serviceProvider)
- public static void Release(this IServiceProvider serviceProvider, object instance)

NServiceBus.ObjectBuilder.Common

public interface IContainer : IDisposable
- object Build(Type typeToBuild)
- IEnumerable<object> BuildAll(Type typeToBuild)
- IContainer BuildChildContainer()
- void Configure(Type component, DependencyLifecycle dependencyLifecycle)
- void Configure<T>(Func<T> component, DependencyLifecycle dependencyLifecycle)
- void ConfigureProperty(Type component, string property, object value)
- bool HasComponent(Type componentType)
- void RegisterSingleton(Type lookupType, object instance)
- void Release(object instance)

NServiceBus.ObjectBuilder.Common.Config

public static class ConfigureContainer

NServiceBus.Outbox

public interface IOutboxStorage
- void SetAsDispatched(string messageId)
- void Store(string messageId, IEnumerable<TransportOperation> transportOperations)
- bool TryGet(string messageId, out OutboxMessage message)
- Task<IOutboxTransaction> BeginTransaction(ContextBag context, CancellationToken cancellationToken = default)
- Task<OutboxMessage> Get(string messageId, ContextBag context, CancellationToken cancellationToken = default)
- Task SetAsDispatched(string messageId, ContextBag context, CancellationToken cancellationToken = default)
- Task Store(OutboxMessage message, IOutboxTransaction transaction, ContextBag context, CancellationToken cancellationToken = default)
public interface IOutboxTransaction : IDisposable
- Task Commit(CancellationToken cancellationToken = default)
public class OutboxMessage
- public List<TransportOperation> TransportOperations { get; }
- public OutboxMessage(string messageId)
- public TransportOperation[] TransportOperations { get; }
- public OutboxMessage(string messageId, TransportOperation[] operations)
public class OutboxSettings : ExposeSettings
- public void TimeToKeepDeduplicationData(TimeSpan time)
public interface OutboxTransaction
public class TransportOperation
- public byte[] Body { get; }
- public ReadOnlyMemory<byte> Body { get; }
- public Dictionary<string, string> Options { get; }
- public TransportOperation(string messageId, Dictionary<string, string> options, byte[] body, Dictionary<string, string> headers)
- public DispatchProperties Options { get; }
- public TransportOperation(string messageId, DispatchProperties properties, ReadOnlyMemory<byte> body, Dictionary<string, string> headers)

NServiceBus.Performance.TimeToBeReceived

public class DiscardIfNotReceivedBefore
- public TimeSpan MaxTime { get; }
- public DiscardIfNotReceivedBefore(TimeSpan maxTime)

NServiceBus.Persistence

public class ConcurrencyException : Exception
public interface CompletableSynchronizedStorageSession
public static class CompletableSynchronizedStorageSessionExtensions
- public static ValueTask Open(this ICompletableSynchronizedStorageSession session, IIncomingLogicalMessageContext context)
- public static ValueTask Open(this ICompletableSynchronizedStorageSession session, IOutboxTransaction outboxTransaction, TransportTransaction transportTransaction, ContextBag contextBag, CancellationToken cancellationToken = default)
public interface ICompletableSynchronizedStorageSession : ISynchronizedStorageSession, IDisposable
- Task CompleteAsync(CancellationToken cancellationToken = default)
- Task Open(ContextBag context, CancellationToken cancellationToken = default)
- ValueTask<bool> TryOpen(IOutboxTransaction transaction, ContextBag context, CancellationToken cancellationToken = default)
- ValueTask<bool> TryOpen(TransportTransaction transportTransaction, ContextBag context, CancellationToken cancellationToken = default)
public interface ISynchronizedStorage
- Task<ICompletableSynchronizedStorageSession> OpenSession(ContextBag contextBag, CancellationToken cancellationToken = default)
public interface ISynchronizedStorageAdapter
- Task<ICompletableSynchronizedStorageSession> TryAdapt(IOutboxTransaction transaction, ContextBag context, CancellationToken cancellationToken = default)
- Task<ICompletableSynchronizedStorageSession> TryAdapt(TransportTransaction transportTransaction, ContextBag context, CancellationToken cancellationToken = default)
public interface ISynchronizedStorageSession
public abstract class PersistenceDefinition
- public bool HasSupportFor(Storage storage)
- protected void Supports(Storage storage, Action<SettingsHolder> action)
public enum Storage
public abstract class StorageType
public interface SynchronizedStorageSession

NServiceBus.Persistence.Legacy

public class MsmqPersistence : PersistenceDefinition

NServiceBus.Pipeline

public abstract class BehaviorContext
public interface IBehavior<TContext> where TContext : BehaviorContext
public class PipelineExecutor : IDisposable
public class PipelineNotifications : IDisposable
public abstract class Behavior<TContext> : IBehavior<TContext, TContext>, IBehavior where TContext : IBehaviorContext
- protected Behavior()
- public Task Invoke(TContext context, Func<TContext, Task> next)
- public abstract Task Invoke(TContext context, Func<Task> next)
public abstract class ForkConnector<TFromContext, TForkContext> : Behavior<TFromContext>, IForkConnector<TFromContext, TFromContext, TForkContext>, IBehavior<TFromContext, TFromContext>, IBehavior, IForkConnector where TFromContext : IBehaviorContext where TForkContext : IBehaviorContext
- protected ForkConnector()
- public abstract Task Invoke(TFromContext context, Func<Task> next, Func<TForkContext, Task> fork)
public interface IAuditActionContext : IBehaviorContext, ICancellableContext, IExtendable
- string AuditAddress { get; }
- IReadOnlyDictionary<string, string> AuditMetadata { get; }
- OutgoingMessage Message { get; }
- TimeSpan? TimeToBeReceived { get; }
public interface IAuditContext : IBehaviorContext, ICancellableContext, IExtendable
- AuditAction AuditAction { get; set; }
- string AuditAddress { get; }
- Dictionary<string, string> AuditMetadata { get; }
- OutgoingMessage Message { get; }
- TimeSpan? TimeToBeReceived { get; }
- void AddAuditData(string key, string value)
- IAuditActionContext PreventChanges()
public interface IBatchDispatchContext : IBehaviorContext, ICancellableContext, IExtendable
- IReadOnlyCollection<TransportOperation> Operations { get; }
public interface IBehavior
public interface IBehavior<TInContext, TOutContext> : IBehavior where TInContext : IBehaviorContext where TOutContext : IBehaviorContext
- Task Invoke(TInContext context, Func<TOutContext, Task> next)
public interface IBehaviorContext : ICancellableContext, IExtendable
- IServiceProvider Builder { get; }
public interface IDispatchContext : IBehaviorContext, ICancellableContext, IExtendable
- IEnumerable<TransportOperation> Operations { get; }
public interface IForwardingContext : IBehaviorContext, ICancellableContext, IExtendable
public interface IIncomingContext : IBehaviorContext, ICancellableContext, IExtendable, IMessageProcessingContext, IPipelineContext
public interface IIncomingLogicalMessageContext : IIncomingContext, IBehaviorContext, ICancellableContext, IExtendable, IMessageProcessingContext, IPipelineContext
- Dictionary<string, string> Headers { get; }
- LogicalMessage Message { get; }
- bool MessageHandled { get; set; }
- void UpdateMessageInstance(object newInstance)
public interface IIncomingPhysicalMessageContext : IIncomingContext, IBehaviorContext, ICancellableContext, IExtendable, IMessageProcessingContext, IPipelineContext
- IncomingMessage Message { get; }
- void UpdateMessage(ReadOnlyMemory<byte> body)
public interface IInvokeHandlerContext : IIncomingContext, IBehaviorContext, ICancellableContext, IExtendable, IMessageProcessingContext, IPipelineContext, IMessageHandlerContext
- bool HandlerInvocationAborted { get; }
- Dictionary<string, string> Headers { get; }
- object MessageBeingHandled { get; }
- MessageHandler MessageHandler { get; }
- MessageMetadata MessageMetadata { get; }
public interface IOutgoingContext : IBehaviorContext, ICancellableContext, IExtendable, IPipelineContext
- Dictionary<string, string> Headers { get; }
- string MessageId { get; }
public interface IOutgoingLogicalMessageContext : IOutgoingContext, IBehaviorContext, ICancellableContext, IExtendable, IPipelineContext
- OutgoingLogicalMessage Message { get; }
- IReadOnlyCollection<RoutingStrategy> RoutingStrategies { get; }
- void UpdateMessage(object newInstance)
public interface IOutgoingPhysicalMessageContext : IOutgoingContext, IBehaviorContext, ICancellableContext, IExtendable, IPipelineContext
- ReadOnlyMemory<byte> Body { get; }
- IReadOnlyCollection<RoutingStrategy> RoutingStrategies { get; }
- void UpdateMessage(ReadOnlyMemory<byte> body)
public interface IOutgoingPublishContext : IOutgoingContext, IBehaviorContext, ICancellableContext, IExtendable, IPipelineContext
- OutgoingLogicalMessage Message { get; }
public interface IOutgoingReplyContext : IOutgoingContext, IBehaviorContext, ICancellableContext, IExtendable, IPipelineContext
- OutgoingLogicalMessage Message { get; }
public interface IOutgoingSendContext : IOutgoingContext, IBehaviorContext, ICancellableContext, IExtendable, IPipelineContext
- OutgoingLogicalMessage Message { get; }
public interface IRecoverabilityActionContext : IBehaviorContext, ICancellableContext, IExtendable
- int DelayedDeliveriesPerformed { get; }
- Exception Exception { get; }
- IncomingMessage FailedMessage { get; }
- int ImmediateProcessingFailures { get; }
- IReadOnlyDictionary<string, string> Metadata { get; }
- string ReceiveAddress { get; }
public interface IRecoverabilityContext : IBehaviorContext, ICancellableContext, IExtendable
- int DelayedDeliveriesPerformed { get; }
- Exception Exception { get; }
- IncomingMessage FailedMessage { get; }
- int ImmediateProcessingFailures { get; }
- Dictionary<string, string> Metadata { get; }
- string ReceiveAddress { get; }
- RecoverabilityAction RecoverabilityAction { get; set; }
- RecoverabilityConfig RecoverabilityConfiguration { get; }
- IRecoverabilityActionContext PreventChanges()
public interface IRoutingContext : IBehaviorContext, ICancellableContext, IExtendable
- OutgoingMessage Message { get; }
- IReadOnlyCollection<RoutingStrategy> RoutingStrategies { get; set; }
public interface ISubscribeContext : IBehaviorContext, ICancellableContext, IExtendable
- Type EventType { get; }
- Type[] EventTypes { get; }
public interface ITransportReceiveContext : IBehaviorContext, ICancellableContext, IExtendable
- IncomingMessage Message { get; }
- void AbortReceiveOperation()
public interface IUnsubscribeContext : IBehaviorContext, ICancellableContext, IExtendable
- Type EventType { get; }
public class LogicalMessage
- public object Instance { get; }
- public Type MessageType { get; }
- public MessageMetadata Metadata { get; }
- public LogicalMessage(MessageMetadata metadata, object message)
public class LogicalMessageFactory
- public LogicalMessageFactory(MessageMetadataRegistry messageMetadataRegistry, IMessageMapper messageMapper)
- public LogicalMessage Create(object message)
- public LogicalMessage Create(Type messageType, object message)
public class MessageHandler
- public Type HandlerType { get; }
- public object Instance { get; set; }
- public MessageHandler(Func<object, object, IMessageHandlerContext, Task> invocation, Type handlerType)
- public Task Invoke(object message, IMessageHandlerContext handlerContext)
public class OutgoingLogicalMessage
- public object Instance { get; }
- public Type MessageType { get; }
- public OutgoingLogicalMessage(Type messageType, object message)
public class PipelineSettings : ExposeSettings
- public PipelineSettings(BusConfiguration config)
- public void Register(Type behavior, string description)
- public void Register(WellKnownStep wellKnownStep, Type behavior, string description)
- public void Register<T>(Func<IServiceProvider, T> factoryMethod, string description) where T : IBehavior
- public void Register<T>(string stepId, Func<IServiceProvider, T> factoryMethod, string description) where T : IBehavior
- public void Register<T>(T behavior, string description) where T : IBehavior
- public void Register<T>(string stepId, T behavior, string description) where T : IBehavior
- public void Register(RegisterStep registration)
- public void RegisterOrReplace(string stepId, Type behavior, string description = null)
- public void RegisterOrReplace<T>(string stepId, T behavior, string description = null) where T : IBehavior
- public void RegisterOrReplace<T>(string stepId, Func<IServiceProvider, T> factoryMethod, string description = null) where T : IBehavior
- public void Remove(WellKnownStep wellKnownStep)
- public void Replace(WellKnownStep wellKnownStep, Type newBehavior, string description = null)
- public void Replace<T>(string stepId, T newBehavior, string description = null) where T : IBehavior
- public void Replace<T>(string stepId, Func<IServiceProvider, T> factoryMethod, string description = null) where T : IBehavior
public abstract class PipelineTerminator<T> : StageConnector<T, ITerminatingContext<T>>, IPipelineTerminator where T : IBehaviorContext
- public interface ITerminatingContext<T> : IBehaviorContext, ICancellableContext, IExtendable where T : IBehaviorContext
- protected PipelineTerminator()
- protected abstract Task Terminate(T context)
public abstract class RegisterStep
- protected RegisterStep(string stepId, Type behavior, string description)
- public void InsertAfter(WellKnownStep step)
- protected RegisterStep(string stepId, Type behavior, string description, Func<IServiceProvider, IBehavior> factoryMethod = null)
- public void InsertAfterIfExists(WellKnownStep step)
- public void InsertBefore(WellKnownStep step)
- public void InsertBeforeIfExists(WellKnownStep step)
public struct StepEnded
public struct StepStarted
public class WellKnownStep
public abstract class StageConnector<TFromContext, TToContext> : IStageConnector<TFromContext, TToContext>, IBehavior<TFromContext, TToContext>, IBehavior, IStageConnector where TFromContext : IBehaviorContext where TToContext : IBehaviorContext
- protected StageConnector()
- public abstract Task Invoke(TFromContext context, Func<TToContext, Task> stage)
public abstract class StageForkConnector<TFromContext, TToContext, TForkContext> : IStageForkConnector<TFromContext, TToContext, TForkContext>, IForkConnector<TFromContext, TToContext, TForkContext>, IBehavior<TFromContext, TToContext>, IBehavior, IForkConnector, IStageConnector where TFromContext : IBehaviorContext where TToContext : IBehaviorContext where TForkContext : IBehaviorContext
- protected StageForkConnector()
- public Task Invoke(TFromContext context, Func<TToContext, Task> next)
- public abstract Task Invoke(TFromContext context, Func<TToContext, Task> stage, Func<TForkContext, Task> fork)
public static class TransportMessageContextExtensions
- public static bool TryGetIncomingPhysicalMessage(this IOutgoingReplyContext context, out IncomingMessage message)
- public static bool TryGetIncomingPhysicalMessage(this IOutgoingLogicalMessageContext context, out IncomingMessage message)
- public static bool TryGetIncomingPhysicalMessage(this IOutgoingPhysicalMessageContext context, out IncomingMessage message)

NServiceBus.Pipeline.Contexts

public class IncomingContext : BehaviorContext
public class OutgoingContext : BehaviorContext

NServiceBus.Recoverability

public static class RecoverabilityContextExtensions
- public static IRoutingContext CreateRoutingContext(this IRecoverabilityActionContext context, OutgoingMessage outgoingMessage, RoutingStrategy routingStrategy)

NServiceBus.Routing

public abstract class AddressTag
- protected AddressTag()
public class DistributionContext : IExtendable
- public ContextBag Extensions { get; }
- public Dictionary<string, string> Headers { get; }
- public OutgoingLogicalMessage Message { get; }
- public string MessageId { get; }
- public string[] ReceiverAddresses { get; }
- public DistributionContext(string[] receiverAddresses, OutgoingLogicalMessage message, string messageId, Dictionary<string, string> headers, ITransportAddressResolver addressTranslation, ContextBag extensions)
- public string ToTransportAddress(EndpointInstance endpointInstance)
public abstract class DistributionStrategy
- public string Endpoint { get; }
- public DistributionStrategyScope Scope { get; }
- protected DistributionStrategy(string endpoint, DistributionStrategyScope scope)
- public abstract string SelectDestination(DistributionContext context)
public sealed class EndpointInstance
- public string Discriminator { get; }
- public string Endpoint { get; }
- public IReadOnlyDictionary<string, string> Properties { get; }
- public EndpointInstance(string endpoint, string discriminator = null, IReadOnlyDictionary<string, string> properties = null)
- public static bool op_Equality(EndpointInstance left, EndpointInstance right)
- public static bool op_Inequality(EndpointInstance left, EndpointInstance right)
- public EndpointInstance SetProperty(string key, string value)
public class EndpointInstances
- public EndpointInstances()
- public void AddOrReplaceInstances(string sourceKey, IList<EndpointInstance> endpointInstances)
- public IEnumerable<EndpointInstance> FindInstances(string endpoint)
public interface IMessageDrivenSubscriptionTransport
public class MulticastAddressTag : AddressTag
- public Type MessageType { get; }
- public MulticastAddressTag(Type messageType)
public class MulticastRoutingStrategy : RoutingStrategy
- public MulticastRoutingStrategy(Type messageType)
public class RouteTableEntry
- public Type MessageType { get; }
- public UnicastRoute Route { get; }
- public RouteTableEntry(Type messageType, UnicastRoute route)
public abstract class RoutingStrategy
- protected RoutingStrategy()
- public abstract AddressTag Apply(Dictionary<string, string> headers)
public class SingleInstanceRoundRobinDistributionStrategy : DistributionStrategy
- public SingleInstanceRoundRobinDistributionStrategy(string endpoint, DistributionStrategyScope scope)
public class UnicastAddressTag : AddressTag
- public string Destination { get; }
- public UnicastAddressTag(string destination)
public class UnicastRoute
- public string Endpoint { get; }
- public EndpointInstance Instance { get; }
- public string PhysicalAddress { get; }
- public static UnicastRoute CreateFromEndpointInstance(EndpointInstance instance)
- public static UnicastRoute CreateFromEndpointName(string endpoint)
- public static UnicastRoute CreateFromPhysicalAddress(string physicalAddress)
public class UnicastRoutingStrategy : RoutingStrategy
- public UnicastRoutingStrategy(string destination)
public class UnicastRoutingTable
- public UnicastRoutingTable()
- public void AddOrReplaceRoutes(string sourceKey, IList<RouteTableEntry> entries)

NServiceBus.Routing.MessageDrivenSubscriptions

public class PublisherAddress
- public static PublisherAddress CreateFromEndpointInstances(EndpointInstance[] instances)
- public static PublisherAddress CreateFromEndpointName(string endpoint)
- public static PublisherAddress CreateFromPhysicalAddresses(string[] addresses)
public class Publishers
- public Publishers()
- public void AddOrReplacePublishers(string sourceKey, IList<PublisherTableEntry> entries)
public class PublisherTableEntry
- public PublisherAddress Address { get; }
- public Type EventType { get; }
- public PublisherTableEntry(Type eventType, PublisherAddress address)

NServiceBus.Saga

public abstract class ContainSagaData : IContainSagaData
public interface HasCompleted
public interface IAmStartedByMessages<T> : IHandleMessages<T>
public interface IConfigurable
public interface IConfigureHowToFindSagaWithMessage
public interface IContainSagaData
public interface IFinder
public abstract class IFindSagas<T> where T : IContainSagaData
public interface IHandleSagaNotFound
public interface IHandleTimeouts<T>
public interface IPersistSagas
public interface ISaga
public interface ISaga<T>
public interface ISagaPersister
public abstract class Saga
public abstract class Saga<TSagaData> : Saga where TSagaData : IContainSagaData
public class SagaPropertyMapper<TSagaData> where TSagaData : IContainSagaData
public class ToSagaExpression<TSagaData, TMessage> where TSagaData : IContainSagaData
public sealed class UniqueAttribute : Attribute

NServiceBus.Sagas

public class ActiveSagaInstance
- public Saga Instance { get; }
- public DateTimeOffset Created { get; }
- public Saga Instance { get; }
- public DateTimeOffset Modified { get; }
- public Type SagaType { get; }
- public void AttachNewEntity(IContainSagaData sagaEntity)
- public ActiveSagaInstance(Saga saga, SagaMetadata metadata, Func<DateTimeOffset> currentDateTimeOffsetProvider)
- public void AttachNewEntity(IContainSagaData sagaEntity)
public interface IFinder
public abstract class IFindSagas<T>
- protected IFindSagas()
public interface IHandleSagaNotFound
- Task Handle(object message, IMessageProcessingContext context)
public interface ISagaFinder<TSagaData, TMessage> : IFinder where TSagaData : IContainSagaData
- Task<TSagaData> FindBy(TMessage message, ISynchronizedStorageSession storageSession, IReadOnlyContextBag context, CancellationToken cancellationToken = default)
public interface ISagaIdGenerator
- Guid Generate(SagaIdGeneratorContext context)
public interface ISagaPersister
- Task Complete(IContainSagaData sagaData, ISynchronizedStorageSession session, ContextBag context, CancellationToken cancellationToken = default)
- Task<TSagaData> Get<TSagaData>(Guid sagaId, ISynchronizedStorageSession session, ContextBag context, CancellationToken cancellationToken = default) where TSagaData : IContainSagaData
- Task<TSagaData> Get<TSagaData>(string propertyName, object propertyValue, ISynchronizedStorageSession session, ContextBag context, CancellationToken cancellationToken = default) where TSagaData : IContainSagaData
- Task Save(IContainSagaData sagaData, SagaCorrelationProperty correlationProperty, ISynchronizedStorageSession session, ContextBag context, CancellationToken cancellationToken = default)
- Task Update(IContainSagaData sagaData, ISynchronizedStorageSession session, ContextBag context, CancellationToken cancellationToken = default)
public class SagaCorrelationProperty
- public static SagaCorrelationProperty None { get; }
- public string Name { get; }
- public object Value { get; }
- public SagaCorrelationProperty(string name, object value)
public class SagaFinderDefinition
- public Type MessageType { get; }
- public string MessageTypeName { get; }
- public Dictionary<string, object> Properties { get; }
- public Type Type { get; }
public class SagaIdGeneratorContext : IExtendable
- public SagaCorrelationProperty CorrelationProperty { get; }
- public ContextBag Extensions { get; }
- public SagaMetadata SagaMetadata { get; }
- public SagaIdGeneratorContext(SagaCorrelationProperty correlationProperty, SagaMetadata sagaMetadata, ContextBag extensions)
public class SagaMessage
- public bool IsAllowedToStartSaga { get; }
- public Type MessageType { get; }
- public string MessageTypeName { get; }
public class SagaMetadata
- public class CorrelationPropertyMetadata
- public IReadOnlyCollection<SagaMessage> AssociatedMessages { get; }
- public string EntityName { get; }
- public IReadOnlyCollection<SagaFinderDefinition> Finders { get; }
- public string Name { get; }
- public Type SagaEntityType { get; }
- public Type SagaType { get; }
- public SagaMetadata(string name, Type sagaType, string entityName, Type sagaEntityType, CorrelationPropertyMetadata correlationProperty, IReadOnlyCollection<SagaMessage> messages, IReadOnlyCollection<SagaFinderDefinition> finders)
- public static SagaMetadata Create(Type sagaType)
- public static SagaMetadata Create(Type sagaType, IEnumerable<Type> availableTypes, Conventions conventions)
- public bool IsMessageAllowedToStartTheSaga(string messageType)
- public bool TryGetCorrelationProperty(out CorrelationPropertyMetadata property)
- public bool TryGetFinder(string messageType, out SagaFinderDefinition finderDefinition)
public class SagaMetadataCollection : IEnumerable<SagaMetadata>, IEnumerable
- public SagaMetadataCollection()
- public SagaMetadata Find(Type sagaType)
- public SagaMetadata FindByEntity(Type entityType)
- public IEnumerator<SagaMetadata> GetEnumerator()
- public void Initialize(IEnumerable<Type> availableTypes)
- public void Initialize(IEnumerable<Type> availableTypes, Conventions conventions)
public class SagaSettings : ExposeSettings
- public void DisableBestPracticeValidation()

NServiceBus.Satellites

public interface IAdvancedSatellite : ISatellite
public interface ISatellite

NServiceBus.SecondLevelRetries.Config

public class SecondLevelRetriesSettings

NServiceBus.SecondLevelRetries.Helpers

public static class TransportMessageHelpers

NServiceBus.Serialization

public interface IMessageSerializer
- object[] Deserialize(Stream stream, IList<Type> messageTypes = null)
- object[] Deserialize(ReadOnlyMemory<byte> body, IList<Type> messageTypes = null)
public abstract class SerializationDefinition
- public abstract Func<IMessageMapper, IMessageSerializer> Configure(IReadOnlySettings settings)
public class SerializationExtentions<T> : ExposeSettings where T : SerializationDefinition
public class SerializationExtensions<T> : ExposeSettings where T : SerializationDefinition
- public SerializationExtensions(SettingsHolder serializerSettings, SettingsHolder endpointConfigurationSettings)

NServiceBus.Serializers.Binary

public class BinaryMessageSerializer : IMessageSerializer
public class SimpleMessageMapper : IMessageMapper, IMessageCreator

NServiceBus.Serializers.Json

public class BsonMessageSerializer : JsonMessageSerializerBase
public class JsonMessageSerializer : JsonMessageSerializerBase
public abstract class JsonMessageSerializerBase : IMessageSerializer

NServiceBus.Serializers.XML

public class XmlMessageSerializer : IMessageSerializer

NServiceBus.Serializers.XML.Config

public class XmlSerializationSettings

NServiceBus.Settings

public interface IReadOnlySettings
- T Get<T>()
- T Get<T>(string key)
- object Get(string key)
- T GetOrDefault<T>()
- T GetOrDefault<T>(string key)
- bool HasExplicitValue(string key)
- bool HasExplicitValue<T>()
- bool HasSetting(string key)
- bool HasSetting<T>()
- bool TryGet<T>(out T val)
- bool TryGet<T>(string key, out T val)
public interface ReadOnlySettings
- void ApplyTo<T>(IComponentConfig config)
- T Get<T>()
- T Get<T>(string key)
- object Get(string key)
- T GetOrDefault<T>(string key)
- bool HasExplicitValue(string key)
- bool HasExplicitValue<T>()
- bool HasSetting(string key)
- bool HasSetting<T>()
- bool TryGet<T>(out T val)
- bool TryGet<T>(string key, out T val)
public class ScaleOutSettings
public class SerializationSettings
public class SettingsHolder : IReadOnlySettings
- public void ApplyTo<T>(IComponentConfig config)
- public void Clear()
- public T GetOrCreate<T>()
- public void Set(string key, object value)
- public void Set(string key, object value)
- public void Set<T>(T value)
- public void SetDefault<T>(T value)
- public void SetProperty<T>(Expression<Func<T, object>> property, object value)
- public void SetPropertyDefault<T>(Expression<Func<T, object>> property, object value)
public class TransactionSettings

NServiceBus.Timeout.Core

public interface IManageTimeouts
public interface IPersistTimeouts
- void Add(TimeoutData timeout)
- IEnumerable<Tuple<string, DateTime>> GetNextChunk(DateTime startSlice, out DateTime nextTimeToRunQuery)
- void RemoveTimeoutBy(Guid sagaId)
- bool TryRemove(string timeoutId, out TimeoutData timeoutData)
- Task Add(TimeoutData timeout, ContextBag context)
- Task<TimeoutData> Peek(string timeoutId, ContextBag context)
- Task RemoveTimeoutBy(Guid sagaId, ContextBag context)
- Task<bool> TryRemove(string timeoutId, ContextBag context)
public interface IPersistTimeoutsV2
public interface IQueryTimeouts
- Task<TimeoutsChunk> GetNextChunk(DateTime startSlice)
public class TimeoutData
- public const string OriginalReplyToAddress = "NServiceBus.Timeout.ReplyToAddress"
- public Address Destination { get; set; }
- public string Destination { get; }
- public SendOptions ToSendOptions(Address replyToAddress)
- public TransportMessage ToTransportMessage()
public static class TimeoutPersistenceVersionCheckExtension
public class TimeoutsChunk
- public struct Timeout
- public Timeout[] DueTimeouts { get; }
- public DateTime NextTimeToQuery { get; }
- public TimeoutsChunk(Timeout[] dueTimeouts, DateTime nextTimeToQuery)

NServiceBus.Transport

public enum DispatchConsistency
- Default = 1
- Isolated = 2
public class DispatchProperties : Dictionary<string, string>
- public DelayDeliveryWith DelayDeliveryWith { get; set; }
- public DiscardIfNotReceivedBefore DiscardIfNotReceivedBefore { get; set; }
- public DoNotDeliverBefore DoNotDeliverBefore { get; set; }
- public DispatchProperties()
- public DispatchProperties(Dictionary<string, string> properties)
public class ErrorContext
- public int DelayedDeliveriesPerformed { get; }
- public Exception Exception { get; }
- public ContextBag Extensions { get; }
- public int ImmediateProcessingFailures { get; }
- public IncomingMessage Message { get; }
- public string ReceiveAddress { get; }
- public TransportTransaction TransportTransaction { get; }
- public ErrorContext(Exception exception, Dictionary<string, string> headers, string nativeMessageId, ReadOnlyMemory<byte> body, TransportTransaction transportTransaction, int immediateProcessingFailures, string receiveAddress, ContextBag context)
public enum ErrorHandleResult
- Handled = 0
- RetryRequired = 1
public class HostSettings
- public IReadOnlySettings CoreSettings { get; }
- public Action<string, Exception, CancellationToken> CriticalErrorAction { get; }
- public string HostDisplayName { get; }
- public string Name { get; }
- public bool SetupInfrastructure { get; }
- public StartupDiagnosticEntries StartupDiagnostic { get; }
- public HostSettings(string name, string hostDisplayName, StartupDiagnosticEntries startupDiagnostic, Action<string, Exception> criticalErrorAction, bool setupInfrastructure, ReadOnlySettings coreSettings = null)
- public HostSettings(string name, string hostDisplayName, StartupDiagnosticEntries startupDiagnostic, Action<string, Exception, CancellationToken> criticalErrorAction, bool setupInfrastructure, IReadOnlySettings coreSettings = null)
public interface ICancelDeferredMessages
- Task CancelDeferredMessages(string messageKey, IBehaviorContext context)
public interface ICreateQueues
- Task CreateQueueIfNecessary(QueueBindings queueBindings, string identity)
public interface IDispatchMessages
- Task Dispatch(TransportOperations outgoingMessages, TransportTransaction transaction, ContextBag context)
public interface IManageSubscriptions
- Task Subscribe(Type eventType, ContextBag context)
- Task Unsubscribe(Type eventType, ContextBag context)
public interface IMessageDispatcher
- Task Dispatch(TransportOperations outgoingMessages, TransportTransaction transaction, CancellationToken cancellationToken = default)
public interface IMessageReceiver
- string Id { get; }
- string ReceiveAddress { get; }
- ISubscriptionManager Subscriptions { get; }
- Task ChangeConcurrency(PushRuntimeSettings limitations, CancellationToken cancellationToken = default)
- Task Initialize(PushRuntimeSettings limitations, OnMessage onMessage, OnError onError, CancellationToken cancellationToken = default)
- Task StartReceive(CancellationToken cancellationToken = default)
- Task StopReceive(CancellationToken cancellationToken = default)
public class IncomingMessage
- public ReadOnlyMemory<byte> Body { get; }
- public Dictionary<string, string> Headers { get; }
- public string MessageId { get; }
- public string NativeMessageId { get; }
- public IncomingMessage(string nativeMessageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body)
public static class IncomingMessageExtensions
- public static MessageIntent GetMessageIntent(this IncomingMessage message)
- public static string GetReplyToAddress(this IncomingMessage message)
public interface IOutgoingTransportOperation
- OutgoingMessage Message { get; }
- DispatchProperties Properties { get; }
- DispatchConsistency RequiredDispatchConsistency { get; }
public interface IPushMessages
- Task Init(Func<MessageContext, Task> onMessage, Func<ErrorContext, Task<ErrorHandleResult>> onError, CriticalError criticalError, PushSettings settings)
- void Start(PushRuntimeSettings limitations)
- Task Stop()
public interface ISubscriptionManager
- Task SubscribeAll(MessageMetadata[] eventTypes, ContextBag context, CancellationToken cancellationToken = default)
- Task Unsubscribe(MessageMetadata eventType, ContextBag context, CancellationToken cancellationToken = default)
public interface ITransportAddressResolver
- string ToTransportAddress(QueueAddress queueAddress)
public static class LogicalAddressExtensions
- public static string GetTransportAddress(this ReadOnlySettings settings, LogicalAddress logicalAddress)
public class MessageContext : IExtendable
- public ReadOnlyMemory<byte> Body { get; }
- public ContextBag Extensions { get; }
- public Dictionary<string, string> Headers { get; }
- public string MessageId { get; }
- public string NativeMessageId { get; }
- public string ReceiveAddress { get; }
- public CancellationTokenSource ReceiveCancellationTokenSource { get; }
- public TransportTransaction TransportTransaction { get; }
- public MessageContext(string messageId, Dictionary<string, string> headers, byte[] body, TransportTransaction transportTransaction, CancellationTokenSource receiveCancellationTokenSource, ContextBag context)
- public MessageContext(string nativeMessageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body, TransportTransaction transportTransaction, string receiveAddress, ContextBag context)
public class MulticastTransportOperation : IOutgoingTransportOperation
- public OutgoingMessage Message { get; }
- public Type MessageType { get; }
- public DispatchProperties Properties { get; }
- public DispatchConsistency RequiredDispatchConsistency { get; }
- public MulticastTransportOperation(OutgoingMessage message, Type messageType, DispatchProperties properties, DispatchConsistency requiredDispatchConsistency = 1)
public sealed delegate OnError : MulticastDelegate
- public OnError(object object, IntPtr method)
- public virtual IAsyncResult BeginInvoke(ErrorContext errorContext, CancellationToken cancellationToken, AsyncCallback callback, object object)
- public virtual Task<ErrorHandleResult> EndInvoke(IAsyncResult result)
- public virtual Task<ErrorHandleResult> Invoke(ErrorContext errorContext, CancellationToken cancellationToken = default)
public sealed delegate OnMessage : MulticastDelegate
- public OnMessage(object object, IntPtr method)
- public virtual IAsyncResult BeginInvoke(MessageContext messageContext, CancellationToken cancellationToken, AsyncCallback callback, object object)
- public virtual Task EndInvoke(IAsyncResult result)
- public virtual Task Invoke(MessageContext messageContext, CancellationToken cancellationToken = default)
public class OutboundRoutingPolicy
- public OutboundRoutingType Publishes { get; }
- public OutboundRoutingType Replies { get; }
- public OutboundRoutingType Sends { get; }
- public OutboundRoutingPolicy(OutboundRoutingType sends, OutboundRoutingType publishes, OutboundRoutingType replies)
public enum OutboundRoutingType
- Multicast = 1
- Unicast = 0
public class OutgoingMessage
- public ReadOnlyMemory<byte> Body { get; }
- public Dictionary<string, string> Headers { get; }
- public string MessageId { get; }
- public OutgoingMessage(string messageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body)
- public void UpdateBody(ReadOnlyMemory<byte> updatedBody)
public class PushRuntimeSettings
- public static PushRuntimeSettings Default { get; }
- public int MaxConcurrency { get; }
- public PushRuntimeSettings()
- public PushRuntimeSettings(int maxConcurrency)
public class PushSettings
- public PushSettings()
public class QueueAddress
- public string BaseAddress { get; }
- public string Discriminator { get; }
- public IReadOnlyDictionary<string, string> Properties { get; }
- public string Qualifier { get; }
- public QueueAddress(string baseAddress, string discriminator = null, IReadOnlyDictionary<string, string> properties = null, string qualifier = null)
public class QueueBindings
- public IReadOnlyCollection<string> ReceivingAddresses { get; }
- public IReadOnlyCollection<string> SendingAddresses { get; }
- public QueueBindings()
- public void BindReceiving(string address)
- public void BindSending(string transportAddress)
public class ReceiveSettings
- public string ErrorQueue { get; }
- public string Id { get; set; }
- public bool PurgeOnStartup { get; set; }
- public QueueAddress ReceiveAddress { get; }
- public bool UsePublishSubscribe { get; set; }
- public ReceiveSettings(string id, QueueAddress receiveAddress, bool usePublishSubscribe, bool purgeOnStartup, string errorQueue)
public class StartupCheckResult
- public static readonly StartupCheckResult Success
- public string ErrorMessage { get; }
- public bool Succeeded { get; }
- public StartupCheckResult()
- public static StartupCheckResult Failed(string errorMessage)
public abstract class TransportDefinition
- public bool SupportsDelayedDelivery { get; }
- public bool SupportsPublishSubscribe { get; }
- public bool SupportsTTBR { get; }
- public virtual TransportTransactionMode TransportTransactionMode { get; set; }
- protected TransportDefinition(TransportTransactionMode defaultTransactionMode, bool supportsDelayedDelivery, bool supportsPublishSubscribe, bool supportsTTBR)
- public abstract IReadOnlyCollection<TransportTransactionMode> GetSupportedTransactionModes()
- public abstract Task<TransportInfrastructure> Initialize(HostSettings hostSettings, ReceiveSettings[] receivers, string[] sendingAddresses, CancellationToken cancellationToken = default)
- public abstract string ToTransportAddress(QueueAddress address)
public abstract class TransportInfrastructure
- public IMessageDispatcher Dispatcher { get; protected set; }
- public IReadOnlyDictionary<string, IMessageReceiver> Receivers { get; protected set; }
- protected TransportInfrastructure()
- public abstract Task Shutdown(CancellationToken cancellationToken = default)
- public abstract string ToTransportAddress(QueueAddress address)
public class TransportOperation
- public AddressTag AddressTag { get; }
- public OutgoingMessage Message { get; }
- public DispatchProperties Properties { get; }
- public DispatchConsistency RequiredDispatchConsistency { get; set; }
- public TransportOperation(OutgoingMessage message, AddressTag addressTag, DispatchProperties properties = null, DispatchConsistency requiredDispatchConsistency = 1)
public class TransportOperations
- public List<MulticastTransportOperation> MulticastTransportOperations { get; }
- public List<UnicastTransportOperation> UnicastTransportOperations { get; }
- public TransportOperations(TransportOperation[] transportOperations)
public class TransportSendInfrastructure
- public Func<IMessageDispatcher> DispatcherFactory { get; }
- public Func<Task<StartupCheckResult>> PreStartupCheck { get; }
- public TransportSendInfrastructure(Func<IMessageDispatcher> dispatcherFactory, Func<Task<StartupCheckResult>> preStartupCheck)
public class TransportSubscriptionInfrastructure
- public TransportSubscriptionInfrastructure(Func<IManageSubscriptions> subscriptionManagerFactory)
public sealed class TransportTransaction : ContextBag
- public TransportTransaction()
public class UnicastTransportOperation : IOutgoingTransportOperation
- public string Destination { get; }
- public OutgoingMessage Message { get; }
- public DispatchProperties Properties { get; }
- public DispatchConsistency RequiredDispatchConsistency { get; }
- public UnicastTransportOperation(OutgoingMessage message, string destination, DispatchProperties properties, DispatchConsistency requiredDispatchConsistency = 1)

NServiceBus.Transports

public abstract class ConfigureTransport : Feature
public interface IAuditMessages
public interface ICreateQueues
public interface IDeferMessages
public interface IDequeueMessages
public interface IManageSubscriptions
public interface IPublishMessages
public interface ISendMessages
public abstract class TransportDefinition

NServiceBus.Transports.Msmq

public class HeaderInfo
public class MsmqDequeueStrategy : IDequeueMessages, IDisposable
public class MsmqMessageSender : ISendMessages
public class MsmqUnitOfWork : IDisposable
public class MsmqUtilities

NServiceBus.Transports.Msmq.Config

public class MsmqSettings

NServiceBus.Unicast

public static class BuilderExtensions
- public static void ForEach<T>(this IBuilder builder, Action<T> action)
- public static void ForEach<T>(this IServiceProvider builder, Action<T> action)
public class BusAsyncResult : IAsyncResult
public class Callback
public abstract class DeliveryOptions
public interface IMessageDispatcherFactory
public interface IMessageHandlerRegistry
public class IUnicastBus
public class MessageContext : IMessageContext
public class MessageHandlerRegistry
- public void CacheMethodForHandler(Type handler, Type messageType)
- public MessageHandlerRegistry()
- public IEnumerable<Type> GetHandlerTypes(Type messageType)
- public List<MessageHandler> GetHandlersFor(Type messageType)
- public void InvokeHandle(object handler, object message)
- public void InvokeTimeout(object handler, object state)
public class PublishOptions : DeliveryOptions
public class ReplyOptions : SendOptions
public class SendOptions : DeliveryOptions
public class UnicastBus : IStartableBus, IBus, ISendOnlyBus, IDisposable, IInMemoryOperations, IManageMessageHeaders

NServiceBus.Unicast.Behaviors

public class MessageHandler

NServiceBus.Unicast.Config

public class ConfigUnicastBus

NServiceBus.Unicast.Messages

public class LogicalMessage
public class LogicalMessageFactory
public class MessageMetadata
- public IEnumerable<Type> MessageHierarchy { get; }
- public Type[] MessageHierarchy { get; }
- public string MessageHierarchySerialized { get; }
- public bool Recoverable { get; }
- public TimeSpan TimeToBeReceived { get; }
- public MessageMetadata(Type messageType)
- public MessageMetadata(Type messageType, Type[] messageHierarchy)
public class MessageMetadataRegistry
- public MessageMetadataRegistry(Func<Type, bool> isMessageType, bool allowDynamicTypeLoading)
- public MessageMetadata[] GetAllMessages()

NServiceBus.Unicast.Queuing

public class FailedToSendMessageException : Exception
public interface IWantQueueCreated
public class QueueNotFoundException : Exception
- public Address Queue { get; set; }
- public string Queue { get; set; }
- public QueueNotFoundException(Address queue, string message, Exception inner)
- public QueueNotFoundException(string queue, string message, Exception inner)

NServiceBus.Unicast.Routing

public class StaticMessageRouter

NServiceBus.Unicast.Subscriptions

public class SubscriptionEventArgs : EventArgs

NServiceBus.Unicast.Subscriptions.MessageDrivenSubscriptions

public interface IInitializableSubscriptionStorage : ISubscriptionStorage
- void Init()
public interface ISubscriptionStorage
- IEnumerable<Address> GetSubscriberAddressesForMessage(IEnumerable<MessageType> messageTypes)
- void Init()
- void Subscribe(Address client, IEnumerable<MessageType> messageTypes)
- void Unsubscribe(Address client, IEnumerable<MessageType> messageTypes)
- Task<IEnumerable<Subscriber>> GetSubscriberAddressesForMessage(IEnumerable<MessageType> messageTypes, ContextBag context, CancellationToken cancellationToken = default)
- Task Subscribe(Subscriber subscriber, MessageType messageType, ContextBag context, CancellationToken cancellationToken = default)
- Task Unsubscribe(Subscriber subscriber, MessageType messageType, ContextBag context, CancellationToken cancellationToken = default)
public class Subscriber
- public string Endpoint { get; }
- public string TransportAddress { get; }
- public Subscriber(string transportAddress, string endpoint)

NServiceBus.Unicast.Transport

public static class ControlMessage
public class FailedMessageProcessingEventArgs : EventArgs
public class FinishedMessageProcessingEventArgs : EventArgs
public interface ITransport
public class StartedMessageProcessingEventArgs : EventArgs
public class TransactionSettings
public class TransportMessageAvailableEventArgs : EventArgs
public class TransportMessageHandlingFailedException : Exception
public class TransportMessageReceivedEventArgs : EventArgs
public class TransportReceiver : ITransport, IDisposable
public static class ControlMessageFactory
- public static OutgoingMessage Create(MessageIntent intent)

NServiceBus.UnitOfWork

public interface IManageUnitsOfWork
- void Begin()
- void End(Exception ex = null)
- Task Begin()
- Task End(Exception ex = null)

NServiceBus.Utils

public class FileVersionRetriever
public static class RegistryReader<T>

System.Threading.Tasks.Schedulers

public sealed class MTATaskScheduler

API Diff between 8.0.0 and 5.2.18

NServiceBus

NServiceBus.Audit

NServiceBus.AutomaticSubscriptions

NServiceBus.AutomaticSubscriptions.Config

NServiceBus.CircuitBreakers

NServiceBus.Config

NServiceBus.Config.ConfigurationSource

NServiceBus.Configuration.AdvanceExtensibility

NServiceBus.Configuration.AdvancedExtensibility

NServiceBus.ConsistencyGuarantees

NServiceBus.Container

NServiceBus.DataBus

NServiceBus.DelayedDelivery

NServiceBus.DeliveryConstraints

NServiceBus.Encryption

NServiceBus.Encryption.Rijndael

NServiceBus.Extensibility

NServiceBus.Faults

NServiceBus.Features

NServiceBus.Gateway.Deduplication

NServiceBus.Hosting

NServiceBus.Hosting.Helpers

NServiceBus.IdGeneration

NServiceBus.Installation

NServiceBus.Installation.Environments

NServiceBus.Logging

NServiceBus.Logging.Log4NetBridge

NServiceBus.Logging.Loggers

NServiceBus.Logging.Loggers.Log4NetAdapter

NServiceBus.Logging.Loggers.NLogAdapter

NServiceBus.MessageMutator

NServiceBus.ObjectBuilder

NServiceBus.ObjectBuilder.Common

NServiceBus.ObjectBuilder.Common.Config

NServiceBus.Outbox

NServiceBus.Performance.TimeToBeReceived

NServiceBus.Persistence

NServiceBus.Persistence.Legacy

NServiceBus.Pipeline

NServiceBus.Pipeline.Contexts

NServiceBus.Recoverability

NServiceBus.Routing

NServiceBus.Routing.MessageDrivenSubscriptions

NServiceBus.Saga

NServiceBus.Sagas

NServiceBus.Satellites

NServiceBus.SecondLevelRetries.Config

NServiceBus.SecondLevelRetries.Helpers

NServiceBus.Serialization

NServiceBus.Serializers.Binary

NServiceBus.Serializers.Json

NServiceBus.Serializers.XML

NServiceBus.Serializers.XML.Config

NServiceBus.Settings

NServiceBus.Timeout.Core

NServiceBus.Transport

NServiceBus.Transports

NServiceBus.Transports.Msmq

NServiceBus.Transports.Msmq.Config

NServiceBus.Unicast

NServiceBus.Unicast.Behaviors

NServiceBus.Unicast.Config

NServiceBus.Unicast.Messages

NServiceBus.Unicast.Queuing

NServiceBus.Unicast.Routing

NServiceBus.Unicast.Subscriptions

NServiceBus.Unicast.Subscriptions.MessageDrivenSubscriptions

NServiceBus.Unicast.Transport

NServiceBus.UnitOfWork

NServiceBus.Utils

System.Threading.Tasks.Schedulers