NServiceBus by Particular Software

<PackageReference Include="NServiceBus" Version="8.0.0" />

---

API Diff between 8.0.0 and 7.8.4

402 Additions 244 Removals

NServiceBus

• public static class AuditConfigReader
  • public static bool TryGetAuditMessageExpiration(this ReadOnlySettings settings, out TimeSpan auditMessageExpiration)
  • public static bool TryGetAuditQueueAddress(this ReadOnlySettings settings, out string address)
  • 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 ConfigureCriticalErrorAction
  • public static void DefineCriticalErrorAction(this EndpointConfiguration endpointConfiguration, Func<ICriticalErrorContext, CancellationToken, Task> onCriticalError)
• public static class ConfigureRijndaelEncryptionService
• public static class ConnectorContextExtensions
  • public static IAuditContext CreateAuditContext(this ForkConnector<IIncomingPhysicalMessageContext, IAuditContext> forkConnector, OutgoingMessage message, string auditAddress, TimeSpan? timeToBeReceived, IIncomingPhysicalMessageContext sourceContext)
  • public static IInvokeHandlerContext CreateInvokeHandlerContext(this StageConnector<IIncomingLogicalMessageContext, IInvokeHandlerContext> stageConnector, MessageHandler messageHandler, CompletableSynchronizedStorageSession storageSession, IIncomingLogicalMessageContext sourceContext)
  • public static IInvokeHandlerContext CreateInvokeHandlerContext(this StageConnector<IIncomingLogicalMessageContext, IInvokeHandlerContext> stageConnector, MessageHandler messageHandler, ICompletableSynchronizedStorageSession storageSession, IIncomingLogicalMessageContext sourceContext)
  • public static IOutgoingPhysicalMessageContext CreateOutgoingPhysicalMessageContext(this StageConnector<IOutgoingLogicalMessageContext, IOutgoingPhysicalMessageContext> stageConnector, byte[] messageBody, IReadOnlyCollection<RoutingStrategy> routingStrategies, IOutgoingLogicalMessageContext sourceContext)
  • public static IOutgoingPhysicalMessageContext CreateOutgoingPhysicalMessageContext(this StageConnector<IOutgoingLogicalMessageContext, IOutgoingPhysicalMessageContext> stageConnector, ReadOnlyMemory<byte> messageBody, IReadOnlyCollection<RoutingStrategy> routingStrategies, IOutgoingLogicalMessageContext sourceContext)
• public class Conventions
  • public bool IsEncryptedProperty(PropertyInfo property)
• public class ConventionsBuilder : ExposeSettings
  • public ConventionsBuilder DefiningEncryptedPropertiesAs(Func<PropertyInfo, bool> definesEncryptedProperty)
• public static class CorrelationContextExtensions
• public class CriticalError
  • public CriticalError(Func<ICriticalErrorContext, CancellationToken, Task> onCriticalErrorAction)
  • public virtual void Raise(string errorMessage, Exception exception)
  • public virtual void Raise(string errorMessage, Exception exception, CancellationToken cancellationToken = default)
• public class CriticalErrorContext : ICriticalErrorContext
  • public Func<Task> Stop { get; }
  • public Func<CancellationToken, Task> Stop { get; }
  • public CriticalErrorContext(Func<CancellationToken, Task> stop, string error, Exception exception)
• public static class CriticalTimeMonitoringConfig
• public class DataBusProperty<T> : IDataBusProperty, ISerializable
  • public Type Type { get; }
• public static class DateTimeOffsetHelper
  • public static DateTimeOffset ToDateTimeOffset(string wireFormattedString)
  • public static string ToWireFormattedString(DateTimeOffset dateTime)
• public class DelayedRetriesSettings : ExposeSettings
  • public DelayedRetriesSettings OnMessageBeingRetried(Func<DelayedRetryMessage, CancellationToken, Task> notificationCallback)
• public static class DiagnosticSettingsExtensions
  • public static void AddStartupDiagnosticsSection(this ReadOnlySettings settings, string sectionName, object section)
  • public static void AddStartupDiagnosticsSection(this IReadOnlySettings settings, string sectionName, object section)
  • public static void CustomDiagnosticsWriter(this EndpointConfiguration config, Func<string, CancellationToken, Task> customDiagnosticsWriter)
• public class Discard : RecoverabilityAction
  • public Discard(string reason)
