NServiceBus by Particular Software

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

---

API Diff between 8.0.0 and 6.5.8

491 Additions 426 Removals

• public static class ConfigureHandlerSettings

NServiceBus

• public class Address
• public class AllAssemblies
• public class AssemblyScannerConfiguration
  • public string AdditionalAssemblyScanningPath { get; set; }
  • public bool ScanFileSystemAssemblies { get; set; }
• public static class AuditConfigReader
  • 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 Bus
• public class BusAsyncResultEventArgs
• public class BusConfiguration
• public class BusNotifications
• public class CompletionResult
• public class Configure
• public static class ConfigureCriticalErrorAction
  • public static void DefineCriticalErrorAction(this EndpointConfiguration endpointConfiguration, Func<ICriticalErrorContext, CancellationToken, Task> onCriticalError)
  • public static void DefineCriticalErrorAction(this EndpointConfiguration endpointConfiguration, Action<string, Exception> onCriticalError)
• public static class ConfigureFileShareDataBus
  • public static DataBusExtentions<FileShareDataBus> BasePath(this DataBusExtentions<FileShareDataBus> config, string basePath)
• public static class ConfigureInMemoryFaultManagement
• public static class ConfigurePurging
  • public static bool PurgeOnStartup(this Configure config)
• public static class ConfigureQueueCreation
  • public static bool CreateQueues(this Configure config)
• public static class ConfigureRijndaelEncryptionService
• public static class ConfigureTransportConnectionString
• 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 static bool IsExpressMessageType(Type t)
  • public TimeSpan GetTimeToBeReceived(Type messageType)
  • public bool IsEncryptedProperty(PropertyInfo property)
• public class ConventionsBuilder : ExposeSettings
  • public ConventionsBuilder Add(IMessageConvention messageConvention)
  • public ConventionsBuilder DefiningEncryptedPropertiesAs(Func<PropertyInfo, bool> definesEncryptedProperty)
• public static class CorrelationContextExtensions
• 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(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 DataBusProperty()
• 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, Task> notificationCallback)
  • public DelayedRetriesSettings OnMessageBeingRetried(Func<DelayedRetryMessage, CancellationToken, Task> notificationCallback)
• 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 static class DurableMessagesConfig
  • public static bool DurableMessagesEnabled(this Configure config)
• 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 IDictionary<string, string> OutgoingHeaders { get; }
  • public void AssembliesToScan(IEnumerable<Assembly> assemblies)
  • public void AssembliesToScan(Assembly[] assemblies)
  • public void CustomConfigurationSource(IConfigurationSource configurationSource)
  • public void EndpointName(string name)
  • public void ExcludeAssemblies(string[] assemblies)
  • public void ExcludeTypes(Type[] types)
  • public void OverridePublicReturnAddress(Address address)
  • public void RegisterComponents(Action<IConfigureComponents> registration)
  • public void ScanAssembliesInDirectory(string probeDirectory)
  • public void ScanAssembliesInNestedDirectories()
  • public void RegisterComponents(Action<IServiceCollection> registration)
  • public void TypesToScan(IEnumerable<Type> typesToScan)
  • public RoutingSettings<TTransport> UseTransport<TTransport>(TTransport transportDefinition) where TTransport : TransportDefinition
• public static class EndpointInstanceExtensions
  • public static EndpointInstance AtMachine(this EndpointInstance instance, string machineName)
  • 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 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 static class ExtensionMethods
• public class FailedConfig
  • public FailedConfig(string errorQueue)
• public class First<T>
• public static class Headers
  • public const string DataBusConfigContentType = "NServiceBus.DataBusConfig.ContentType"
  • 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 PreviousConversationId = "NServiceBus.PreviousConversationId"
  • public const string Retries = "NServiceBus.Retries"
  • public const string RetriesTimestamp = "NServiceBus.Retries.Timestamp"
  • public const string RijndaelKeyIdentifier = "NServiceBus.RijndaelKeyIdentifier"
  • public const string WindowsIdentityName = "WinIdName"
• public class HostInfoSettings
  • public HostInfoSettings UsingHostName(string hostName)
• public interface IAuthorizeSubscriptions
• public interface IBus
• public static class IBusExtensions
• public interface ICallback
• public interface ICancellableContext
  • CancellationToken CancellationToken { get; }
