NServiceBus by Particular Software

public class HostInformation
- public string DisplayName { get; }
- public Guid HostId { get; }
- public Dictionary<string, string> Properties { get; }
- public HostInformation(Guid hostId, string displayName)
- public HostInformation(Guid hostId, string displayName, Dictionary<string, string> properties)

NServiceBus.Hosting.Helpers

public class AssemblyScanner
- public bool ScanAppDomainAssemblies { get; set; }
- public bool ScanFileSystemAssemblies { get; set; }
- public bool ThrowExceptions { get; set; }
- public AssemblyScanner()
- public AssemblyScanner(string baseDirectoryToScan)
- public AssemblyScannerResults GetScannableAssemblies()
public class AssemblyScannerResults
- public List<Assembly> Assemblies { get; }
- public bool ErrorsThrownDuringScanning { get; }
- public List<SkippedFile> SkippedFiles { get; }
- public List<Type> Types { get; }
- public AssemblyScannerResults()
public class SkippedFile
- public string FilePath { get; }
- public string SkipReason { get; }

NServiceBus.HttpHeaders

public class Bootstrapper : INeedInitialization

NServiceBus.Impersonation

public class ImpersonationManager : INeedInitialization, IMutateOutgoingTransportMessages

NServiceBus.Installation

public interface IEnvironment
public interface INeedToInstallInfrastructure : INeedToInstallSomething
public interface INeedToInstallInfrastructure<T> : INeedToInstallInfrastructure, INeedToInstallSomething where T : IEnvironment
public interface INeedToInstallSomething
- void Install(WindowsIdentity identity)
- Task Install(string identity, CancellationToken cancellationToken = default)
public interface INeedToInstallSomething<T> : INeedToInstallSomething where T : IEnvironment

NServiceBus.Installation.Environments

public class Windows : IEnvironment

NServiceBus.Licensing

public class Bootstrapper : INeedInitialization, IWantToRunWhenConfigurationIsComplete
public class LicenseAttributeKeys
public class LicenseDescriptor
public class LicenseManager
public class LicenseValidator : AbstractLicenseValidator
public class SystemInfo

NServiceBus.Licensing.Extensions

public static class StringExtensions

NServiceBus.Logging

public class DefaultFactory : LoggingFactoryDefinition
- public DefaultFactory()
- public void Directory(string directory)
- public void Level(LogLevel level)
public interface ILog
- bool IsDebugEnabled { get; }
- bool IsErrorEnabled { get; }
- bool IsFatalEnabled { get; }
- bool IsInfoEnabled { get; }
- bool IsWarnEnabled { get; }
- void Debug(string message)
- void Debug(string message, Exception exception)
- void DebugFormat(string format, object[] args)
- void Error(string message)
- void Error(string message, Exception exception)
- void ErrorFormat(string format, object[] args)
- void Fatal(string message)
- void Fatal(string message, Exception exception)
- void FatalFormat(string format, object[] args)
- void Info(string message)
- void Info(string message, Exception exception)
- void InfoFormat(string format, object[] args)
- void Warn(string message)
- void Warn(string message, Exception exception)
- void WarnFormat(string format, object[] args)
public interface ILoggerFactory
- ILog GetLogger(Type type)
- ILog GetLogger(string name)
public abstract class LoggingFactoryDefinition
- protected LoggingFactoryDefinition()
public enum LogLevel
- Debug = 0
- Error = 3
- Fatal = 4
- Info = 1
- Warn = 2
public static class LogManager
- public static ILog GetLogger<T>()
- public static ILog GetLogger(Type type)
- public static ILog GetLogger(string name)
- public static T Use<T>() where T : LoggingFactoryDefinition
- public static void UseFactory(ILoggerFactory loggerFactory)

NServiceBus.MessageHeaders

public class MessageHeaderManager : IMutateOutgoingTransportMessages

NServiceBus.MessageInterfaces.MessageMapper.Reflection

public class MessageMapper : IMessageMapper, IMessageCreator
- public Type CreateTypeFrom(Type t, ModuleBuilder moduleBuilder)
- public string GetNewTypeName(Type t)
- public void InitType(Type t, ModuleBuilder moduleBuilder)

NServiceBus.MessageMutator

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

NServiceBus.ObjectBuilder

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

NServiceBus.ObjectBuilder.Common

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

NServiceBus.ObjectBuilder.Common.Config

public static class ConfigureCommon
public static class ConfigureContainer

NServiceBus.Outbox

