RawRabbit by pardahlman, enrique-avalon

<PackageReference Include="RawRabbit" Version="2.0.0-beta1" />

---

API Diff between 2.0.0-beta1 and 2.0.0-beta5

202 Additions 33 Removals

RawRabbit.Advanced

• public static class CreateChannelExtension
• public static class CreateConsumerExtension
• public static class DeclareQueueExtension

RawRabbit.Common

• public class BasicPropertiesProvider : IBasicPropertiesProvider
  • public BasicPropertiesProvider(RawRabbitConfiguration config)
  • public IBasicProperties GetProperties<TMessage>(Action<IBasicProperties> custom = null)
  • public IBasicProperties GetProperties(Type msgType, Action<IBasicProperties> custom = null)
  • public IBasicProperties GetProperties(Action<IBasicProperties> custom = null)
• public interface IBasicPropertiesProvider
  • IBasicProperties GetProperties<TMessage>(Action<IBasicProperties> custom = null)
  • IBasicProperties GetProperties(Type type, Action<IBasicProperties> custom = null)
  • IBasicProperties GetProperties(Action<IBasicProperties> custom = null)
• public interface INamingConventions
  • Func<string> DeadLetterExchangeNamingConvention { get; set; }
  • Func<string> RetryQueueNamingConvention { get; set; }
• public interface IResourceDisposer : IDisposable
  • Task ShutdownAsync(TimeSpan? graceful = default)
• public interface ISubscription : IDisposable
  • bool Active { get; }
  • string ConsumerTag { get; }
  • string QueueName { get; }
• public class NamingConventions : INamingConventions
  • public virtual Func<string> DeadLetterExchangeNamingConvention { get; set; }
  • public virtual Func<string> RetryQueueNamingConvention { get; set; }
• public class PropertyHeaders
  • public static readonly string GlobalExecutionId
• public class ResourceDisposer : IResourceDisposer, IDisposable
  • public ResourceDisposer(IChannelFactory channelFactory, IConnectionFactory connectionFactory, ISubscriptionRepository subscriptionRepo, RawRabbitConfiguration config)
  • public ResourceDisposer(IChannelFactory channelFactory, IConnectionFactory connectionFactory)
  • public Task ShutdownAsync(TimeSpan? graceful = default)
• public class Subscription : ISubscription, IDisposable
  • public bool Active { get; set; }
  • public string ConsumerTag { get; }
  • public string QueueName { get; }
  • public Subscription(IBasicConsumer consumer, string queueName)
  • public void Dispose()

RawRabbit.Configuration.BasicPublish

• public class BasicPublishConfigurationFactory : IBasicPublishConfigurationFactory
  • public BasicPublishConfigurationFactory(INamingConventions conventions, ISerializer serializer, RawRabbitConfiguration config)
  • public BasicPublishConfigurationFactory(INamingConventions conventions, IBasicPropertiesProvider provider, ISerializer serializer)

RawRabbit.DependecyInjection

• public static class RawRabbitDependencyRegisterExtension
  • public static IDependecyRegister AddRawRabbit(this IDependecyRegister register, RawRabbitOptions options = null)
  • public static IDependecyRegister AddRawRabbit(this IDependecyRegister register)

RawRabbit.Instantiation

• public class ClientBuilder : IClientBuilder
  • public Action<IDependecyRegister> DependencyInjection { get; set; }
  • public Action<IDependecyRegister> ServiceAction { get; set; }
• public class InstanceFactory : IDisposable, IInstanceFactory
  • public Task ShutdownAsync(TimeSpan? graceful = default)

RawRabbit.Pipe

• public class CachedPipeBuilderFactory : IPipeBuilderFactory
  • public CachedPipeBuilderFactory(IDependecyResolver resolver)
  • public CachedPipeBuilderFactory(Func<IExtendedPipeBuilder> pipeBuilder)