• public interface IConfigureHowToFindSagaWithMessageHeaders
  • void ConfigureMapping<TSagaEntity, TMessage>(Expression<Func<TSagaEntity, object>> sagaEntityProperty, string headerName) where TSagaEntity : IContainSagaData
• 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 IExcludesBuilder
• public interface IIncludesBuilder
• public interface IManageMessageHeaders
• 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
  • 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, Task> notificationCallback)
  • public ImmediateRetriesSettings OnMessageBeingRetried(Func<ImmediateRetryMessage, CancellationToken, Task> notificationCallback)
• 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 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 class InstanceMappingFileSettings : ExposeSettings
• public static class IPipelineContextExtensions
• public interface ISendOnlyBus : IDisposable
• public interface ISpecifyMessageHandlerOrdering
• public interface IStartableBus : IBus
• public interface IStartableEndpoint
  • Task<IEndpointInstance> Start()
  • 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 IWantToRunWhenBusStartsAndStops
• 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 static class LoadMessageHandlersExtensions
  • public static void LoadMessageHandlers<TFirst>(this EndpointConfiguration config)
  • public static void LoadMessageHandlers<T>(this EndpointConfiguration config, First<T> order)
• public static class LoadMessageHandlersExtentions
• public struct LogicalAddress
  • public static bool op_Equality(LogicalAddress left, LogicalAddress right)
  • public static bool op_Inequality(LogicalAddress left, LogicalAddress right)
• public static class MessageCausationConfigurationExtensions
  • public static void CustomConversationIdStrategy(this EndpointConfiguration endpointConfiguration, Func<ConversationIdStrategyContext, ConversationId> customStrategy)
• 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 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 static class MsmqConfigurationExtensions
• public class MsmqTransport : TransportDefinition, IMessageDrivenSubscriptionTransport
• public class Notifications
  • public PipelineNotifications Pipeline { get; }
• 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 class PersistenceExtensions : ExposeSettings
  • public PersistenceExtensions For(Storage[] specificStorages)
• public class PersistenceExtensions<T> : PersistenceExtensions where T : PersistenceDefinition
  • public PersistenceExtensions<T> For(Storage[] specificStorages)
• public class PersistenceExtentions
• public class PersistenceExtentions<T>
• public class PersistenceExtentions<T, S>
• public class PipelineNotifications
• 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<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 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 static Discard Discard(string reason)
  • public abstract IReadOnlyCollection<IRoutingContext> GetRoutingContexts(IRecoverabilityActionContext context)
• public class RecoverabilitySettings : ExposeSettings
  • public RecoverabilitySettings DisableLegacyRetriesSatellite()
  • public RecoverabilitySettings OnConsecutiveFailures(int numberOfConsecutiveFailures, RateLimitSettings settings)
• public class RetryFailedSettings : ExposeSettings
  • public RetryFailedSettings OnMessageSentToErrorQueue(Func<FailedMessage, Task> notificationCallback)
  • 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
  • public IBus Bus { get; set; }
  • protected Task ReplyToOriginator(IMessageHandlerContext context, object message)
  • protected void ReplyToOriginator(object message)
  • protected virtual void ReplyToOriginator<TMessage>(Action<TMessage> messageConstructor)
  • 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)
  • protected void RequestTimeout<TTimeoutMessageType>(DateTime at)
  • protected void RequestTimeout<TTimeoutMessageType>(DateTime at, Action<TTimeoutMessageType> action)
  • protected void RequestTimeout<TTimeoutMessageType>(DateTime at, TTimeoutMessageType timeoutMessage)
  • protected void RequestTimeout<TTimeoutMessageType>(TimeSpan within)
  • protected void RequestTimeout<TTimeoutMessageType>(TimeSpan within, Action<TTimeoutMessageType> messageConstructor)
  • protected void RequestTimeout<TTimeoutMessageType>(TimeSpan within, TTimeoutMessageType timeoutMessage)
• public class SagaPropertyMapper<TSagaData> where TSagaData : IContainSagaData
  • public IToSagaExpression<TSagaData> ConfigureHeaderMapping<TMessage>(string headerName)
  • public CorrelatedSagaPropertyMapper<TSagaData> MapSaga(Expression<Func<TSagaData, object>> sagaProperty)
