SlimMessageBus.Host by zarusz

<PackageReference Include="SlimMessageBus.Host" Version="1.15.0" />

---

API Diff between 1.15.0 and 2.0.0-rc6

106 Additions 173 Removals

SlimMessageBus.Host

• public class AssemblyQualifiedNameMessageTypeResolver : IMessageTypeResolver
  • public bool EmitAssemblyStrongName { get; set; }
• public class CheckpointTrigger : ICheckpointTrigger
  • public CheckpointTrigger(int countLimit, TimeSpan durationlimit, ILoggerFactory loggerFactory)
  • public CheckpointTrigger(HasProviderExtensions settings, ILoggerFactory loggerFactory)
  • public static ValueTuple<int, TimeSpan> GetConfiguration(HasProviderExtensions settings)
  • public static bool IsConfigured(HasProviderExtensions settings)
  • public CheckpointTrigger(int countLimit, TimeSpan durationlimit)
  • public CheckpointTrigger(HasProviderExtensions settings)
• public class CheckpointTriggerFactory : ICheckpointTriggerFactory
• public class ConcurrencyIncreasingMessageProcessorDecorator<TMessage> : IMessageProcessor<TMessage>, IDisposable
  • public IReadOnlyCollection<AbstractConsumerSettings> ConsumerSettings { get; }
  • public ConcurrencyIncreasingMessageProcessorDecorator(int concurrency, MessageBusBase messageBus, IMessageProcessor<TMessage> target)
  • public ValueTask DisposeAsync()
  • protected virtual ValueTask DisposeAsyncCore()
  • public TMessage GetMessageWithException()
  • public Task<ValueTuple<Exception, AbstractConsumerSettings, object>> ProcessMessage(TMessage message, IReadOnlyDictionary<string, object> messageHeaders, CancellationToken cancellationToken)
  • public Task WaitAll()
  • public ConcurrencyIncreasingMessageProcessorDecorator(AbstractConsumerSettings consumerSettings, MessageBusBase messageBus, IMessageProcessor<TMessage> target)
  • public void Dispose()
  • protected virtual void Dispose(bool disposing)
  • public Task<Exception> ProcessMessage(TMessage message)
• public class ConcurrencyLimittingMessageProcessorDecorator<TMessage> : IMessageProcessor<TMessage>, IDisposable
  • public ConcurrencyLimittingMessageProcessorDecorator(AbstractConsumerSettings consumerSettings, MessageBusBase messageBus, IMessageProcessor<TMessage> target)
  • public void Dispose()
  • protected virtual void Dispose(bool disposing)
  • public Task<Exception> ProcessMessage(TMessage message)
• public class ConsumerContext : IConsumerContext
  • public IMessageBus Bus { get; set; }
  • public CancellationToken CancellationToken { get; set; }
  • public object Consumer { get; set; }
  • public IMessageTypeConsumerInvokerSettings ConsumerInvoker { get; set; }
  • public string Path { get; set; }
  • public IDictionary<string, object> Properties { get; }
  • public IReadOnlyDictionary<string, object> Properties { get; }
  • public void SetProperty(string key, object value)
• public class ConsumerInstanceMessageProcessor<TMessage> : IMessageProcessor<TMessage>, IDisposable
  • protected IReadOnlyCollection<AbstractConsumerSettings> _consumerSettings
  • protected IReadOnlyCollection<IMessageTypeConsumerInvokerSettings> _invokers
  • protected IMessageTypeConsumerInvokerSettings _singleInvoker
  • public IReadOnlyCollection<AbstractConsumerSettings> ConsumerSettings { get; }
  • public ConsumerInstanceMessageProcessor(IEnumerable<AbstractConsumerSettings> consumerSettings, MessageBusBase messageBus, Func<Type, TTransportMessage, object> messageProvider, string path, Action<TTransportMessage, ConsumerContext> consumerContextInitializer = null, bool sendResponses = true, Func<TTransportMessage, Type> messageTypeProvider = null)
  • public ValueTask DisposeAsync()
  • protected virtual ValueTask DisposeAsyncCore()
  • protected Type GetMessageType(IReadOnlyDictionary<string, object> headers)
  • public virtual Task<ValueTuple<Exception, AbstractConsumerSettings, object>> ProcessMessage(TTransportMessage transportMessage, IReadOnlyDictionary<string, object> messageHeaders, CancellationToken cancellationToken)
  • protected IEnumerable<IMessageTypeConsumerInvokerSettings> TryMatchConsumerInvoker(Type messageType)
  • public ConsumerInstanceMessageProcessor(ConsumerSettings consumerSettings, MessageBusBase messageBus, Func<TMessage, MessageWithHeaders> messageProvider, Action<TMessage, ConsumerContext> consumerContextInitializer = null)
  • protected object DeserializeMessage(TMessage msg, out IDictionary headers, out string requestId, out Nullable expires)
  • public void Dispose()
  • protected virtual void Dispose(bool disposing)
  • public virtual Task<Exception> ProcessMessage(TMessage msg)