• public static class DictionaryExtensions
  • public static bool AddOrReplace<TKey, TValue>(this IDictionary<TKey, TValue> dictionary, TKey key, TValue value)
• public class PipeBuilderFactory : IPipeBuilderFactory
  • public PipeBuilderFactory(IDependecyResolver resolver)
  • public PipeBuilderFactory(Func<IExtendedPipeBuilder> pipeBuilder)
• public static class PipeContextExtension
  • public static BasicGetResult GetBasicGetResult(this IPipeContext context)
  • public static List<Action<IBasicPublishConfigurationBuilder>> GetBasicPublishActions(this IPipeContext context, Type type = null)
  • public static List<Action<IConsumeConfigurationBuilder>> GetConsumeActions(this IPipeContext context, Type type = null)
  • public static List<Action<IExchangeDeclarationBuilder>> GetExchangeActions(this IPipeContext context, Type type = null)
  • public static GetConfiguration GetGetConfiguration(this IPipeContext context)
  • public static string GetGlobalExecutionId(this IPipeContext context)
  • public static List<Action<IQueueDeclarationBuilder>> GetQueueActions(this IPipeContext context, Type type = null)
  • public static ISubscription GetSubscription(this IPipeContext context)
  • public static ISubscription GetSubscription(this IPipeContext context)
• public static class PipeKey
  • public const string BasicGetResult = "BasicGetResult"
  • public const string BasicPublishActions = "BasicPublishActions"
  • public const string CancellationToken = "CancellationToken"
  • public const string ConsumeActions = "ConsumeActions"
  • public const string ExchangeActions = "ExchangeActions"
  • public const string GetConfiguration = "GetConfiguration"
  • public const string GlobalExecutionId = "GlobalExecutionId"
  • public const string Operation = "Operation"
  • public const string QueueActions = "QueueActions"
• public static class StageMarker
  • public const string ProducerInitialized = "ProducerInitialized"

RawRabbit.Pipe.Extensions

• public static class DeleteExchangeExtension
• public static class DeleteQueueExtension
• public static class CreateChannelExtension
  • public static readonly Action<IPipeBuilder> CreateChannelPipe
  • public static Task<IModel> CreateChannelAsync(this IBusClient busClient, ChannelCreationOptions options = null, CancellationToken token = default)

RawRabbit.Pipe.Middleware

• public class AddContextPropertyMiddleware : Middleware
  • protected Func<IPipeContext, string> KeyFunc
  • protected Func<IPipeContext, bool> OverrideExistingFunc
  • protected Func<IPipeContext, object> ValueFunc
  • public AddContextPropertyMiddleware(AddContextPropertyOptions options)
  • protected virtual string GetKey(IPipeContext context)
  • protected virtual object GetValue(IPipeContext context)
  • protected virtual bool OverrideExisting(IPipeContext context)
• public class AddContextPropertyOptions
  • public Func<IPipeContext, string> KeyFunc { get; set; }
  • public Func<IPipeContext, bool> OverrideExistingFunc { get; set; }
  • public Func<IPipeContext, object> ValueFunc { get; set; }
  • public AddContextPropertyOptions()
• public class ApplicationQueueSuffix
  • public Func<IPipeContext, bool> ActivatedFlagFunc { get; set; }
  • public Func<IPipeContext, List<Action<IQueueDeclarationBuilder>>> QueueActionListFunc { get; set; }
  • public Func<IPipeContext, Action<IQueueDeclarationBuilder>> QueueSuffixFunc { get; set; }
  • public ApplicationQueueSuffix()
