API Diff between 8.0.0 and 6.5.3
491 Additions
426 Removals
NServiceBus
-
public class Address
-
public class AllAssemblies
-
public class AssemblyScannerConfiguration
-
public static class AuditConfigReader
-
public static class AuditContextExtensions
-
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 class ConfigureFileShareDataBus
-
public static class ConfigureInMemoryFaultManagement
-
public static class ConfigurePurging
-
public static class ConfigureQueueCreation
-
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 class ConventionsBuilder : ExposeSettings
-
public static class CorrelationContextExtensions
-
public class ConversationId
-
public class ConversationIdStrategyContext
-
public static class ConversationRoutingExtensions
-
public class CorrelatedSagaPropertyMapper<TSagaData> where TSagaData : IContainSagaData
-
public class CriticalError
-
public class CriticalErrorContext : ICriticalErrorContext
-
public static class CriticalTimeMonitoringConfig
-
public class DataBusProperty<T> : IDataBusProperty, ISerializable
-
public static class DateTimeOffsetHelper
-
public class DelayedRetriesSettings : ExposeSettings
-
public static class DiagnosticSettingsExtensions
-
public class Discard : RecoverabilityAction
-
public static class DurableMessagesConfig
-
public class EncryptedValue
-
public static class Endpoint
-
public class EndpointConfiguration : ExposeSettings
-
public static class EndpointInstanceExtensions
-
public static class EndpointWithExternallyManagedContainer
-
public static class ErrorQueueSettings
-
public static class ExtensionMethods
-
public class FailedConfig
-
public class First<T>
-
public static class
- public const string = "NServiceBus.DataBusConfig.ContentType"
- public const string = "NServiceBus.DeliverAt"
- public const string = "baggage"
- public const string = "traceparent"
- public const string = "tracestate"
- public const string = "NServiceBus.FLRetries"
- public const string = "NServiceBus.PreviousConversationId"
- public const string = "NServiceBus.Retries"
- public const string = "NServiceBus.Retries.Timestamp"
- public const string = "NServiceBus.RijndaelKeyIdentifier"
- public const string = "WinIdName"
-
public class HostInfoSettings
-
public interface IAuthorizeSubscriptions
-
public interface IBus
-
public static class IBusExtensions
-
public interface ICallback
-
public interface ICancellableContext
-
public interface
-
public interface ICriticalErrorContext
-
public interface IDataBusProperty
-
public interface IEncryptionService
-
public interface IEndpointInstance : IMessageSession
-
public interface IExcludesBuilder
-
public interface IIncludesBuilder
-
public interface
-
public interface IMessageContext
-
public interface IMessageConvention
-
public interface IMessageHandlerContext : IMessageProcessingContext, IPipelineContext, ICancellableContext, IExtendable
-
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 class ImmediateRetriesSettings : ExposeSettings
-
public static class InMemoryGatewayPersistenceConfigurationExtensions
-
public class InMemoryOutboxPersistence
-
public static class InMemoryOutboxSettingsExtensions
-
public class InMemoryPersistence : PersistenceDefinition
-
public class InMemorySagaPersistence
-
public class InMemorySubscriptionPersistence
-
public class InMemoryTimeoutPersistence
-
public static class InstallConfigExtensions
-
public class InstanceMappingFileSettings : ExposeSettings
-
public static class IPipelineContextExtensions
-
public interface ISendOnlyBus : IDisposable
-
public interface ISpecifyMessageHandlerOrdering
-
public interface IStartableBus : IBus
-
public interface IStartableEndpoint
-
public interface IStartableEndpointWithExternallyManagedContainer
-
public interface IToSagaExpression<TSagaData> where TSagaData : IContainSagaData
-
public interface IWantToRunWhenBusStartsAndStops
-
public class JsonSerializer : SerializationDefinition
-
public static class JsonSerializerConfigurationExtensions
-
public class LearningTransport : TransportDefinition
-
public static class LearningTransportConfigurationExtensions
-
public static class LoadMessageHandlersExtensions
-
public static class LoadMessageHandlersExtentions
-
public struct LogicalAddress
-
public static class MessageCausationConfigurationExtensions
-
public static class MessageDrivenSubscriptionsConfigExtensions
-
public enum MessageIntent
-
public enum MessageIntentEnum
-
public static class MessageProcessingContextExtensions
-
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 class Order
-
public sealed delegate OnSatelliteMessage : MulticastDelegate
-
public static class OpenTelemetryConfigurationExtensions
-
public class PersistenceExtensions : ExposeSettings
-
public class PersistenceExtensions<T> : PersistenceExtensions where T : PersistenceDefinition
-
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 class ReceiveAddresses
-
public static class ReceiveFeatureConfigurationContextExtensions
-
public class ReceivePipelineCompleted
-
public static class ReceivePipelineConfigExtensions
-
public abstract class RecoverabilityAction
-
public class RecoverabilitySettings : ExposeSettings
-
public class RetryFailedSettings : ExposeSettings
-
public static class RoutingSettingsExtensions
-
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 static class ScaleOutExtentions
-
public class Schedule
-
public static class SagasConfigExtensions
-
public class ScheduledTask
-
public static class ScheduleExtensions
-
public static class SecondLevelRetriesConfigExtensions
-
public class SecondLevelRetriesSettings
-
public static class SerializationConfigExtensions
-
public class SerializationExtentions<T>
-
public static class SerializationExtensionsExtensions
-
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 class SettingsExtentions
-
public static class SLAMonitoringConfig
-
public class StartupDiagnosticEntries
-
public abstract class StorageType
-
public class SubscriptionMigrationModeSettings : ExposeSettings
-
public class SystemJsonDataBusSerializer : IDataBusSerializer
-
public class TimeoutManagerConfiguration
-
public class TransportExtensions<T> where T : TransportDefinition
-
public class TransportMessage
-
public static class UseDataBusExtensions
-
public static class UseTransportExtensions
-
public class WireEncryptedString : ISerializable
-
public static class XmlSerializationExtensions
NServiceBus.Audit
NServiceBus.AutomaticSubscriptions.Config
NServiceBus.Config
NServiceBus.Config.ConfigurationSource
NServiceBus.Configuration.AdvanceExtensibility
NServiceBus.Configuration.AdvancedExtensibility
NServiceBus.ConsistencyGuarantees
NServiceBus.Container
NServiceBus.DataBus
NServiceBus.DelayedDelivery
NServiceBus.DeliveryConstraints
NServiceBus.Extensibility
NServiceBus.Faults
-
public class DelayedRetryMessage
-
public class ErrorsNotifications
-
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
-
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
-
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 class SecondLevelRetries : Feature
-
public static class SerializationFeatureHelper
-
public static class SettingsExtensions
-
public class SLAMonitoring : Feature
-
public class StorageDrivenPublishing
-
public class SynchronizedStorage : Feature
-
public class TimeoutManagerBasedDeferral
NServiceBus.Hosting.Helpers
NServiceBus.InMemory.Outbox
NServiceBus.Installation
NServiceBus.MessageMutator
-
public interface IMessageMutator
-
public interface IMutateTransportMessages : IMutateIncomingTransportMessages, IMutateOutgoingTransportMessages
-
public class MutateIncomingMessageContext : ICancellableContext
-
public class MutateIncomingTransportMessageContext : ICancellableContext
-
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
NServiceBus.ObjectBuilder.Common
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
-
public class OutboxSettings : ExposeSettings
-
public interface OutboxTransaction
-
public class TransportOperation
- public byte[] Body { get; }
- public ReadOnlyMemory<byte> Body { get; }
- public Dictionary<string, string> Options { get; }
- public TransportOperation(string messageId, Dictionary<string, string> options, byte[] body, Dictionary<string, string> headers)
- public DispatchProperties Options { get; }
- public TransportOperation(string messageId, DispatchProperties properties, ReadOnlyMemory<byte> body, Dictionary<string, string> headers)
NServiceBus.Persistence
NServiceBus.Persistence.Legacy
NServiceBus.Pipeline
-
public interface IAuditActionContext : IBehaviorContext, ICancellableContext, IExtendable
-
public interface IAuditContext : IBehaviorContext, ICancellableContext, IExtendable
-
public interface IBehavior<TContext>
-
public interface IBehaviorContext : ICancellableContext, IExtendable
-
public interface IForwardingContext : IBehaviorContext, ICancellableContext, IExtendable
-
public interface IIncomingPhysicalMessageContext : IIncomingContext, IBehaviorContext, ICancellableContext, IExtendable, IMessageProcessingContext, IPipelineContext
-
public interface IInvokeHandlerContext : IIncomingContext, IBehaviorContext, ICancellableContext, IExtendable, IMessageProcessingContext, IPipelineContext, IMessageHandlerContext
-
public interface IOutgoingPhysicalMessageContext : IOutgoingContext, IBehaviorContext, ICancellableContext, IExtendable, IPipelineContext
-
public interface IRecoverabilityActionContext : IBehaviorContext, ICancellableContext, IExtendable
-
public interface IRecoverabilityContext : IBehaviorContext, ICancellableContext, IExtendable
-
public interface ISubscribeContext : IBehaviorContext, ICancellableContext, IExtendable
-
public class LogicalMessage
-
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
-
public class WellKnownStep
NServiceBus.Pipeline.Contexts
NServiceBus.Recoverability
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
NServiceBus.Routing.Legacy
NServiceBus.Routing.StorageDrivenPublishing
NServiceBus.Sagas
-
public class ActiveSagaInstance
-
public abstract class IFindSagas<T>
-
public interface ISagaFinder<TSagaData, TMessage> : IFinder where TSagaData : IContainSagaData
-
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
NServiceBus.Satellites
NServiceBus.SecondLevelRetries.Config
NServiceBus.Serialization
NServiceBus.Serializers.Json
NServiceBus.Serializers.XML
NServiceBus.Settings
NServiceBus.Settings.NServiceBus
NServiceBus.Timeout.Core
NServiceBus.Transport
-
public class DispatchProperties : Dictionary<string, string>
-
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
-
public interface IMessageReceiver
-
public class IncomingMessage
-
public static class IncomingMessageExtensions
-
public interface IOutgoingTransportOperation
-
public interface ISubscriptionManager
-
public interface ITransportAddressResolver
-
public class MessageContext : IExtendable
-
public class MulticastTransportOperation : IOutgoingTransportOperation
-
public sealed delegate OnError : MulticastDelegate
-
public sealed delegate OnMessage : MulticastDelegate
-
public class OutgoingMessage
-
public class PushSettings
-
public class QueueAddress
-
public class ReceiveSettings
-
public class StartupCheckResult
-
public abstract class TransportDefinition
-
public abstract class TransportInfrastructure
-
public class TransportOperation
-
public class TransportReceiveInfrastructure
-
public class TransportSendInfrastructure
-
public class UnicastTransportOperation : IOutgoingTransportOperation
NServiceBus.Transport.Msmq
NServiceBus.Transports
NServiceBus.Transports.Msmq
NServiceBus.Transports.Msmq.Config
NServiceBus.Unicast
NServiceBus.Unicast.Behaviors
NServiceBus.Unicast.Messages
NServiceBus.Unicast.Queuing
NServiceBus.Unicast.Routing
NServiceBus.Unicast.Subscriptions
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