• public class CurrentMessageBusProvider : ICurrentMessageBusProvider
• public class ConsumerInstancePoolMessageProcessor<TMessage> : IMessageProcessor<TMessage>, IDisposable
  • public ConsumerInstancePoolMessageProcessor(ConsumerSettings consumerSettings, MessageBusBase messageBus, Func<TMessage, MessageWithHeaders> messageProvider, Action<TMessage, ConsumerContext> consumerContextInitializer = null)
  • public void Dispose()
  • protected virtual void Dispose(bool disposing)
  • public virtual Task<Exception> ProcessMessage(TMessage msg)
• public interface ICheckpointTriggerFactory
• public interface ICompositeMessageBus
• public interface IConsumerContextAware : IConsumerWithContext
• public interface IConsumerControl
• public interface ICurrentMessageBusProvider
• public interface ICurrentTimeProvider
• public interface IMasterMessageBus : IMessageBus, IRequestResponseBus, IPublishBus, IMessageBusProducer, IConsumerControl, ITopologyControl
• public interface IMessageBusProducer
• public interface IMessageHandler
• public interface IMessageHeadersFactory
• public interface IMessageProcessor<TMessage> : IDisposable
  • IReadOnlyCollection<AbstractConsumerSettings> ConsumerSettings { get; }
  • Task<ValueTuple<Exception, AbstractConsumerSettings, object>> ProcessMessage(TMessage transportMessage, IReadOnlyDictionary<string, object> messageHeaders, CancellationToken cancellationToken)
  • Task<Exception> ProcessMessage(TMessage message)
• public interface IMessageScopeFactory
• public class InMemoryPendingRequestStore : IPendingRequestStore
  • public void RemoveAll(IEnumerable<string> ids)
• public static class InterceptorExtensions
• public interface IPendingRequestStore
  • void RemoveAll(IEnumerable<string> ids)
