EasyNetQ by Mike Hadlow, Chris Edwards, A Hazelwood

<PackageReference Include="EasyNetQ" Version="0.33.2.277" />

---

API Diff between 0.33.2.277 and 0.35.3.295

2 Additions 39 Removals

EasyNetQ

• public class BasicGetResult : IBasicGetResult
• public class BasicGetResult<T> : IBasicGetResult<T>
• public class DeliveryModeAttribute : Attribute
• public interface IAdvancedBus : IDisposable
  • Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey)
  • Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey)
  • Task<IExchange> ExchangeDeclareAsync(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null)
  • IBasicGetResult<T> Get<T>(IQueue queue)
  • IBasicGetResult Get(IQueue queue)
  • Task<IQueue> QueueDeclareAsync(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int perQueueTtl = 2147483647, int expires = 2147483647, string deadLetterExchange = null)
• public interface IBasicGetResult
• public interface IBasicGetResult<T>
• public interface IMessageDeliveryModeStrategy
• public class MessageDeliveryModeStrategy : IMessageDeliveryModeStrategy
• public class MessageNotAvailableException : Exception
• public class RabbitAdvancedBus : IAdvancedBus, IDisposable
  • public Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey)
  • public Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey)
  • public Task<IExchange> ExchangeDeclareAsync(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null)
  • public IBasicGetResult<T> Get<T>(IQueue queue)
  • public IBasicGetResult Get(IQueue queue)
  • public Task<IQueue> QueueDeclareAsync(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int perQueueTtl = 2147483647, int expires = 2147483647, string deadLetterExchange = null)
• public class RabbitBus : IBus, IDisposable
  • public RabbitBus(IEasyNetQLogger logger, IConventions conventions, IAdvancedBus advancedBus, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IRpc rpc, ISendReceive sendReceive, IConnectionConfiguration connectionConfiguration)
  • public RabbitBus(IEasyNetQLogger logger, IConventions conventions, IAdvancedBus advancedBus, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IRpc rpc, ISendReceive sendReceive, IConnectionConfiguration connectionConfiguration)
• public static class ReflectionHelpers
• public static class TaskHelpers
  • public static Task Completed { get; }
  • public static Task<T> FromResult<T>(T value)
  • public static Task<T2> Then<T1, T2>(Task<T1> first, Func<T2> next)
  • public static Task<T2> Then<T2>(Task first, Func<T2> next)
  • public static Task Then<T1>(Task<T1> first, Func<T1, Task> next)
  • public static Task<T2> Then<T1, T2>(Task<T1> first, Func<T1, Task<T2>> next)

EasyNetQ.AutoSubscribe

• public class AutoSubscriber
  • protected Action<ISubscriptionConfiguration> ConfigureSubscriptionConfiguration { get; set; }
• public class SubscriptionConfigurationAttribute : Attribute

EasyNetQ.MessageVersioning

• public class VersionedPublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
  • public Task<IExchange> DeclareExchangeAsync(IAdvancedBus advancedBus, string exchangeName, string exchangeType)
  • public Task<IExchange> DeclareExchangeAsync(IAdvancedBus advancedBus, Type messageType, string exchangeType)

EasyNetQ.Producer

• public interface IPublishExchangeDeclareStrategy
  • Task<IExchange> DeclareExchangeAsync(IAdvancedBus advancedBus, string exchangeName, string exchangeType)
  • Task<IExchange> DeclareExchangeAsync(IAdvancedBus advancedBus, Type messageType, string exchangeType)
• public class PublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
  • public Task<IExchange> DeclareExchangeAsync(IAdvancedBus advancedBus, string exchangeName, string exchangeType)
  • public Task<IExchange> DeclareExchangeAsync(IAdvancedBus advancedBus, Type messageType, string exchangeType)
• public class Rpc : IRpc
  • protected virtual void OnResponderFailure<TRequest, TResponse>(IMessage<TRequest> requestMessage, string exceptionMessage, Exception exception)
  • protected virtual void OnResponderSuccess<TRequest, TResponse>(IMessage<TRequest> requestMessage, TResponse response)
• public class SendReceive : ISendReceive
  • public SendReceive(IAdvancedBus advancedBus, IMessageDeliveryModeStrategy messageDeliveryModeStrategy)
  • public SendReceive(IAdvancedBus advancedBus, IConnectionConfiguration connectionConfiguration)