• public class ApplicationQueueSuffixMiddleware : Middleware
  • protected Func<IPipeContext, bool> ActivatedFlagFunc
  • protected INamingConventions Conventsions
  • protected Func<IPipeContext, List<Action<IQueueDeclarationBuilder>>> QueueActionListFunc
  • protected Func<IPipeContext, Action<IQueueDeclarationBuilder>> QueueSuffixFunc
  • public ApplicationQueueSuffixMiddleware(INamingConventions conventsions, ApplicationQueueSuffix options = null)
  • protected virtual void AddSuffixAction(List<Action<IQueueDeclarationBuilder>> queueActions, Action<IQueueDeclarationBuilder> suffixAction)
  • protected virtual bool GetActivatedFlag(IPipeContext context)
  • protected virtual List<Action<IQueueDeclarationBuilder>> GetQueueActionList(IPipeContext context)
  • protected virtual Action<IQueueDeclarationBuilder> GetQueueSuffixAction(IPipeContext context)
• public static class ApplicationSuffixExtension
  • public static bool GetApplicationSuffixFlag(this IPipeContext context)
  • public static IPipeContext UseApplicationQueueSuffix(this IPipeContext context, bool use = true)
• public class BasicGetMiddleware : Middleware
  • protected Func<IPipeContext, IModel> ChannelFunc
  • protected Func<IPipeContext, bool> NoAckFunc
  • protected Action<IPipeContext, BasicGetResult> PostExecutionAction
  • protected Func<IPipeContext, string> QueueNameFunc
  • public BasicGetMiddleware(BasicGetOptions options = null)
  • protected virtual IModel GetChannel(IPipeContext context)
  • protected virtual bool GetNoAck(IPipeContext context)
  • protected virtual string GetQueueName(IPipeContext context)
  • protected virtual BasicGetResult PerformBasicGet(IModel channel, string queueName, bool noAck)
• public class BasicGetOptions
  • public Func<IPipeContext, IModel> ChannelFunc { get; set; }
  • public Func<IPipeContext, bool> NoAckFunc { get; }
  • public Action<IPipeContext, BasicGetResult> PostExecutionAction { get; set; }
  • public Func<IPipeContext, string> QueueNameFunc { get; }
  • public BasicGetOptions()
• public class BasicPropertiesMiddleware : Middleware
  • protected Func<IPipeContext, IBasicProperties> GetOrCreatePropsFunc
  • protected Func<IPipeContext, IBasicProperties> CreatePropsFunc
  • protected virtual IBasicProperties GetOrCreateBasicProperties(IPipeContext context)
  • protected virtual IBasicProperties CreateBasicProperties(IPipeContext context)
• public class BasicPropertiesOptions
  • public Func<IPipeContext, IBasicProperties> GetOrCreatePropsFunc { get; set; }
  • public Func<IPipeContext, IBasicProperties> CreatePropsFunc { get; set; }
• public abstract class ConfigurationMiddlewareBase : Middleware
  • protected ConfigurationMiddlewareBase()
  • protected virtual List<Action<IConsumeConfigurationBuilder>> GetConsumeActions(IPipeContext context, Type messageType = null)
  • protected virtual List<Action<IExchangeDeclarationBuilder>> GetExchangeActions(IPipeContext context, Type messageType)
  • protected virtual List<Action<IBasicPublishConfigurationBuilder>> GetPublishActions(IPipeContext context, Type messageType = null)
  • protected virtual List<Action<IQueueDeclarationBuilder>> GetQueueActions(IPipeContext context, Type messageType)
  • protected virtual void InvokeConsumeActions(IPipeContext context, Type msgType, ConsumeConfiguration consumeCfg)
  • protected virtual void InvokeExchangeActions(IPipeContext context, Type msgType, ExchangeDeclaration exchangeCfg)
  • protected virtual void InvokePublishActions(IPipeContext context, Type msgType, BasicPublishConfiguration publishCfg)
  • protected virtual void InvokeQueueActions(IPipeContext context, Type msgType, QueueDeclaration queueCfg)