• public interface ITopologyControl
• public abstract class MessageBusBase : IMessageBus, IDisposable, IRequestResponseBus, IPublishBus
  • protected Task BeforeStartTask { get; protected set; }
  • public bool IsStarted { get; }
  • protected bool IsStarting { get; }
  • protected bool IsStopping { get; }
  • public virtual string Name { get; }
  • protected ProducerByMessageTypeCache<ProducerSettings> ProducerSettingsByMessageType { get; }
  • public RuntimeTypeCache RuntimeTypeCache { get; }
  • protected IDictionary<Type, ProducerSettings> ProducerSettingsByMessageType { get; }
  • protected virtual void AssertProducers()
  • protected virtual void AssertSerializerSettings()
  • protected virtual void BuildPendingRequestStore()
  • public virtual MessageScopeWrapper CreateMessageScope(ConsumerSettings consumerSettings, object message)
  • public ValueTask DisposeAsync()
  • protected virtual ValueTask DisposeAsyncCore()
  • protected virtual string GetDefaultPath(Type messageType)
  • protected virtual IMessageSerializer GetSerializer()
  • public virtual Task<Exception> OnResponseArrived(byte[] responsePayload, string path, IReadOnlyDictionary<string, object> responseHeaders)
  • public virtual Task<Exception> OnResponseArrived(byte[] responsePayload, string path, string requestId, Exception responseException, object response = null)
  • protected virtual Task OnStart()
  • protected virtual Task OnStop()
  • public virtual Task<Exception> OnResponseArrived(byte[] responsePayload, string path, IDictionary<string, object> responseHeaders)
  • public virtual Task<Exception> OnResponseArrived(byte[] responsePayload, string path, string requestId, string errorMessage, object response = null)
  • public virtual Task ProduceResponse(object request, IReadOnlyDictionary<string, object> requestHeaders, object response, IDictionary<string, object> responseHeaders, ConsumerSettings consumerSettings)
  • public abstract Task ProduceToTransport(object message, string path, byte[] messagePayload, IDictionary<string, object> messageHeaders = null, CancellationToken cancellationToken = default)
  • public virtual Task ProvisionTopology()
  • public virtual Task Publish(object message, string path = null, IDictionary<string, object> headers = null, CancellationToken cancellationToken = default, IServiceProvider currentServiceProvider = null)
  • public virtual Task Publish<TMessage>(TMessage message, string path = null, IDictionary<string, object> headers = null, CancellationToken cancellationToken = default)
  • public virtual Task<TResponse> Send<TResponse>(IRequest<TResponse> request, string path = null, IDictionary<string, object> headers = null, TimeSpan? timeout = default, CancellationToken cancellationToken = default)
  • public Task Send(IRequest request, string path = null, IDictionary<string, object> headers = null, TimeSpan? timeout = default, CancellationToken cancellationToken = default)
  • public Task<TResponse> Send<TResponse, TRequest>(TRequest request, string path = null, IDictionary<string, object> headers = null, TimeSpan? timeout = default, CancellationToken cancellationToken = default)
  • public virtual Task<TResponse> SendInternal<TResponse>(object request, TimeSpan? timeout, string path, IDictionary<string, object> headers, CancellationToken cancellationToken, IServiceProvider currentServiceProvider = null)
  • public Task Start()
  • public Task Stop()
  • public virtual Task ProduceResponse(object request, IDictionary<string, object> requestHeaders, object response, IDictionary<string, object> responseHeaders, ConsumerSettings consumerSettings)
  • public abstract Task ProduceToTransport(Type messageType, object message, string path, byte[] messagePayload, IDictionary<string, object> messageHeaders = null)
  • public virtual Task Publish(Type messageType, object message, string path = null, IDictionary<string, object> headers = null)
  • public virtual Task Publish<TMessage>(TMessage message, string path = null, IDictionary<string, object> headers = null)
  • public virtual Task<TResponseMessage> Send<TResponseMessage>(IRequestMessage<TResponseMessage> request, CancellationToken cancellationToken)
  • public Task<TResponseMessage> Send<TResponseMessage, TRequestMessage>(TRequestMessage request, CancellationToken cancellationToken)
  • public virtual Task<TResponseMessage> Send<TResponseMessage>(IRequestMessage<TResponseMessage> request, string path = null, IDictionary<string, object> headers = null, CancellationToken cancellationToken = default)
  • public virtual Task<TResponseMessage> Send<TResponseMessage, TRequestMessage>(TRequestMessage request, string path = null, IDictionary<string, object> headers = null, CancellationToken cancellationToken = default)
  • public virtual Task<TResponseMessage> Send<TResponseMessage>(IRequestMessage<TResponseMessage> request, TimeSpan timeout, string path = null, IDictionary<string, object> headers = null, CancellationToken cancellationToken = default)
  • protected virtual Task<TResponseMessage> SendInternal<TResponseMessage>(object request, TimeSpan? timeout, string path, IDictionary<string, object> headers, CancellationToken cancellationToken)
• public class MessageBusHostedService : IHostedService
• public class MessageBusProxy : IMessageBus, IRequestResponseBus, IPublishBus, ICompositeMessageBus
• public class MessageHandler : IMessageHandler
• public static class MessageHeaderExtensions
  • public static bool TryGetHeader(this IReadOnlyDictionary<string, object> headers, string header, out object value)
  • public static bool TryGetHeader(this IReadOnlyDictionary<string, object> headers, string header, out string value)
  • public static bool TryGetHeader(this IReadOnlyDictionary<string, object> headers, string header, out DateTimeOffset dt)
  • public static bool TryGetHeader(this IReadOnlyDictionary<string, object> headers, string header, out Nullable dt)
• public class MessageQueueWorker<TMessage> : IDisposable
  • public ConsumerInstancePoolMessageProcessor<TMessage> ConsumerInstancePool { get; }
  • public IMessageProcessor<TMessage> MessageProcessor { get; }
  • public MessageQueueWorker(IMessageProcessor<TMessage> messageProcessor, ICheckpointTrigger checkpointTrigger, ILoggerFactory loggerFactory)
  • public MessageQueueWorker(ConsumerInstancePoolMessageProcessor<TMessage> consumerInstancePool, ICheckpointTrigger checkpointTrigger, ILoggerFactory loggerFactory)
  • public ValueTask DisposeAsync()
  • protected virtual ValueTask DisposeAsyncCore()
  • public virtual bool Submit(TMessage message, IReadOnlyDictionary<string, object> messageHeaders, CancellationToken cancellationToken)
  • protected virtual void Dispose(bool disposing)
  • public void Dispose()
  • public virtual bool Submit(TMessage message)