• public class EncryptedValue
• public static class Endpoint
  • public static Task<IStartableEndpoint> Create(EndpointConfiguration configuration)
  • public static Task<IEndpointInstance> Start(EndpointConfiguration configuration)
  • 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 void CustomConfigurationSource(IConfigurationSource configurationSource)
  • public void ExcludeAssemblies(string[] assemblies)
  • public void ExcludeTypes(Type[] types)
  • public void RegisterComponents(Action<IConfigureComponents> registration)
  • public void ScanAssembliesInNestedDirectories()
  • public void RegisterComponents(Action<IServiceCollection> registration)
  • public RoutingSettings<TTransport> UseTransport<TTransport>(TTransport transportDefinition) where TTransport : TransportDefinition
• public static class EndpointInstanceExtensions
  • public static Task Stop(this IEndpointInstance endpoint, TimeSpan gracefulStopTimeout)
• public static class EndpointWithExternallyManagedContainer
  • public static IStartableEndpointWithExternallyManagedContainer Create(EndpointConfiguration configuration, IConfigureComponents configureComponents)
  • public static IStartableEndpointWithExternallyManagedContainer Create(EndpointConfiguration configuration, IServiceCollection serviceCollection)
• public static class ErrorQueueSettings
  • public static string ErrorQueueAddress(this ReadOnlySettings settings)
  • public static bool TryGetExplicitlyConfiguredErrorQueueAddress(this ReadOnlySettings settings, out string errorQueue)
  • public static string ErrorQueueAddress(this IReadOnlySettings settings)
  • public static bool TryGetExplicitlyConfiguredErrorQueueAddress(this IReadOnlySettings settings, out string errorQueue)
• public class FailedConfig
  • public FailedConfig(string errorQueue)
• public static class Headers
  • public const string DataBusConfigContentType = "NServiceBus.DataBusConfig.ContentType"
  • public const string DiagnosticsBaggage = "baggage"
  • public const string DiagnosticsTraceParent = "traceparent"
  • public const string DiagnosticsTraceState = "tracestate"
• public class HostInfoSettings
  • public HostInfoSettings UsingHostName(string hostName)
• public interface ICancellableContext
  • CancellationToken CancellationToken { get; }
• public interface ICriticalErrorContext
  • Func<Task> Stop { get; }
  • Func<CancellationToken, Task> Stop { get; }
• public interface IDataBusProperty
  • Type Type { get; }
• public interface IEncryptionService
• public interface IEndpointInstance : IMessageSession
  • Task Stop()
  • Task Stop(CancellationToken cancellationToken = default)
• public interface IMessageHandlerContext : IMessageProcessingContext, IPipelineContext, ICancellableContext, IExtendable
  • SynchronizedStorageSession SynchronizedStorageSession { get; }
  • ISynchronizedStorageSession SynchronizedStorageSession { get; }
  • Task HandleCurrentMessageLater()
• public static class IMessageProcessingContextExtensions
• public interface IMessageSession
  • 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)
  • Task Subscribe(Type eventType, SubscribeOptions options)
  • Task Unsubscribe(Type eventType, UnsubscribeOptions options)
  • 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 static class IMessageSessionExtensions
• public static class ImmediateDispatchOptionExtensions
  • public static bool IsImmediateDispatchSet(this ExtendableOptions options)
• public class ImmediateRetriesSettings : ExposeSettings
  • public ImmediateRetriesSettings OnMessageBeingRetried(Func<ImmediateRetryMessage, CancellationToken, Task> notificationCallback)
• 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 class InMemorySagaPersistence
  • public InMemorySagaPersistence()
• public class InMemorySubscriptionPersistence
  • public InMemorySubscriptionPersistence()
• public class InMemoryTimeoutPersistence
  • public InMemoryTimeoutPersistence()
• public static class InstallConfigExtensions
  • public static void DisableInstallers(this EndpointConfiguration config)
• public static class IPipelineContextExtensions
• public interface IStartableEndpoint
  • Task<IEndpointInstance> Start()
  • Task<IEndpointInstance> Start(CancellationToken cancellationToken = default)
• public interface IStartableEndpointWithExternallyManagedContainer
  • Task<IEndpointInstance> Start(IBuilder builder)
  • Task<IEndpointInstance> Start(IServiceProvider builder, CancellationToken cancellationToken = default)
• public class JsonSerializer : SerializationDefinition
• public static class JsonSerializerConfigurationExtensions
• public class LearningTransport : TransportDefinition
  • public bool RestrictPayloadSize { get; set; }
  • public string StorageDirectory { get; set; }
