SlimMessageBus.Host by zarusz

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

---

API Diff between 1.14.1 and 1.11.0

56 Additions 15 Removals

SlimMessageBus.Host

• public class ConcurrencyIncreasingMessageProcessorDecorator<TMessage> : IMessageProcessor<TMessage>, IDisposable
  • public int PendingCount { get; }
  • 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 ConsumerInstanceMessageProcessor<TMessage> : IMessageProcessor<TMessage>, IDisposable
  • public ConsumerInstanceMessageProcessor(ConsumerSettings consumerSettings, MessageBusBase messageBus, Func<TMessage, byte[]> messagePayloadProvider, Action<TMessage, ConsumerContext> consumerContextInitializer = null)
  • protected void DeserializeMessage(TMessage msg, out MessageWithHeaders requestMessage, out string requestId, out Nullable expires, out object message)
  • public void Dispose()
  • protected virtual void Dispose(bool disposing)
  • public virtual Task<Exception> ProcessMessage(TMessage msg)
• public class ConsumerInstancePoolMessageProcessor<TMessage> : IMessageProcessor<TMessage>, IDisposable
  • protected void DeserializeMessage(TMessage msg, out MessageWithHeaders requestMessage, out string requestId, out Nullable expires, out object message)
• public abstract class MessageBusBase : IMessageBus, IDisposable, IRequestResponseBus, IPublishBus
  • public virtual bool IsMessageScopeEnabled(ConsumerSettings consumerSettings)
  • public Task<TResponseMessage> Send<TResponseMessage, TRequestMessage>(TRequestMessage request, CancellationToken cancellationToken)
  • public virtual Task<TResponseMessage> Send<TResponseMessage, TRequestMessage>(TRequestMessage request, string path = null, CancellationToken cancellationToken = default)
  • protected virtual Task<TResponseMessage> SendInternal<TResponseMessage>(IRequestMessage<TResponseMessage> request, TimeSpan? timeout, string name, CancellationToken cancellationToken)
  • protected virtual Task<TResponseMessage> SendInternal<TResponseMessage>(object request, TimeSpan? timeout, string name, CancellationToken cancellationToken)
• public static class MessageScope
  • public static IDependencyResolver Current { get; set; }

SlimMessageBus.Host.Collections

• public class KindMapping
  • public KindMapping()
  • public void Configure(MessageBusSettings settings)
  • public PathKind GetKind(Type messageType, string path)

SlimMessageBus.Host.Config

• public abstract class AbstractConsumerBuilder<T>
  • public TBuilder AttachEvents<TBuilder>(Action<IConsumerEvents> eventsConfig) where TBuilder : AbstractConsumerBuilder<T>
• public abstract class AbstractConsumerSettings : HasProviderExtensions, IConsumerEvents
  • public Action<IMessageBus, AbstractConsumerSettings, object, string> OnMessageArrived { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object> OnMessageExpired { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object, Exception> OnMessageFault { get; set; }
  • public string Topic { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object, string, object> OnMessageArrived { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object, object> OnMessageExpired { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object, Exception, object> OnMessageFault { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object, string, object> OnMessageFinished { get; set; }
  • public string Path { get; set; }
  • public PathKind PathKind { get; set; }
• public abstract class AbstractTopicConsumerBuilder
  • public string Path { get; }
  • public string Topic { get; }
  • public TBuilder AttachEvents<TBuilder>(Action<IConsumerEvents> eventsConfig) where TBuilder : AbstractTopicConsumerBuilder
• public class ConsumerSettings : AbstractConsumerSettings
  • public bool IsDisposeConsumerEnabled { get; set; }
  • public bool? IsMessageScopeEnabled { get; set; }
• public interface IConsumerEvents
  • Action<IMessageBus, AbstractConsumerSettings, object, string> OnMessageArrived { get; set; }
  • Action<IMessageBus, AbstractConsumerSettings, object> OnMessageExpired { get; set; }
  • Action<IMessageBus, AbstractConsumerSettings, object, Exception> OnMessageFault { get; set; }
  • Action<IMessageBus, AbstractConsumerSettings, object, string, object> OnMessageArrived { get; set; }
  • Action<IMessageBus, AbstractConsumerSettings, object, object> OnMessageExpired { get; set; }
  • Action<IMessageBus, AbstractConsumerSettings, object, Exception, object> OnMessageFault { get; set; }
  • Action<IMessageBus, AbstractConsumerSettings, object, string, object> OnMessageFinished { get; set; }
• public class MessageBusBuilder
  • public MessageBusBuilder PerMessageScopeEnabled(bool enabled)
• public class MessageBusSettings : IBusEvents, IProducerEvents, IConsumerEvents
  • public bool? IsMessageScopeEnabled { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object, string> OnMessageArrived { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object> OnMessageExpired { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object, Exception> OnMessageFault { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object, string, object> OnMessageArrived { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object, object> OnMessageExpired { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object, Exception, object> OnMessageFault { get; set; }
  • public Action<IMessageBus, AbstractConsumerSettings, object, string, object> OnMessageFinished { get; set; }
• public enum PathKind
  • Queue = 1
  • Topic = 0
• public class ProducerSettings : HasProviderExtensions, IProducerEvents
  • public string DefaultTopic { get; set; }
  • public string DefaultPath { get; set; }
  • public PathKind PathKind { get; set; }
• public class TopicConsumerBuilder<TMessage> : AbstractTopicConsumerBuilder
  • public TopicConsumerBuilder<TMessage> AttachEvents(Action<IConsumerEvents> eventsConfig)
  • public TopicConsumerBuilder<TMessage> DisposeConsumerEnabled(bool enabled)
  • public TopicConsumerBuilder<TMessage> PerMessageScopeEnabled(bool enabled)
• public class TopicHandlerBuilder<TRequest, TResponse> : AbstractTopicConsumerBuilder
  • public TopicHandlerBuilder<TRequest, TResponse> AttachEvents(Action<IConsumerEvents> eventsConfig)