• public static class MessageScope
  • public static IDependencyResolver Current { get; set; }
• public struct MessageWithHeaders : IEquatable<MessageWithHeaders>
  • public IReadOnlyDictionary<string, object> Headers { get; }
  • public IDictionary<string, object> Headers { get; }
  • public MessageWithHeaders(byte[] payload, IReadOnlyDictionary<string, object> headers)
  • public MessageWithHeaders(byte[] payload)
  • public MessageWithHeaders(byte[] payload, Dictionary<string, object> headers)
• public class ProducerContext : IProducerContext
• public class PublishContext : ProducerContext
• public static class ReflectionUtils
• public class ResponseMessageProcessor<TMessage> : IMessageProcessor<TMessage>, IDisposable
  • public IReadOnlyCollection<AbstractConsumerSettings> ConsumerSettings { get; }
  • public ResponseMessageProcessor(RequestResponseSettings requestResponseSettings, MessageBusBase messageBus, Func<TMessage, byte[]> messageProvider)
  • public ValueTask DisposeAsync()
  • protected virtual ValueTask DisposeAsyncCore()
  • public Task<Exception> ProcessMessage(TMessage message, IReadOnlyDictionary<string, object> messageHeaders, CancellationToken cancellationToken, IMessageTypeConsumerInvokerSettings consumerInvoker)
  • public Task<ValueTuple<Exception, AbstractConsumerSettings, object>> ProcessMessage(TMessage message, IReadOnlyDictionary<string, object> messageHeaders, CancellationToken cancellationToken)
  • public ResponseMessageProcessor(RequestResponseSettings requestResponseSettings, MessageBusBase messageBus, Func<TMessage, MessageWithHeaders> messageProvider)
  • protected virtual void Dispose(bool disposing)
  • public void Dispose()
  • public Task<Exception> ProcessMessage(TMessage message)
• public class SendContext : ProducerContext
• public static class ServiceCollectionExtensions
• public class TaskMarker
  • public bool CanRun { get; set; }
  • public bool IsRunning { get; set; }
  • public TaskMarker()
  • public void OnFinished()
  • public void OnStarted()
  • public Task Stop()
• public static class Utils
  • public static ValueTask DisposeSilently(this IAsyncDisposable disposable, Action<Exception> failed = null)
  • public static ValueTask DisposeSilently(this IAsyncDisposable disposable, Func<string> nameFunc, ILogger logger)
  • public static ValueTask DisposeSilently(this IAsyncDisposable disposable, string name, ILogger logger)
• public sealed class Void

SlimMessageBus.Host.Collections

• public class GenericTypeCache<TFunc> : IGenericTypeCache<TFunc>, IReadOnlyCache<Type, TFunc> where TFunc : Delegate
• public class GenericTypeCache2<TFunc> : IGenericTypeCache2<TFunc>, IReadOnlyCache<ValueTuple<Type, Type>, TFunc> where TFunc : Delegate
• public interface IGenericTypeCache<TFunc> : IReadOnlyCache<Type, TFunc> where TFunc : Delegate
• public interface IGenericTypeCache2<TFunc> : IReadOnlyCache<ValueTuple<Type, Type>, TFunc> where TFunc : Delegate
• public interface IReadOnlyCache<TKey, TValue>
• public interface IRuntimeTypeCache
• public class ProducerByMessageTypeCache<TProducer> : IReadOnlyCache<Type, TProducer>
• public class RuntimeTypeCache : IRuntimeTypeCache
• public class SafeDictionaryWrapper<TKey, TValue>
  • public IReadOnlyDictionary<TKey, TValue> Dictionary { get; }
  • public TValue this[TKey key] { get; }
  • public IDictionary<TKey, TValue> Dictonary { get; }
  • public IReadOnlyCollection<TValue> ClearAndSnapshot()
  • public void Mutate(Action<IDictionary<TKey, TValue>> action)
  • public void Set(TKey key, TValue value)
  • public IReadOnlyCollection<TValue> Snapshot()
  • public bool TryGet(TKey key, out TValue value)
• public class TaskOfTypeCache

SlimMessageBus.Host.Config