• 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 TransportExtensions<LearningTransport> UseTransport<T>(this EndpointConfiguration config) where T : LearningTransport
• public struct LogicalAddress
  • public static bool op_Equality(LogicalAddress left, LogicalAddress right)
  • public static bool op_Inequality(LogicalAddress left, LogicalAddress right)
• public static class MessageDrivenSubscriptionsConfigExtensions
  • public static void DisablePublishing<T>(this RoutingSettings<T> routingSettings) where T : TransportDefinition, IMessageDrivenSubscriptionTransport
  • public static void SubscriptionAuthorizer<T>(this RoutingSettings<T> routingSettings, Func<IIncomingPhysicalMessageContext, bool> authorizer) where T : TransportDefinition, IMessageDrivenSubscriptionTransport
• 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 MessageProcessingContextExtensions
  • public static Task Reply(this IMessageProcessingContext context, object message)
  • public static Task Reply<T>(this IMessageProcessingContext context, Action<T> messageConstructor)
• 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 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 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 RateLimitSettings
  • public Func<Task> OnRateLimitEnded { get; }
  • public Func<Task> OnRateLimitStarted { get; }
  • public Func<CancellationToken, Task> OnRateLimitEnded { get; }
  • public Func<CancellationToken, Task> OnRateLimitStarted { get; }
  • public RateLimitSettings(TimeSpan? timeToWaitBetweenThrottledAttempts = default, Func<Task> onRateLimitStarted = null, Func<Task> onRateLimitEnded = null)
  • 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 DateTime CompletedAt { get; }
  • public DateTimeOffset CompletedAt { get; }
  • public DateTime StartedAt { get; }
  • public ReceivePipelineCompleted(IncomingMessage processedMessage, DateTime startedAt, DateTime completedAt)
  • 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, CancellationToken, Task> subscription)
• public abstract class RecoverabilityAction
  • public abstract ErrorHandleResult ErrorHandleResult { get; }
  • public abstract IReadOnlyCollection<IRoutingContext> GetRoutingContexts(IRecoverabilityActionContext context)
• public class RecoverabilitySettings : ExposeSettings
  • public RecoverabilitySettings DisableLegacyRetriesSatellite()
• public class RetryFailedSettings : ExposeSettings
  • public RetryFailedSettings OnMessageSentToErrorQueue(Func<FailedMessage, CancellationToken, Task> notificationCallback)
• public static class RoutingSettingsExtensions
  • public static RoutingSettings<T> Routing<T>(this TransportExtensions<T> config) where T : TransportDefinition
• public abstract class Saga
  • protected Task ReplyToOriginator(IMessageHandlerContext context, object message)
  • protected Task RequestTimeout<TTimeoutMessageType>(IMessageHandlerContext context, DateTime at)
  • protected Task RequestTimeout<TTimeoutMessageType>(IMessageHandlerContext context, DateTime at, TTimeoutMessageType timeoutMessage)
  • 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)
• public static class SagasConfigExtensions
  • public static SagaSettings Sagas(this EndpointConfiguration config)
• public class ScheduledTask
  • public TimeSpan Every { get; set; }
  • public string Name { get; set; }
  • public Guid TaskId { get; set; }
  • public ScheduledTask()
• 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 SettingsExtensions
  • public static string EndpointName(this ReadOnlySettings settings)
  • public static IList<Type> GetAvailableTypes(this ReadOnlySettings settings)
  • public static T GetConfigSection<T>(this ReadOnlySettings settings)
  • public static string InstanceSpecificQueue(this ReadOnlySettings settings)
  • public static string LocalAddress(this ReadOnlySettings settings)
  • 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 class SLAMonitoringConfig
• 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 TimeoutManagerConfiguration(SettingsHolder settings)
• public class TransportExtensions<T> where T : TransportDefinition
  • public T Transport { get; }
  • public TransportExtensions(T transport, RoutingSettings<T> routing)
  • public TransportExtensions<T> ConnectionString(string connectionString)
  • public TransportExtensions<T> ConnectionString(Func<string> connectionString)
  • public RoutingSettings<T> Routing()
• public static class UseDataBusExtensions
  • 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 class UseTransportExtensions
  • public static TransportExtensions<T> UseTransport<T>(this EndpointConfiguration endpointConfiguration) where T : TransportDefinition
• public class WireEncryptedString

NServiceBus.Audit

• public abstract class AuditAction
  • protected AuditAction()
  • public abstract IReadOnlyCollection<IRoutingContext> GetRoutingContexts(IAuditActionContext context)
• public class RouteToAudit : AuditAction

NServiceBus.Config