• public static class ScaleOutExtentions
• public class Schedule
• 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 ScheduleExtensions
  • public static void ScheduleEvery(this IMessageSession session, TimeSpan timeSpan, Action task)
  • public static void ScheduleEvery(this IMessageSession session, TimeSpan timeSpan, string name, Action task)
• public static class SecondLevelRetriesConfigExtensions
• public class SecondLevelRetriesSettings
• public static class SerializationConfigExtensions
  • public static void UseSerialization(this EndpointConfiguration config, Type serializerType)
• public class SerializationExtentions<T>
• 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 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 SettingsExtentions
• public static class SLAMonitoringConfig
• public class StartupDiagnosticEntries
  • public class StartupDiagnosticEntry
  • public StartupDiagnosticEntries()
  • public void Add(string sectionName, object section)
• 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 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 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 class TransportMessage
• 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 : ISerializable
• public static class XmlSerializationExtensions
  • public static SerializationExtentions<XmlSerializer> DontWrapRawXml(this SerializationExtentions<XmlSerializer> config)
  • public static SerializationExtentions<XmlSerializer> Namespace(this SerializationExtentions<XmlSerializer> config, string namespaceToUse)
  • public static SerializationExtentions<XmlSerializer> SanitizeInput(this SerializationExtentions<XmlSerializer> config)

NServiceBus.Audit

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

NServiceBus.AutomaticSubscriptions.Config

• public class AutoSubscribeSettings
  • public void AutoSubscribePlainMessages()
  • public void DoNotRequireExplicitRouting()

NServiceBus.Config

• public class AuditConfig : ConfigurationSection
• public interface IWantToRunWhenConfigurationIsComplete
• public enum KeyFormat
• public class Logging : ConfigurationSection
• public class MasterNodeConfig : ConfigurationSection
• public class MessageEndpointMapping : ConfigurationElement, IComparable<MessageEndpointMapping>
• public class MessageEndpointMappingCollection : ConfigurationElementCollection
• public class MessageForwardingInCaseOfFaultConfig : ConfigurationSection
• public class MsmqSubscriptionStorageConfig : ConfigurationSection
• public class RijndaelEncryptionServiceConfig : ConfigurationSection
• public class RijndaelExpiredKey : ConfigurationElement
• public class RijndaelExpiredKeyCollection : ConfigurationElementCollection
• public class SecondLevelRetriesConfig : ConfigurationSection
• public class TransportConfig : ConfigurationSection
• public class UnicastBusConfig : ConfigurationSection

NServiceBus.Config.ConfigurationSource

• public class DefaultConfigurationSource : IConfigurationSource
• public interface IConfigurationSource
• public interface IProvideConfiguration<T>

NServiceBus.Configuration.AdvanceExtensibility

• public static class AdvanceExtensibilityExtensions
• public abstract class ExposeSettings

NServiceBus.Configuration.AdvancedExtensibility

• public static class AdvancedExtensibilityExtensions
  • public static SettingsHolder GetSettings(this ExposeSettings config)
• public abstract class ExposeSettings
  • protected ExposeSettings(SettingsHolder settings)

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 class DataBusExtentions
• public class DataBusExtentions<T>
• 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)
  • public static void RemoveDeliveryConstraint(this ContextBag context, DeliveryConstraint constraint)

NServiceBus.Extensibility

• public class ContextBag : IReadOnlyContextBag
  • public T Get<T>(string key)
• public static class ExtendableOptionsExtensions
  • public static DispatchProperties GetDispatchProperties(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 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>()
  • 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 string MessageId { get; }
  • 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 ErrorsNotifications
  • public EventHandler MessageHasBeenSentToSecondLevelRetries
  • public EventHandler MessageHasFailedAFirstLevelRetryAttempt
• public class FailedMessage
  • public byte[] Body { get; }
  • public ReadOnlyMemory<byte> Body { get; }
  • public FailedMessage(string messageId, Dictionary<string, string> headers, byte[] body, Exception exception)
  • 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 struct FirstLevelRetry
• public interface IManageMessageFailures
• 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)
• public struct SecondLevelRetry