• public abstract class AbstractConsumerBuilder
• public abstract class AbstractConsumerBuilder<T>
  • public Type MessageType { get; }
  • public MessageBusSettings Settings { get; }
  • protected AbstractConsumerBuilder(MessageBusSettings settings)
  • protected AbstractConsumerBuilder(MessageBusSettings settings, Type messageType)
• public abstract class AbstractHandlerBuilder<TRequest, THandlerBuilder> : AbstractConsumerBuilder where THandlerBuilder : AbstractHandlerBuilder<TRequest, THandlerBuilder>
• public abstract class AbstractTopicConsumerBuilder
  • public ConsumerSettings ConsumerSettings { get; }
  • public Type MessageType { get; }
  • public string Path { get; }
  • public MessageBusSettings Settings { get; }
  • protected AbstractTopicConsumerBuilder(string path, Type messageType, MessageBusSettings settings)
  • public TBuilder AttachEvents<TBuilder>(Action<IConsumerEvents> eventsConfig) where TBuilder : AbstractTopicConsumerBuilder
  • public T Do<T>(Action<T> builder) where T : AbstractTopicConsumerBuilder
• public class ConsumerBuilder<T> : AbstractConsumerBuilder<T>
  • public ConsumerBuilder(MessageBusSettings settings)
  • public ConsumerBuilder<T> AttachEvents(Action<IConsumerEvents> eventsConfig)
  • public ConsumerBuilder<T> DisposeConsumerEnabled(bool enabled)
  • public ConsumerBuilder<T> Do(Action<ConsumerBuilder<T>> action)
  • public ConsumerBuilder<T> Instances(int numberOfInstances)
  • public ConsumerBuilder<T> Path(string path)
  • public ConsumerBuilder<T> Path(string path, Action<ConsumerBuilder<T>> pathConfig)
  • public ConsumerBuilder<T> PerMessageScopeEnabled(bool enabled)
  • public ConsumerBuilder<T> Topic(string topic)
  • public ConsumerBuilder<T> Topic(string topic, Action<ConsumerBuilder<T>> topicConfig)
  • public ConsumerBuilder<T> WhenUndeclaredMessageTypeArrives(Action<UndeclaredMessageTypeSettings> action)
  • public ConsumerBuilder<T> WithConsumer<TConsumer>() where TConsumer : IConsumer<T>
  • public ConsumerBuilder<T> WithConsumer<TConsumer, TMessage>() where TConsumer : IConsumer<TMessage> where TMessage : T
  • public ConsumerBuilder<T> WithConsumer(Type derivedConsumerType, Type derivedMessageType)
  • public ConsumerBuilder<T> WithConsumer<TConsumer>(Func<TConsumer, T, Task> consumerMethod)
  • public ConsumerBuilder<T> WithConsumer<TConsumer>(string consumerMethodName)
  • public ConsumerBuilder<T> WithConsumer(Type consumerType, string consumerMethodName = null)
  • public TopicConsumerBuilder<T> Topic(string topic)
  • public TopicConsumerBuilder<T> Topic(string topic, Action<TopicConsumerBuilder<T>> topicConfig)
• public class ConsumerSettings : AbstractConsumerSettings
  • public Func<object, object, Task> ConsumerMethod { get; set; }
  • public Func<object, object, string, Task> ConsumerMethod { get; set; }
  • public Func<Task, object> ConsumerMethodResult { get; set; }
  • public ISet<IMessageTypeConsumerInvokerSettings> Invokers { get; }
  • public bool IsRequestMessage { get; }
  • public ConsumerSettings ParentSettings { get; }
  • public UndeclaredMessageTypeSettings UndeclaredMessageType { get; set; }
• public class DiscoveryConsumerType
• public class DiscoveryProspectType
• public class HandlerBuilder<TRequest> : AbstractHandlerBuilder<TRequest, HandlerBuilder<TRequest>>
• public class HandlerBuilder<TRequest, TResponse> : AbstractConsumerBuilder<TRequest>
  • public HandlerBuilder(MessageBusSettings settings, Type requestType = null, Type responseType = null)
  • public HandlerBuilder<TRequest, TResponse> WithHandler<THandler>() where THandler : IRequestHandler<TRequest, TResponse>
  • public HandlerBuilder<TRequest, TResponse> WithHandler<THandler, TDerivedRequest>() where THandler : IRequestHandler<TDerivedRequest, TResponse> where TDerivedRequest : TRequest
  • public HandlerBuilder(MessageBusSettings settings)
  • public TopicHandlerBuilder<TRequest, TResponse> Topic(string topic)
  • public TopicHandlerBuilder<TRequest, TResponse> Topic(string topic, Action<TopicHandlerBuilder<TRequest, TResponse>> topicConfig)