public interface IOutboxStorage
- Task<IOutboxTransaction> BeginTransaction(ContextBag context, CancellationToken cancellationToken = default)
- Task<OutboxMessage> Get(string messageId, ContextBag context, CancellationToken cancellationToken = default)
- Task SetAsDispatched(string messageId, ContextBag context, CancellationToken cancellationToken = default)
- Task Store(OutboxMessage message, IOutboxTransaction transaction, ContextBag context, CancellationToken cancellationToken = default)
public interface IOutboxTransaction : IDisposable
- Task Commit(CancellationToken cancellationToken = default)
public class OutboxMessage
- public string MessageId { get; }
- public TransportOperation[] TransportOperations { get; }
- public OutboxMessage(string messageId, TransportOperation[] operations)
public class OutboxSettings : ExposeSettings
public interface OutboxTransaction
public class TransportOperation
- public ReadOnlyMemory<byte> Body { get; }
- public Dictionary<string, string> Headers { get; }
- public string MessageId { get; }
- public DispatchProperties Options { get; }
- public TransportOperation(string messageId, DispatchProperties properties, ReadOnlyMemory<byte> body, Dictionary<string, string> headers)

NServiceBus.Performance.TimeToBeReceived

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

NServiceBus.Persistence

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

NServiceBus.Persistence.Raven

public static class RavenPersistenceConstants

NServiceBus.Pipeline

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

NServiceBus.Recoverability

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

NServiceBus.Routing

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

NServiceBus.Routing.MessageDrivenSubscriptions

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

NServiceBus.SagaPersisters.InMemory

public class InMemorySagaPersister : ISagaPersister

NServiceBus.SagaPersisters.Raven

public class RavenSagaPersister : ISagaPersister

NServiceBus.Sagas

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

NServiceBus.Sagas.Impl

public class Configure
public class ConfigureHowToFindSagaWithMessageDispatcher : IConfigureHowToFindSagaWithMessage
public static class GuidCombGenerator
public static class MessageExtensions
public class ReplyingToNullOriginatorDispatcher : IHandleReplyingToNullOriginator
public class SagaIdEnricher : IMutateOutgoingMessages
public class SagaMessageHandler : IMessageHandler<object>

NServiceBus.Sagas.Impl.Finders

public class HeaderSagaIdFinder<T> : Using<T, object>, IFinder where T : ISagaEntity
public class NullSagaFinder<T> : Using<T, object>, IFinder where T : ISagaEntity
public class PropertySagaFinder<TSaga, TMessage> : Using<TSaga, TMessage>, IFinder where TSaga : ISagaEntity

NServiceBus.Serialization

public interface IMessageSerializer
- string ContentType { get; }
- object[] Deserialize(ReadOnlyMemory<byte> body, IList<Type> messageTypes = null)
- void Serialize(object message, Stream stream)
public abstract class SerializationDefinition
- protected SerializationDefinition()
- public abstract Func<IMessageMapper, IMessageSerializer> Configure(IReadOnlySettings settings)
public class SerializationExtensions<T> : ExposeSettings where T : SerializationDefinition
- public SerializationExtensions(SettingsHolder serializerSettings, SettingsHolder endpointConfigurationSettings)

NServiceBus.Serializers.Binary

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

NServiceBus.Serializers.Json

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

NServiceBus.Serializers.Json.Internal

public class MessageContractResolver : DefaultContractResolver
public class MessageSerializationBinder : SerializationBinder

NServiceBus.Serializers.XML

public class XmlMessageSerializer : IMessageSerializer

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
public class SettingsHolder : IReadOnlySettings
- public SettingsHolder()
- public void Clear()
- public T Get<T>(string key)
- public T Get<T>()
- public object Get(string key)
- public T GetOrCreate<T>()
- public T GetOrDefault<T>()
- public T GetOrDefault<T>(string key)
- public bool HasExplicitValue(string key)
- public bool HasExplicitValue<T>()
- public bool HasSetting(string key)
- public bool HasSetting<T>()
- public void Set<T>(object value)
- public void Set(string key, object value)
- public void Set<T>(T value)
- public void Set<T>(Action value)
- public void SetDefault<T>(object value)
- public void SetDefault<T>(T value)
- public void SetDefault<T>(Action value)
- public void SetDefault(string key, object value)
- public bool TryGet<T>(out T val)
- public bool TryGet<T>(string key, out T val)

NServiceBus.Support

public static class RuntimeEnvironment
- public static string MachineName { get; }
- public static Func<string> MachineNameAction { get; set; }

NServiceBus.Timeout.Core