NServiceBus.Features

• public class ConfigureTransport
• public class CriticalTimeMonitoring : Feature
• public class Encryptor
• public abstract class Feature
  • protected void RegisterStartupTask<T>() where T : FeatureStartupTask
• public class FeatureConfigurationContext
  • public IConfigureComponents Container { get; }
  • public IServiceCollection Container { get; }
  • public ReadOnlySettings Settings { get; }
  • public void AddSatelliteReceiver(string name, string transportAddress, TransportTransactionMode requiredTransportTransactionMode, PushRuntimeSettings runtimeSettings, Func<RecoverabilityConfig, ErrorContext, RecoverabilityAction> recoverabilityPolicy, Func<IBuilder, MessageContext, Task> onMessage)
  • public void AddSatelliteReceiver(string name, string transportAddress, 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 FirstLevelRetries : Feature
• public class InMemoryOutboxPersistence : Feature
• public class InMemorySagaPersistence : Feature
• public class InMemorySubscriptionPersistence : Feature
• public class InMemoryTimeoutPersistence : Feature
• public class MsmqSubscriptionPersistence : Feature
• public class ReceiveStatisticsPerformanceCounters : Feature
• public class PlatformRetryNotifications : Feature
• public class Scheduler
  • public Scheduler()
• public class SecondLevelRetries : Feature
• public static class SerializationFeatureHelper
• 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 : Feature
• public class StorageDrivenPublishing
• public class SynchronizedStorage : Feature
• public class TimeoutManagerBasedDeferral

NServiceBus.Hosting.Helpers

• public class AssemblyScanner
  • public List<Assembly> MustReferenceAtLeastOneAssembly { get; }
  • public bool ScanFileSystemAssemblies { get; set; }

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 interface IMessageMutator
• public interface IMutateTransportMessages : IMutateIncomingTransportMessages, IMutateOutgoingTransportMessages
• 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 IComponentConfig
• public interface IComponentConfig<T>
• public static class IConfigureComponentObsoleteExtensions
• 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 class OutboxSettings : ExposeSettings
  • public void TimeToKeepDeduplicationData(TimeSpan time)
• 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 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
• public abstract class PersistenceDefinition
  • public bool HasSupportFor(Storage storage)
  • protected void Supports(Storage storage, Action<SettingsHolder> action)
• public enum Storage
• public abstract class StorageType

NServiceBus.Persistence.Legacy

• public class MsmqPersistence : PersistenceDefinition
• public static class MsmqSubscriptionStorageConfigurationExtensions

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 IBehavior<TContext>
• 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 LogicalMessage
  • public void UpdateMessageInstance(object newInstance)
• public class PipelineExecutor
• 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 Remove(WellKnownStep wellKnownStep)
  • public void Replace<T>(string stepId, Func<IBuilder, T> factoryMethod, string description = null) where T : IBehavior
  • public void Replace(WellKnownStep wellKnownStep, Type newBehavior, string description = null)
  • 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)
  • public void InsertAfter(WellKnownStep step)
  • public void InsertAfterIfExists(WellKnownStep step)
  • public void InsertBefore(WellKnownStep step)
  • public void InsertBeforeIfExists(WellKnownStep step)
  • public virtual bool IsEnabled(ReadOnlySettings settings)
• public class WellKnownStep

NServiceBus.Pipeline.Contexts

• public class OutgoingContext

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)
• public abstract class DistributionStrategy
  • public abstract string SelectReceiver(string[] receiverAddresses)

NServiceBus.Routing.Legacy

• public static class ConfigureMSMQDistributor

NServiceBus.Routing.StorageDrivenPublishing

• public class SubscribersForEvent

NServiceBus.Sagas

• public class ActiveSagaInstance
  • public DateTime Created { get; }
  • public DateTimeOffset Created { get; }
  • public DateTime Modified { get; }
  • public DateTimeOffset Modified { get; }
  • public Type SagaType { 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 sealed class UniqueAttribute : Attribute
• public class SagaSettings : ExposeSettings
  • public void DisableBestPracticeValidation()

NServiceBus.Satellites

• public interface IAdvancedSatellite
• public interface ISatellite

NServiceBus.SecondLevelRetries.Config

• public class SecondLevelRetriesSettings

NServiceBus.Serialization

• public abstract class ConfigureSerialization
• 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)
• public class SerializationExtensions<T> : ExposeSettings where T : SerializationDefinition
  • public SerializationExtensions(SettingsHolder settings)
  • public SerializationExtensions(SettingsHolder serializerSettings, SettingsHolder endpointConfigurationSettings)

