RawRabbit.Extensions by par.dahlman

<PackageReference Include="RawRabbit.Extensions" Version="1.10.0" />

---

API Diff between 1.10.0 and 1.9.0-rc1-update2

35 Additions 6 Removals

RawRabbit.Extensions.BulkGet

• public static class BulkGetExtension
  • public static BulkResult<TContextType> GetMessages<TContextType>(this IBusClient<TContextType> client, Action<IBulkGetConfigurationBuilder> cfg) where TContextType : IMessageContext
  • public static BulkResult<TMessageContext> GetMessages<TMessageContext>(this IBusClient<TMessageContext> client, Action<IBulkGetConfigurationBuilder> cfg) where TMessageContext : IMessageContext

RawRabbit.Extensions.CleanEverything.Http

• public static class ContentType
• public enum HttpMethod
• public class WebRequester

RawRabbit.Extensions.Client

• public interface IBusClient : IBusClient<MessageContext>, IBusClient<MessageContext>, IShutdown
• public interface IBusClient<TMessageContext> : IBusClient<TMessageContext>, IShutdown where TMessageContext : IMessageContext
  • TService GetService<TService>()
• public static class IServiceCollectionExtension
  • public static IServiceCollection AddRawRabbit<TMessageContext>(this IServiceCollection collection, Action<IConfigurationBuilder> config = null, Action<IServiceCollection> custom = null) where TMessageContext : IMessageContext
  • public static IServiceCollection AddRawRabbit(this IServiceCollection collection, Action<IConfigurationBuilder> config = null, Action<IServiceCollection> custom = null)
  • public static IServiceCollection AddRawRabbit(this IServiceCollection collection, IConfigurationSection section, Action<IServiceCollection> custom = null)
• public class RawRabbitFactory
  • public static IBusClient<MessageContext> GetExtendableClient(Action<IServiceCollection> custom = null)
  • public static IBusClient<TMessageContext> Create<TMessageContext>(Action<IServiceCollection> custom = null) where TMessageContext : IMessageContext
  • public static IBusClient Create(Action<IServiceCollection> custom = null)
  • public static IBusClient<MessageContext> GetExtendableClient(Action<IServiceCollection> custom = null)
• public class TransientFactory<TMessageContext> : IDisposable where TMessageContext : IMessageContext
  • public TransientFactory(Action<IConfigurationBuilder> config, Action<IServiceCollection> custom)
  • public static TransientFactory<TMessageContext> Create(Action<IConfigurationBuilder> config = null, Action<IServiceCollection> custom = null)
  • public IBusClient<TMessageContext> CreateClient()
  • public void Dispose()

RawRabbit.Extensions.Disposable

• public class BusClient : IBusClient, IBusClient, IBusClient<MessageContext>, IBusClient<MessageContext>, IShutdown, IDisposable
  • public BusClient(IBusClient client)
  • public void Dispose()
  • public TService GetService<TService>()
  • public Task PublishAsync<T>(T message = null, Guid globalMessageId = default, Action<IPublishConfigurationBuilder> configuration = null)
  • public Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest message = null, Guid globalMessageId = default, Action<IRequestConfigurationBuilder> configuration = null)
  • public ISubscription RespondAsync<TRequest, TResponse>(Func<TRequest, MessageContext, Task<TResponse>> onMessage, Action<IResponderConfigurationBuilder> configuration = null)
  • public Task ShutdownAsync(TimeSpan? graceful = default)
  • public ISubscription SubscribeAsync<T>(Func<T, MessageContext, Task> subscribeMethod, Action<ISubscriptionConfigurationBuilder> configuration = null)
• public class BusClient<TMessageContext> : IBusClient<TMessageContext>, IBusClient<TMessageContext>, IShutdown, IDisposable where TMessageContext : IMessageContext
  • public BusClient(IBusClient<TMessageContext> client)
  • public void Dispose()
  • public Task PublishAsync<T>(T message = null, Guid globalMessageId = default, Action<IPublishConfigurationBuilder> configuration = null)
  • public Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest message = null, Guid globalMessageId = default, Action<IRequestConfigurationBuilder> configuration = null)
  • public ISubscription RespondAsync<TRequest, TResponse>(Func<TRequest, TMessageContext, Task<TResponse>> onMessage, Action<IResponderConfigurationBuilder> configuration = null)
  • public Task ShutdownAsync(TimeSpan? graceful = default)
  • public ISubscription SubscribeAsync<T>(Func<T, TMessageContext, Task> subscribeMethod, Action<ISubscriptionConfigurationBuilder> configuration = null)
• public interface IBusClient : IBusClient, IBusClient<MessageContext>, IBusClient<MessageContext>, IShutdown, IDisposable
• public interface IBusClient<TMessageContext> : IBusClient<TMessageContext>, IShutdown, IDisposable where TMessageContext : IMessageContext

RawRabbit.Extensions.MessageSequence.Configuration

• public class MessageSequenceBuilder<TMessageContext> : IMessageChainPublisher<TMessageContext>, IMessageSequenceBuilder<TMessageContext> where TMessageContext : IMessageContext
  • public MessageSequenceBuilder(IBusClient<TMessageContext> busClient, IMessageChainTopologyUtil chainTopology, IMessageChainDispatcher dispatcher, IMessageSequenceRepository repository)
  • public MessageSequenceBuilder(IBusClient<TMessageContext> busClient, IMessageChainTopologyUtil chainTopology, IMessageChainDispatcher dispatcher, IMessageSequenceRepository repository, RawRabbitConfiguration mainCfg)