public class DefaultTimeoutManager : IManageTimeouts
public interface IManageTimeouts
public interface IPersistTimeouts
- void Add(TimeoutData timeout)
- IEnumerable<TimeoutData> GetAll()
- void Remove(Guid sagaId)
- Task Add(TimeoutData timeout, ContextBag context)
- Task<TimeoutData> Peek(string timeoutId, ContextBag context)
- Task RemoveTimeoutBy(Guid sagaId, ContextBag context)
- Task<bool> TryRemove(string timeoutId, ContextBag context)
public interface IQueryTimeouts
- Task<TimeoutsChunk> GetNextChunk(DateTime startSlice)
public class TimeoutData
- public Address Destination { get; set; }
- public string Destination { get; }
- public Dictionary<string, string> Headers { get; }
- public string Id { get; }
- public string OwningTimeoutManager { get; }
public class TimeoutMessageConverter : IMutateOutgoingMessages, INeedInitialization
public class TimeoutRunner : IWantToRunWhenTheBusStarts
public class TimeoutTransportMessageHandler
public class TimeoutsChunk
- public struct Timeout
- public Timeout[] DueTimeouts { get; }
- public DateTime NextTimeToQuery { get; }
- public TimeoutsChunk(Timeout[] dueTimeouts, DateTime nextTimeToQuery)

NServiceBus.Timeout.Hosting.Windows

public class TimeoutMessageProcessor : IWantToRunWhenTheBusStarts, IDisposable

NServiceBus.Timeout.Hosting.Windows.Installer

public class TimeoutInstaller : INeedToInstallSomething<Windows>, INeedToInstallSomething

NServiceBus.Timeout.Hosting.Windows.Persistence

public class InMemoryTimeoutPersistence : IPersistTimeouts
public class RavenTimeoutPersistence : IPersistTimeouts

NServiceBus.Transport

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

NServiceBus.Unicast

public static class BuilderExtensions
- public static void ForEach<T>(this IBuilder builder, Action<T> action)
- public static void ForEach<T>(this IServiceProvider builder, Action<T> action)
public class BusAsyncResult : IAsyncResult
public class BusAsyncResultEventArgs : EventArgs
public class Callback : ICallback
public interface IUnicastBus : IBus, IMessageCreator
public interface IWantToRunWhenTheBusStarts
public class MessageContext : IMessageContext
public class MessageHandlerRegistry
- public MessageHandlerRegistry()
- public void Clear()
- public List<MessageHandler> GetHandlersFor(Type messageType)
- public IEnumerable<Type> GetMessageTypes()
- public void RegisterHandler(Type handlerType)
public class SubscriptionEventArgs : EventArgs
public class SubscriptionsManager
public class UnicastBus : IUnicastBus, IBus, IMessageCreator, IStartableBus, IDisposable

NServiceBus.Unicast.Config

public class ConfigUnicastBus : Configure

NServiceBus.Unicast.Distributor

public class Distributor
public interface IWorkerAvailabilityManager

NServiceBus.Unicast.Messages

public class MessageMetadata
- public Type[] MessageHierarchy { get; }
- public string MessageHierarchySerialized { get; }
- public Type MessageType { get; }
- public MessageMetadata(Type messageType)
- public MessageMetadata(Type messageType, Type[] messageHierarchy)
public class MessageMetadataRegistry
- public MessageMetadataRegistry(Func<Type, bool> isMessageType, bool allowDynamicTypeLoading)
- public MessageMetadata[] GetAllMessages()
- public MessageMetadata GetMessageMetadata(Type messageType)
- public MessageMetadata GetMessageMetadata(string messageTypeIdentifier)

NServiceBus.Unicast.Queuing

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

NServiceBus.Unicast.Queuing.Ftp

public class FtpMessageQueue : ISendMessages, IReceiveMessages

NServiceBus.Unicast.Queuing.Msmq

public class HeaderInfo
public class MsmqMessageReceiver : IReceiveMessages
public class MsmqMessageSender : ISendMessages

NServiceBus.Unicast.Subscriptions

public interface ISubscriptionStorage

NServiceBus.Unicast.Subscriptions.InMemory

public class InMemorySubscriptionStorage : ISubscriptionStorage

NServiceBus.Unicast.Subscriptions.MessageDrivenSubscriptions

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

NServiceBus.Unicast.Subscriptions.Msmq

public class Entry
public class MsmqSubscriptionStorage : ISubscriptionStorage

NServiceBus.Unicast.Subscriptions.Msmq.Config

public class Installer : INeedToInstallSomething<Windows>, INeedToInstallSomething

NServiceBus.Unicast.Subscriptions.Raven

public class LambdaComparer<T> : IEqualityComparer<T>
public class MessageTypeConverter : JsonConverter
public class RavenSubscriptionStorage : ISubscriptionStorage
public class Subscription

NServiceBus.Unicast.Transport