• public interface IMessageBusConfigurator
• public interface IMessageTypeConsumerInvokerSettings
• public class MessageBusBuilder
  • public Func<MessageBusSettings, IMessageBus> BusFactory { get; }
  • public IDictionary<string, MessageBusBuilder> Children { get; }
  • public IServiceCollection Services { get; }
  • protected MessageBusBuilder(MessageBusBuilder other)
  • public MessageBusBuilder AddChildBus(string busName, Action<MessageBusBuilder> builderAction)
  • public MessageBusBuilder AutoStartConsumersEnabled(bool enabled)
  • public MessageBusBuilder Handle<TRequest>(Action<HandlerBuilder<TRequest>> builder)
  • public MessageBusBuilder Handle(Type requestType, Type responseType, Action<HandlerBuilder<object, object>> builder)
  • public MessageBusBuilder Handle(Type requestType, Action<HandlerBuilder<object>> builder)
  • public MessageBusBuilder WithDependencyResolver(IServiceProvider serviceProvider)
  • public MessageBusBuilder WithDependencyResolver(IDependencyResolver dependencyResolver)
  • public MessageBusBuilder WithLoggerFacory(ILoggerFactory loggerFactory)
  • public MessageBusBuilder WithSerializer<T>()
  • public MessageBusBuilder WithSerializer(Type serializerType)
  • public MessageBusBuilder WithSerializer(IMessageSerializer serializer)
• public class MessageBusSettings : IBusEvents, IProducerEvents, IConsumerEvents
  • public bool AutoStartConsumers { get; set; }
  • public IDependencyResolver DependencyResolver { get; set; }
  • public ILoggerFactory LoggerFactory { get; set; }
  • public string Name { get; set; }
  • public Type SerializerType { get; set; }
  • public IServiceProvider ServiceProvider { get; set; }
  • public IMessageSerializer Serializer { get; set; }
• public class MessageTypeConsumerInvokerSettings : IMessageTypeConsumerInvokerSettings
• public class ProducerBuilder<T>
  • public Type MessageType { get; }
  • public ProducerBuilder<T> DefaultPath(string path)
• public class ReflectionDiscoveryScanner
• public class UndeclaredMessageTypeSettings
• public class TopicConsumerBuilder<TMessage> : AbstractTopicConsumerBuilder
  • public TopicConsumerBuilder(string topic, Type messageType, MessageBusSettings settings)
  • public TopicConsumerBuilder<TMessage> AttachEvents(Action<IConsumerEvents> eventsConfig)
  • public TopicConsumerBuilder<TMessage> DisposeConsumerEnabled(bool enabled)
  • public TopicConsumerBuilder<TMessage> Do(Action<TopicConsumerBuilder<TMessage>> action)
  • public TopicConsumerBuilder<TMessage> Instances(int numberOfInstances)
  • public TopicConsumerBuilder<TMessage> PerMessageScopeEnabled(bool enabled)
  • public TopicConsumerBuilder<TMessage> WithConsumer<TConsumer>() where TConsumer : IConsumer<TMessage>
  • public TopicConsumerBuilder<TMessage> WithConsumer<TConsumer>(Func<TConsumer, TMessage, string, Task> consumerMethod)
  • public TopicConsumerBuilder<TMessage> WithConsumer<TConsumer>(string consumerMethodName)
  • public TopicConsumerBuilder<TMessage> WithConsumer(Type consumerType, string methodName = null)
• public class TopicHandlerBuilder<TRequest, TResponse> : AbstractTopicConsumerBuilder
  • public TopicHandlerBuilder(string path, MessageBusSettings settings)
  • public TopicHandlerBuilder<TRequest, TResponse> AttachEvents(Action<IConsumerEvents> eventsConfig)
  • public TopicHandlerBuilder<TRequest, TResponse> Do(Action<TopicHandlerBuilder<TRequest, TResponse>> action)
  • public TopicHandlerBuilder<TRequest, TResponse> Instances(int numberOfInstances)
  • public TopicHandlerBuilder<TRequest, TResponse> WithHandler<THandler>() where THandler : IRequestHandler<TRequest, TResponse>

SlimMessageBus.Host.Consumer

• public static class MessageScope
• public sealed class MessageScopeWrapper : IAsyncDisposable