• public class AuditConfig
• public enum KeyFormat
• public class Logging
• public class MessageEndpointMapping : IComparable<MessageEndpointMapping>
• public class MessageEndpointMappingCollection
• public class MessageForwardingInCaseOfFaultConfig
• public class MsmqSubscriptionStorageConfig
• public class RijndaelEncryptionServiceConfig
• public class RijndaelExpiredKey
• public class RijndaelExpiredKeyCollection
• public class UnicastBusConfig

NServiceBus.Config.ConfigurationSource

• public interface IConfigurationSource
• public interface IProvideConfiguration<T>

NServiceBus.ConsistencyGuarantees

• public static class TransactionModeSettingsExtensions
  • public static TransportTransactionMode GetRequiredTransactionModeForReceives(this ReadOnlySettings settings)
  • public static TransportTransactionMode GetRequiredTransactionModeForReceives(this IReadOnlySettings settings)

NServiceBus.Container

• public class ContainerCustomizations
  • public SettingsHolder Settings { get; }
• public abstract class ContainerDefinition
  • public abstract IContainer CreateContainer(ReadOnlySettings settings)

NServiceBus.DataBus

• public class DataBusExtensions : ExposeSettings
  • public DataBusExtensions AddDeserializer<TSerializer>() where TSerializer : IDataBusSerializer
  • public DataBusExtensions AddDeserializer<TSerializer>(TSerializer serializer) where TSerializer : IDataBusSerializer
• public interface IDataBus
  • Task<Stream> Get(string key)
  • Task<string> Put(Stream stream, TimeSpan timeToBeReceived)
  • Task 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 abstract class DelayedDeliveryConstraint : DeliveryConstraint
• public class DoNotDeliverBefore
  • public DateTime At { get; }
  • public DoNotDeliverBefore(DateTime at)
  • public DateTimeOffset At { get; }
  • public DoNotDeliverBefore(DateTimeOffset at)

NServiceBus.DeliveryConstraints

• public static class DeliveryConstraintContextExtensions
  • public static void RemoveDeliveryConstaint(this ContextBag context, DeliveryConstraint constraint)

NServiceBus.Extensibility

• public static class ExtendableOptionsExtensions
  • public static DispatchProperties GetDispatchProperties(this ExtendableOptions options)
  • public static ReadOnlyContextBag GetOperationProperties(this IOutgoingContext behaviorContext)
  • public static ReadOnlyContextBag GetOperationProperties(this IUnsubscribeContext behaviorContext)
  • public static ReadOnlyContextBag GetOperationProperties(this ISubscribeContext behaviorContext)
  • public static ReadOnlyContextBag GetOperationProperties(this IRoutingContext behaviorContext)
  • 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 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
  • T Get<T>()
  • T Get<T>(string key)
  • bool TryGet<T>(out T result)
  • bool TryGet<T>(string key, out T result)

NServiceBus.Faults

• public class DelayedRetryMessage
  • public byte[] Body { get; }
  • public ReadOnlyMemory<byte> Body { get; }
  • public DelayedRetryMessage(string messageId, Dictionary<string, string> headers, byte[] body, Exception exception, int retryAttempt)
  • public DelayedRetryMessage(Dictionary<string, string> headers, byte[] body, Exception exception, int retryAttempt)
  • public DelayedRetryMessage(string messageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body, Exception exception, int retryAttempt)
• public class FailedMessage
  • public byte[] Body { get; }
  • public ReadOnlyMemory<byte> Body { get; }
  • public FailedMessage(string messageId, Dictionary<string, string> headers, byte[] body, Exception exception, string errorQueue)
  • public FailedMessage(string messageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body, Exception exception, string errorQueue)
• public class ImmediateRetryMessage
  • public byte[] Body { get; }
  • public ReadOnlyMemory<byte> Body { get; }
  • public ImmediateRetryMessage(string messageId, Dictionary<string, string> headers, byte[] body, Exception exception, int retryAttempt)
  • public ImmediateRetryMessage(string messageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body, Exception exception, int retryAttempt)

NServiceBus.Features