public class AbortHandlingCurrentMessageException : Exception
public static class ControlMessage
public class FailedMessageProcessingEventArgs : EventArgs
public interface ITransport : IDisposable
public enum MessageIntentEnum
public class StartedMessageProcessingEventArgs : EventArgs
public class TransportMessage
public static class TransportMessageExtensions
public class TransportMessageHandlingFailedException : Exception
public class TransportMessageReceivedEventArgs : EventArgs
public static class ControlMessageFactory
- public static OutgoingMessage Create(MessageIntent intent)

NServiceBus.Unicast.Transport.Transactional

public class TransactionalTransport : ITransport, IDisposable

NServiceBus.Unicast.Transport.Transactional.Config

public class Bootstrapper : INeedInitialization

NServiceBus.UnitOfWork

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

NServiceBus.Utils

public static class DtcUtil
public class HeaderInfo
public static class MsmqInstallation
public class MsmqUtilities
public class PerformanceCounterInstallation
public static class ProcessUtil
public class TransactionWrapper
public class WorkerThread

NServiceBus.Utils.Reflection

public static class DelegateFactory
public static class ExtensionMethods
public sealed delegate LateBoundField : MulticastDelegate
public sealed delegate LateBoundFieldSet : MulticastDelegate
public sealed delegate LateBoundMethod : MulticastDelegate
public sealed delegate LateBoundProperty : MulticastDelegate
public sealed delegate LateBoundPropertySet : MulticastDelegate
public class Reflect
public class Reflect<TTarget> : Reflect

API Diff between 8.0.0 and 3.0.0-beta4

NServiceBus

NServiceBus.Audit

NServiceBus.AutomaticSubscriptions.Config

NServiceBus.Config

NServiceBus.Config.ConfigurationSource

NServiceBus.Config.Conventions

NServiceBus.Configuration.AdvancedExtensibility

NServiceBus.ConsistencyGuarantees

NServiceBus.Container

NServiceBus.DataBus

NServiceBus.DataBus.Config

NServiceBus.DataBus.FileShare

NServiceBus.DelayedDelivery

NServiceBus.DeliveryConstraints

NServiceBus.Distributor

NServiceBus.Distributor.Config

NServiceBus.Distributor.Installers

NServiceBus.Distributor.MsmqWorkerAvailabilityManager

NServiceBus.Distributor.ReadyMessages

NServiceBus.Encryption

NServiceBus.Encryption.Rijndael

NServiceBus.Extensibility

NServiceBus.Faults

NServiceBus.Faults.Forwarder

NServiceBus.Faults.InMemory

NServiceBus.Features

NServiceBus.Gateway.Channels

NServiceBus.Gateway.Channels.Http

NServiceBus.Gateway.Config

NServiceBus.Gateway.Deduplication

NServiceBus.Gateway.HeaderManagement

NServiceBus.Gateway.Installation

NServiceBus.Gateway.Notifications

NServiceBus.Gateway.Persistence

NServiceBus.Gateway.Persistence.Raven

NServiceBus.Gateway.Persistence.Sql

NServiceBus.Gateway.Receiving

NServiceBus.Gateway.Routing

NServiceBus.Gateway.Routing.Endpoints

NServiceBus.Gateway.Routing.Sites

NServiceBus.Gateway.Sending

NServiceBus.Gateway.Utils

NServiceBus.Hosting

NServiceBus.Hosting.Helpers

NServiceBus.HttpHeaders

NServiceBus.Impersonation

NServiceBus.Installation

NServiceBus.Installation.Environments

NServiceBus.Licensing

NServiceBus.Licensing.Extensions

NServiceBus.Logging

NServiceBus.MessageHeaders

NServiceBus.MessageInterfaces.MessageMapper.Reflection

NServiceBus.MessageMutator

NServiceBus.ObjectBuilder

NServiceBus.ObjectBuilder.Common

NServiceBus.ObjectBuilder.Common.Config

NServiceBus.Outbox

NServiceBus.Performance.TimeToBeReceived

NServiceBus.Persistence

NServiceBus.Persistence.Raven

NServiceBus.Pipeline

NServiceBus.Recoverability

NServiceBus.Routing

NServiceBus.Routing.MessageDrivenSubscriptions

NServiceBus.SagaPersisters.InMemory

NServiceBus.SagaPersisters.Raven

NServiceBus.Sagas

NServiceBus.Sagas.Impl

NServiceBus.Sagas.Impl.Finders

NServiceBus.Serialization

NServiceBus.Serializers.Binary

NServiceBus.Serializers.Json

NServiceBus.Serializers.Json.Internal

NServiceBus.Serializers.XML

NServiceBus.Settings

NServiceBus.Support

NServiceBus.Timeout.Core

NServiceBus.Timeout.Hosting.Windows