• public class CustomQueueSuffixMiddleware : Middleware
  • protected Func<IPipeContext, bool> ActivatedFlagFunc
  • protected Func<IPipeContext, List<Action<IQueueDeclarationBuilder>>> QueueActionListFunc
  • protected Func<IPipeContext, Action<IQueueDeclarationBuilder>> QueueSuffixFunc
  • public CustomQueueSuffixMiddleware(CustomQueueSuffixOptions options = null)
  • protected virtual void AddSuffixAction(List<Action<IQueueDeclarationBuilder>> queueActions, Action<IQueueDeclarationBuilder> suffixAction)
  • protected virtual bool GetActivatedFlag(IPipeContext context)
  • protected virtual List<Action<IQueueDeclarationBuilder>> GetQueueActionList(IPipeContext context)
  • protected virtual Action<IQueueDeclarationBuilder> GetQueueSuffixAction(IPipeContext context)
• public class CustomQueueSuffixOptions
  • public Func<IPipeContext, bool> ActivatedFlagFunc { get; set; }
  • public Func<IPipeContext, List<Action<IQueueDeclarationBuilder>>> QueueActionListFunc { get; set; }
  • public Func<IPipeContext, Action<IQueueDeclarationBuilder>> QueueSuffixFunc { get; set; }
  • public CustomQueueSuffixOptions()
• public static class CustomSuffixExtension
  • public static string GetCustomQueueSuffix(this IPipeContext context)
  • public static IPipeContext UseCustomQueueSuffix(this IPipeContext context, string prefix)
• public class ExchangeDeleteMiddleware : Middleware
• public class ExchangeDeleteOptions
• public class ExecutionIdRoutingMiddleware : Middleware
  • protected Func<IPipeContext, bool> EnableRoutingFunc
  • protected Func<IPipeContext, string> ExecutionIdFunc
  • protected Func<IPipeContext, string, string> UpdateAction
  • public ExecutionIdRoutingMiddleware(ExecutionIdRoutingOptions options = null)
  • protected virtual string GetExecutionId(IPipeContext context)
  • protected virtual bool GetRoutingEnabled(IPipeContext pipeContext)
  • protected virtual void UpdateRoutingKey(IPipeContext context, string executionId)
• public class ExecutionIdRoutingOptions
  • public Func<IPipeContext, bool> EnableRoutingFunc { get; set; }
  • public Func<IPipeContext, string> ExecutionIdFunc { get; set; }
  • public Func<IPipeContext, string, string> UpdateAction { get; set; }
  • public ExecutionIdRoutingOptions()
• public class GetConfigurationMiddleware : Middleware
  • protected Func<IPipeContext, Action<IGetConfigurationBuilder>> ConfigBuilderFunc
  • protected Func<IPipeContext, GetConfiguration> CreateFunc
  • protected Action<IPipeContext, GetConfiguration> PostExecutionAction
  • public GetConfigurationMiddleware(GetConfigurationOptions options = null)
  • protected virtual GetConfiguration CreateConfiguration(IPipeContext context)
  • protected virtual Action<IGetConfigurationBuilder> GetConfigurationAction(IPipeContext context)
  • protected virtual GetConfiguration GetConfiguredConfiguration(GetConfiguration configuration, Action<IGetConfigurationBuilder> action)
• public class GetConfigurationOptions
  • public Func<IPipeContext, Action<IGetConfigurationBuilder>> ConfigBuilderFunc { get; set; }
  • public Func<IPipeContext, GetConfiguration> CreateFunc { get; set; }
  • public Action<IPipeContext, GetConfiguration> PostExecuteAction { get; set; }
  • public GetConfigurationOptions()
• public class GlobalExecutionIdMiddleware : Middleware
  • protected static readonly AsyncLocal<string> ExecutionId
  • protected Func<IPipeContext, string> IdFunc
  • protected Action<IPipeContext, string> PersistAction
  • public GlobalExecutionIdMiddleware(GlobalExecutionOptions options = null)
  • protected virtual string CreateExecutionId(IPipeContext context)
  • protected virtual string GetExecutionIdFromContext(IPipeContext context)
  • protected virtual string GetExecutionIdFromProcess()
  • protected virtual void SaveIdInProcess(string executionId)