• public class CriticalTimeMonitoring
• public class FeatureConfigurationContext
  • public IConfigureComponents Container { get; }
  • public IServiceCollection Container { get; }
  • public ReadOnlySettings Settings { get; }
  • public void AddSatelliteReceiver(string name, string transportAddress, PushRuntimeSettings runtimeSettings, Func<RecoverabilityConfig, ErrorContext, RecoverabilityAction> recoverabilityPolicy, Func<IBuilder, MessageContext, Task> onMessage)
  • public void AddSatelliteReceiver(string name, string transportAddress, TransportTransactionMode requiredTransportTransactionMode, PushRuntimeSettings runtimeSettings, Func<RecoverabilityConfig, ErrorContext, RecoverabilityAction> recoverabilityPolicy, Func<IBuilder, MessageContext, Task> onMessage)
  • 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>(Func<IBuilder, TTask> startupTaskFactory) where TTask : FeatureStartupTask
  • public void RegisterStartupTask<TTask>(Func<IServiceProvider, TTask> startupTaskFactory) where TTask : FeatureStartupTask
• public abstract class FeatureStartupTask
  • protected abstract Task OnStart(IMessageSession session)
  • protected abstract Task OnStop(IMessageSession session)
  • protected abstract Task OnStart(IMessageSession session, CancellationToken cancellationToken = default)
  • protected abstract Task OnStop(IMessageSession session, CancellationToken cancellationToken = default)
• public class InMemoryOutboxPersistence : Feature
• public class InMemorySagaPersistence : Feature
• public class InMemorySubscriptionPersistence : Feature
• public class InMemoryTimeoutPersistence : Feature
• public class ReceiveStatisticsPerformanceCounters
• public class Scheduler
  • public Scheduler()
• public static class SettingsExtensions
  • public static bool IsFeatureActive(this ReadOnlySettings settings, Type featureType)
  • public static bool IsFeatureEnabled(this ReadOnlySettings settings, Type featureType)
  • public static bool IsFeatureActive(this IReadOnlySettings settings, Type featureType)
  • public static bool IsFeatureEnabled(this IReadOnlySettings settings, Type featureType)
• public class SLAMonitoring

NServiceBus.InMemory.Outbox

• public static class InMemoryOutboxSettingsExtensions

NServiceBus.Installation

• public interface INeedToInstallSomething
  • Task Install(string identity)
  • Task Install(string identity, CancellationToken cancellationToken = default)

NServiceBus.MessageMutator

• public class MutateIncomingMessageContext : ICancellableContext
  • public CancellationToken CancellationToken { get; }
  • public MutateIncomingMessageContext(object message, Dictionary<string, string> headers)
  • public MutateIncomingMessageContext(object message, Dictionary<string, string> headers, CancellationToken cancellationToken = default)
• public class MutateIncomingTransportMessageContext : ICancellableContext
  • public byte[] Body { get; set; }
  • public ReadOnlyMemory<byte> Body { get; set; }
  • public CancellationToken CancellationToken { get; }
  • public MutateIncomingTransportMessageContext(byte[] body, Dictionary<string, string> headers)
  • public MutateIncomingTransportMessageContext(ReadOnlyMemory<byte> body, Dictionary<string, string> headers, CancellationToken cancellationToken = default)
• public class MutateOutgoingMessageContext : ICancellableContext
  • public CancellationToken CancellationToken { get; }
  • public MutateOutgoingMessageContext(object outgoingMessage, Dictionary<string, string> outgoingHeaders, object incomingMessage, IReadOnlyDictionary<string, string> incomingHeaders)
  • public MutateOutgoingMessageContext(object outgoingMessage, Dictionary<string, string> outgoingHeaders, object incomingMessage, IReadOnlyDictionary<string, string> incomingHeaders, CancellationToken cancellationToken = default)
• public class MutateOutgoingTransportMessageContext : ICancellableContext
  • public byte[] OutgoingBody { get; set; }
  • public CancellationToken CancellationToken { get; }
  • public ReadOnlyMemory<byte> OutgoingBody { get; set; }
  • public MutateOutgoingTransportMessageContext(byte[] outgoingBody, object outgoingMessage, Dictionary<string, string> outgoingHeaders, object incomingMessage, IReadOnlyDictionary<string, string> incomingHeaders)
  • public MutateOutgoingTransportMessageContext(ReadOnlyMemory<byte> outgoingBody, object outgoingMessage, Dictionary<string, string> outgoingHeaders, object incomingMessage, IReadOnlyDictionary<string, string> incomingHeaders, CancellationToken cancellationToken = default)

NServiceBus.ObjectBuilder

• public interface IConfigureComponents
  • void ConfigureComponent<T>(Func<IBuilder, T> componentFactory, DependencyLifecycle dependencyLifecycle)
  • void ConfigureComponent<T>(Func<IServiceProvider, T> componentFactory, DependencyLifecycle dependencyLifecycle)