NServiceBus.Serializers.Json

• public class JsonMessageSerializer

NServiceBus.Serializers.XML

• public class XmlMessageSerializer

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 static class ReadOnlySettingsExtensions
• public class ScaleOutSettings
• public class SettingsHolder : IReadOnlySettings
  • public void ApplyTo<T>(IComponentConfig config)
  • public void ApplyTo(Type componentType, IComponentConfig config)
  • 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.Settings.NServiceBus

• public static class TransactionSettingsExtentions

NServiceBus.Timeout.Core

• public class TimeoutData
  • public const string OriginalReplyToAddress = "NServiceBus.Timeout.ReplyToAddress"
  • public SendOptions ToSendOptions(Address replyToAddress)
  • public SendOptions ToSendOptions(string replyToAddress)
  • public TransportMessage ToTransportMessage()

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 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 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 messageId, Dictionary<string, string> headers, byte[] body)
  • public string NativeMessageId { get; }
  • public IncomingMessage(string nativeMessageId, Dictionary<string, string> headers, ReadOnlyMemory<byte> body)
• public static class IncomingMessageExtensions
  • 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 ContextBag Context { 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 bool HasNativePubSubSupport { get; protected set; }
  • public bool HasSupportForCentralizedPubSub { get; protected set; }
  • public bool? HasSupportForDistributedTransactions { get; protected set; }
  • public bool HasSupportForMultiQueueNativeTransactions { get; protected set; }
  • 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; protected 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 TransportSendInfrastructure(Func<IDispatchMessages> dispatcherFactory, Func<Task<StartupCheckResult>> preStartupCheck)
  • public Func<IMessageDispatcher> DispatcherFactory { get; }
  • public Func<Task<StartupCheckResult>> PreStartupCheck { get; }
  • 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.Transport.Msmq

• public class HeaderInfo

NServiceBus.Transports

• public interface IAuditMessages
• public interface IDeferMessages
• public interface IDequeueMessages
• public interface IPublishMessages
• public interface ISendMessages
• public abstract class TransportDefinition

NServiceBus.Transports.Msmq

• public class MsmqDequeueStrategy
• public class MsmqMessageSender
• public class MsmqUnitOfWork

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
• public class DeliveryMessageOptions
• public abstract class DeliveryOptions
• public interface IMessageHandlerRegistry
• public class MessageContext
• public class MessageHandlerRegistry
  • public void CacheMethodForHandler(Type handler, Type messageType)
  • public MessageHandlerRegistry()
  • public IEnumerable<Type> GetHandlerTypes(Type messageType)
  • public void InvokeHandle(object handler, object message)
  • public void InvokeTimeout(object handler, object state)
• public class PublishOptions : DeliveryOptions
• public class ReplyOptions
• public class SendOptions : DeliveryOptions
• public class UnicastBus

NServiceBus.Unicast.Behaviors

• public class MessageHandler

NServiceBus.Unicast.Messages

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

NServiceBus.Unicast.Queuing

• public interface IWantQueueCreated
• public class QueueNotFoundException : Exception
  • public QueueNotFoundException(Address queue, string message, Exception inner)

NServiceBus.Unicast.Routing

• public class StaticMessageRouter

NServiceBus.Unicast.Subscriptions

• public class SubscriptionEventArgs

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 ControlMessage
• public static class ControlMessageFactory
  • public static OutgoingMessage Create(MessageIntentEnum intent)
  • public static OutgoingMessage Create(MessageIntent intent)
• public class FailedMessageProcessingEventArgs : EventArgs
• public class FinishedMessageProcessingEventArgs : EventArgs
• public interface ITransport
• public class StartedMessageProcessingEventArgs
• public class TransactionSettings
• public class TransportMessageAvailableEventArgs
• public class TransportMessageReceivedEventArgs
• public class TransportReceiver