• public class GlobalExecutionOptions
  • public Func<IPipeContext, string> IdFunc { get; set; }
  • public Action<IPipeContext, string> PersistAction { get; set; }
  • public GlobalExecutionOptions()
• public class HostnameQueueSuffixMiddleware : Middleware
  • protected Func<IPipeContext, bool> ActivatedFlagFunc
  • protected Func<IPipeContext, List<Action<IQueueDeclarationBuilder>>> QueueActionListFunc
  • protected Func<IPipeContext, Action<IQueueDeclarationBuilder>> QueueSuffixFunc
  • public HostnameQueueSuffixMiddleware(HostnameQueueSuffixOptions options = null)
  • protected virtual void AddSuffixAction(List<Action<IQueueDeclarationBuilder>> queueActions, Action<IQueueDeclarationBuilder> suffixAction)
  • protected virtual bool GetActivatedFlag(IPipeContext context)
  • protected virtual List<Action<IQueueDeclarationBuilder>> GetQueueActionList(IPipeContext context)
  • protected virtual Action<IQueueDeclarationBuilder> GetQueueSuffixAction(IPipeContext context)
• public class HostnameQueueSuffixOptions
  • public Func<IPipeContext, bool> ActivatedFlagFunc { get; set; }
  • public Func<IPipeContext, List<Action<IQueueDeclarationBuilder>>> QueueActionListFunc { get; set; }
  • public Func<IPipeContext, Action<IQueueDeclarationBuilder>> QueueSuffixFunc { get; set; }
  • public HostnameQueueSuffixOptions()
• public static class HostnameSuffixExtension
  • public static bool GetHostnameQueueSuffixFlag(this IPipeContext context)
  • public static IPipeContext UseHostnameQueueSuffix(this IPipeContext context, bool use = true)
• public class PublishAcknowledgeMiddleware : Middleware
  • protected Func<IPipeContext, IModel> ChannelFunc
  • protected Func<IPipeContext, IModel> ChannelFunc
• public class PublishMessage : Middleware
  • public PublishMessage(PublishOptions options = null)
• public class PublishOptions
  • public Func<IPipeContext, string> BodyFunc { get; set; }
  • public Func<IPipeContext, IModel> ChannelFunc { get; set; }
  • public Func<IPipeContext, string> ExchangeFunc { get; set; }
  • public Func<IPipeContext, string> RoutingKeyFunc { get; set; }
  • public PublishOptions()
• public class QueueDeleteMiddleware : Middleware
• public class QueueDeleteOptions
• public class RepeatMiddleware : Middleware
  • protected Func<IPipeContext, IEnumerable> EnumerableFunc
  • protected Func<IPipeContext, IPipeContextFactory, object, IPipeContext> RepeateContextFactory
  • protected Middleware RepeatPipe
  • public RepeatMiddleware(IPipeBuilderFactory factroy, IPipeContextFactory contextFactory, RepeatOptions options)
• public class RepeatOptions
  • public Func<IPipeContext, IEnumerable> EnumerableFunc { get; set; }
  • public Func<IPipeContext, IPipeContextFactory, object, IPipeContext> RepeatContextFactory { get; set; }
  • public Action<IPipeBuilder> RepeatePipe { get; set; }
  • public RepeatOptions()
• public class SubscriptionMiddleware : Middleware
• public class SubscriptionOptions

RawRabbit.Serialization

• public interface ISerializer
  • string ContentType { get; }
• public class JsonSerializer : ISerializer
  • public string ContentType { get; }

RawRabbit.Subscription

• public interface ISubscription : IDisposable
• public interface ISubscriptionRepository
• public class Subscription : ISubscription, IDisposable
• public class SubscriptionRepository : ISubscriptionRepository