• 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)
  • bool HasComponent(Type componentType)
  • void RegisterSingleton(Type lookupType, object instance)
  • void Release(object instance)

NServiceBus.Outbox

• public interface IOutboxStorage
  • Task<OutboxTransaction> BeginTransaction(ContextBag context)
  • Task<OutboxMessage> Get(string messageId, ContextBag context)
  • Task SetAsDispatched(string messageId, ContextBag context)
  • Task Store(OutboxMessage message, OutboxTransaction transaction, ContextBag context)
  • 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 interface OutboxTransaction
  • Task Commit()
• 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.Persistence

• public interface CompletableSynchronizedStorageSession
  • Task CompleteAsync()
• public sealed class CompletableSynchronizedStorageSessionAdapter : IDisposable
• public static class CompletableSynchronizedStorageSessionAdapterExtensions
• 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<CompletableSynchronizedStorageSession> OpenSession(ContextBag contextBag)
  • Task<ICompletableSynchronizedStorageSession> OpenSession(ContextBag contextBag, CancellationToken cancellationToken = default)
• public interface ISynchronizedStorageAdapter
  • Task<CompletableSynchronizedStorageSession> TryAdapt(OutboxTransaction transaction, ContextBag context)
  • Task<CompletableSynchronizedStorageSession> TryAdapt(TransportTransaction transportTransaction, ContextBag context)
  • Task<ICompletableSynchronizedStorageSession> TryAdapt(IOutboxTransaction transaction, ContextBag context, CancellationToken cancellationToken = default)
  • Task<ICompletableSynchronizedStorageSession> TryAdapt(TransportTransaction transportTransaction, ContextBag context, CancellationToken cancellationToken = default)
• public interface ISynchronizedStorageSession

NServiceBus.Pipeline

• 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; }
  • Dictionary<string, string> AuditMetadata { get; }
  • TimeSpan? TimeToBeReceived { get; }
  • IAuditActionContext PreventChanges()
• public interface IBehaviorContext : ICancellableContext, IExtendable
  • IBuilder Builder { get; }
  • IServiceProvider Builder { get; }
• public interface IForwardingContext : IBehaviorContext, ICancellableContext, IExtendable
  • string Address { get; }
  • OutgoingMessage Message { get; }
• public interface IIncomingPhysicalMessageContext : IIncomingContext, IBehaviorContext, ICancellableContext, IExtendable, IMessageProcessingContext, IPipelineContext
  • void UpdateMessage(byte[] body)
  • void UpdateMessage(ReadOnlyMemory<byte> body)
• public interface IInvokeHandlerContext : IIncomingContext, IBehaviorContext, ICancellableContext, IExtendable, IMessageProcessingContext, IPipelineContext, IMessageHandlerContext
  • bool HandleCurrentMessageLaterWasCalled { get; }
• public interface IOutgoingPhysicalMessageContext : IOutgoingContext, IBehaviorContext, ICancellableContext, IExtendable, IPipelineContext
  • byte[] Body { get; }
  • ReadOnlyMemory<byte> Body { get; }
  • void UpdateMessage(byte[] body)
  • void UpdateMessage(ReadOnlyMemory<byte> body)
• 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 ISubscribeContext : IBehaviorContext, ICancellableContext, IExtendable
  • Type[] EventTypes { get; }
• public class PipelineSettings : ExposeSettings
  • public void Register<T>(Func<IBuilder, T> factoryMethod, string description) where T : IBehavior
  • public void Register<T>(string stepId, Func<IBuilder, T> factoryMethod, string description) where T : IBehavior
  • 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 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 Replace<T>(string stepId, Func<IBuilder, T> factoryMethod, 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 RegisterStep
  • protected RegisterStep(string stepId, Type behavior, string description, Func<IBuilder, IBehavior> factoryMethod = null)
  • protected RegisterStep(string stepId, Type behavior, string description, Func<IServiceProvider, IBehavior> factoryMethod = null)

NServiceBus.Recoverability

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

NServiceBus.Routing

• public class DistributionContext : IExtendable
  • public DistributionContext(string[] receiverAddresses, OutgoingLogicalMessage message, string messageId, Dictionary<string, string> headers, Func<EndpointInstance, string> addressTranslation, ContextBag extensions)
  • public DistributionContext(string[] receiverAddresses, OutgoingLogicalMessage message, string messageId, Dictionary<string, string> headers, ITransportAddressResolver addressTranslation, ContextBag extensions)

NServiceBus.Routing.Legacy

• public static class ConfigureMSMQDistributor

NServiceBus.Sagas

• public class ActiveSagaInstance
  • public DateTime Created { get; }
  • public DateTimeOffset Created { get; }
  • public DateTime Modified { get; }
  • public DateTimeOffset Modified { get; }
  • public ActiveSagaInstance(Saga saga, SagaMetadata metadata, Func<DateTime> currentUtcDateTimeProvider)
  • public ActiveSagaInstance(Saga saga, SagaMetadata metadata, Func<DateTimeOffset> currentDateTimeOffsetProvider)
• public abstract class IFindSagas<T>
  • public interface Using<T, M> : IFinder where T : IContainSagaData
• public interface ISagaFinder<TSagaData, TMessage> : IFinder where TSagaData : IContainSagaData
  • Task<TSagaData> FindBy(TMessage message, ISynchronizedStorageSession storageSession, IReadOnlyContextBag context, CancellationToken cancellationToken = default)
• public interface ISagaPersister
  • Task Complete(IContainSagaData sagaData, SynchronizedStorageSession session, ContextBag context)
  • Task<TSagaData> Get<TSagaData>(Guid sagaId, SynchronizedStorageSession session, ContextBag context) where TSagaData : IContainSagaData
  • Task<TSagaData> Get<TSagaData>(string propertyName, object propertyValue, SynchronizedStorageSession session, ContextBag context) where TSagaData : IContainSagaData
  • Task Save(IContainSagaData sagaData, SagaCorrelationProperty correlationProperty, SynchronizedStorageSession session, ContextBag context)
  • Task Update(IContainSagaData sagaData, SynchronizedStorageSession session, ContextBag context)
  • 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 SagaSettings : ExposeSettings
  • public void DisableBestPracticeValidation()

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(ReadOnlySettings settings)
  • public abstract Func<IMessageMapper, IMessageSerializer> Configure(IReadOnlySettings settings)

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
  • 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 class SettingsHolder : IReadOnlySettings
  • public void Set(string key, object value)
  • public void Set(string key, object value)

NServiceBus.Transport

• 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 ReadOnlyContextBag Extensions { get; }
  • public ContextBag Extensions { get; }
  • public string ReceiveAddress { get; }
  • public ErrorContext(Exception exception, Dictionary<string, string> headers, string transportMessageId, byte[] body, TransportTransaction transportTransaction, int immediateProcessingFailures)
  • public ErrorContext(Exception exception, Dictionary<string, string> headers, string transportMessageId, byte[] body, TransportTransaction transportTransaction, int immediateProcessingFailures, ReadOnlyContextBag context)
  • public ErrorContext(Exception exception, Dictionary<string, string> headers, string nativeMessageId, ReadOnlyMemory<byte> body, TransportTransaction transportTransaction, int immediateProcessingFailures, string receiveAddress, ContextBag context)
• 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 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 byte[] Body { get; }
  • public ReadOnlyMemory<byte> Body { get; }
  • public IncomingMessage(string nativeMessageId, Dictionary<string, string> headers, byte[] body)
  • public IncomingMessage(string nativeMessageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body)
• public static class IncomingMessageExtensions
  • public static MessageIntentEnum GetMessageIntent(this IncomingMessage message)
  • public static MessageIntentEnum GetMesssageIntent(this IncomingMessage message)
  • public static MessageIntent GetMessageIntent(this IncomingMessage message)
• public interface IOutgoingTransportOperation
  • List<DeliveryConstraint> DeliveryConstraints { get; }
  • DispatchProperties Properties { get; }
• 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 class MessageContext : IExtendable
  • public byte[] Body { get; }
  • public ReadOnlyMemory<byte> Body { get; }
  • public string NativeMessageId { get; }
  • public string ReceiveAddress { get; }
  • public MessageContext(string nativeMessageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body, TransportTransaction transportTransaction, string receiveAddress, ContextBag context)
• public class MulticastTransportOperation : IOutgoingTransportOperation
  • public List<DeliveryConstraint> DeliveryConstraints { get; }
  • public DispatchProperties Properties { get; }
  • public MulticastTransportOperation(OutgoingMessage message, Type messageType, DispatchConsistency requiredDispatchConsistency = 1, List<DeliveryConstraint> deliveryConstraints = null)
  • 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 OutgoingMessage
  • public byte[] Body { get; }
  • public ReadOnlyMemory<byte> Body { get; }
  • public OutgoingMessage(string messageId, Dictionary<string, string> headers, byte[] body)
  • public OutgoingMessage(string messageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body)
  • public void UpdateBody(ReadOnlyMemory<byte> updatedBody)
• public class PushSettings
  • public string ErrorQueue { get; }
  • public string InputQueue { get; }
  • public bool PurgeOnStartup { get; }
  • public TransportTransactionMode RequiredTransactionMode { get; }
  • public PushSettings(string inputQueue, string errorQueue, bool purgeOnStartup, TransportTransactionMode requiredTransactionMode)
  • 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 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 StartupCheckResult()
• public abstract class TransportDefinition
  • public abstract string ExampleConnectionStringForErrorMessage { get; }
  • public virtual bool RequiresConnectionString { get; }
  • protected TransportDefinition()
  • public abstract TransportInfrastructure Initialize(SettingsHolder settings, string connectionString)
  • 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 abstract IEnumerable<Type> DeliveryConstraints { get; }
  • public abstract OutboundRoutingPolicy OutboundRoutingPolicy { get; }
  • public bool RequireOutboxConsent { get; set; }
  • public abstract TransportTransactionMode TransactionMode { get; }
  • public IMessageDispatcher Dispatcher { get; protected set; }
  • public IReadOnlyDictionary<string, IMessageReceiver> Receivers { get; protected set; }
  • public abstract EndpointInstance BindToLocalEndpoint(EndpointInstance instance)
  • public abstract TransportReceiveInfrastructure ConfigureReceiveInfrastructure()
  • public abstract TransportSendInfrastructure ConfigureSendInfrastructure()
  • public abstract TransportSubscriptionInfrastructure ConfigureSubscriptionInfrastructure()
  • public virtual string MakeCanonicalForm(string transportAddress)
  • public virtual Task Start()
  • public virtual Task Stop()
  • public abstract string ToTransportAddress(LogicalAddress logicalAddress)
  • public abstract Task Shutdown(CancellationToken cancellationToken = default)
  • public abstract string ToTransportAddress(QueueAddress address)
• public class TransportOperation
  • public List<DeliveryConstraint> DeliveryConstraints { get; }
  • public DispatchProperties Properties { get; }
  • public TransportOperation(OutgoingMessage message, AddressTag addressTag, DispatchConsistency requiredDispatchConsistency = 1, List<DeliveryConstraint> deliveryConstraints = null)
  • public TransportOperation(OutgoingMessage message, AddressTag addressTag, DispatchProperties properties = null, DispatchConsistency requiredDispatchConsistency = 1)
• public class TransportReceiveInfrastructure
• public class TransportSendInfrastructure
  • public Func<IDispatchMessages> DispatcherFactory { get; }
  • public Func<IMessageDispatcher> DispatcherFactory { get; }
  • public TransportSendInfrastructure(Func<IDispatchMessages> dispatcherFactory, Func<Task<StartupCheckResult>> preStartupCheck)
  • public TransportSendInfrastructure(Func<IMessageDispatcher> dispatcherFactory, Func<Task<StartupCheckResult>> preStartupCheck)
• public class UnicastTransportOperation : IOutgoingTransportOperation
  • public List<DeliveryConstraint> DeliveryConstraints { get; }
  • public DispatchProperties Properties { get; }
  • public UnicastTransportOperation(OutgoingMessage message, string destination, DispatchConsistency requiredDispatchConsistency = 1, List<DeliveryConstraint> deliveryConstraints = null)
  • public UnicastTransportOperation(OutgoingMessage message, string destination, DispatchProperties properties, DispatchConsistency requiredDispatchConsistency = 1)

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)

NServiceBus.Unicast.Messages

• public class MessageMetadata
  • public string MessageHierarchySerialized { get; }
• public class MessageMetadataRegistry
  • public MessageMetadataRegistry(Func<Type, bool> isMessageType, bool allowDynamicTypeLoading)
  • public MessageMetadata[] GetAllMessages()

NServiceBus.Unicast.Subscriptions.MessageDrivenSubscriptions

• public interface ISubscriptionStorage
  • Task<IEnumerable<Subscriber>> GetSubscriberAddressesForMessage(IEnumerable<MessageType> messageTypes, ContextBag context)
  • Task Subscribe(Subscriber subscriber, MessageType messageType, ContextBag context)
  • Task Unsubscribe(Subscriber subscriber, MessageType messageType, ContextBag context)
  • 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)

NServiceBus.Unicast.Transport

• public static class ControlMessageFactory
  • public static OutgoingMessage Create(MessageIntentEnum intent)
  • public static OutgoingMessage Create(MessageIntent intent)